-----------------------------------------------------------------------
--           Code Archetypes for the CHESS Component Model           --
--                                                                   --
--                   Copyright (C) 2011-2012                         --
--                 University of Padova, ITALY                       --
--                                                                   --
-- Author: Marco Panunzio         panunzio@math.unipd.it             --
--                                                                   --
-- All rights reserved. This program and the accompanying materials  --
-- are made available under the terms of the Eclipse Public License  --
-- v1.0 which accompanies this distribution, and is available at     --
-- http://www.eclipse.org/legal/epl-v20.html                         --
-----------------------------------------------------------------------

with System_Time;
with Ada.Real_Time;
with Ada.Text_IO; use Ada.Text_IO;
with Middleware_Realtime_Attribute;

package body Remote_Msg_Server_Task is

   use Ada.Real_Time;

   task body Thread_T is
      Task_Period : constant Time_Span := Milliseconds(Period);
      Next_Time : Time := System_Time.System_Start_Time +
        System_Time.Task_Activation_Delay;
      Assigned_Task_ID : constant Task_Gen_ID := My_Task_ID;

   begin
      -- Initialize the Remote Msg Server

      delay until System_Time.System_Start_Time +
        Ada.Real_Time.Milliseconds(Middleware_Realtime_Attribute.Remote_Msg_Server_Init_Delay);

      Ada.Text_IO.Put_Line("Initializing Remote Msg Server...");
      Init_Operation.all;
      -- Suspend the task until first release;
      Ada.Text_IO.Put_Line("Initialization of Remote Msg Server complete.");
      Ada.Text_IO.Put_Line(" ************************* ");
      Ada.Text_IO.New_Line;
      Ada.Text_IO.New_Line;
      delay until Next_Time;

      Put("Remote Msg Server Task ");
      Put(Natural'Image(Natural(Assigned_Task_ID)));
      Put_Line(" first activation");

      Task_Loop :
      loop
         --  Execute the sequential operation
         Operation.all;
         -- Calculate new release time and suspend
         Next_Time:= Next_Time + Task_Period;
         delay until Next_Time;

      end loop Task_Loop;

   end Thread_T;

end Remote_Msg_Server_Task;