* Test cases for LNT backend

	(By Hana Mkaouar)

tests/LNT/FCS/FCS.aadl

+package FlightControlSystem
+public
+  data Alpha
+
+  end Alpha;
+thread NL
+  --  Navigation Law
+features
+  pos_c : in   event data port  Alpha;
+  pos_o : in   event data port  Alpha;
+  acc_c : out  event data port  Alpha;
+properties
+  Dispatch_Protocol      => Periodic;
+  Period                 => 120 ms;
+  Compute_Execution_Time => 0 ms .. 20 ms;
+  Deadline               => 120 ms;
+  Priority               => 2;
+end NL;
+thread NF
+  --  Navigation Filter
+features
+  pos_i : in   event data port  Alpha;
+  pos_o : out  event data port  Alpha;
+properties
+  Dispatch_Protocol      => Periodic;
+  Period                 => 120 ms;
+  Compute_Execution_Time => 0 ms .. 10 ms;
+  Deadline               => 120 ms;
+  Priority               => 1;
+end NF;
+thread PL
+  --  Piloting Law
+features
+  acc_c   : in   event data port  Alpha;
+  acc_o   : in   event data port  Alpha;
+  angle_c : out  event data port  Alpha;
+properties
+  Dispatch_Protocol      => Periodic;
+  Period                 => 40 ms;
+  Compute_Execution_Time => 0 ms .. 5 ms;
+  Deadline               => 40 ms;
+  Priority               => 4;
+end PL;
+thread PF
+  --  Piloting Filter
+features
+  acc_i : in   event data port  Alpha;
+  acc_o : out  event data port  Alpha;
+properties
+  Dispatch_Protocol      => Periodic;
+  Period                 => 40 ms;
+  Compute_Execution_Time => 0 ms .. 5 ms;
+  Deadline               => 40 ms;
+  Priority               => 3;
+end PF;
+thread FL
+  --  Feddback Law
+features
+  angle_c : in   event data port  Alpha;
+  angle_o : in   event data port  Alpha;
+  order   : out  event data port  Alpha;
+properties
+  Dispatch_Protocol      => Periodic;
+  Period                 => 10 ms;
+  Compute_Execution_Time => 0 ms .. 2 ms;
+  Deadline               => 10 ms;
+  Priority               => 7;
+end FL;
+thread FF
+  --  Feedback Filter
+features
+  angle_o : out  event data port  Alpha;
+  angle   : in   event data port  Alpha;
+properties
+  Dispatch_Protocol      => Periodic;
+  Period                 => 10 ms;
+  Compute_Execution_Time => 0 ms .. 1 ms;
+  Deadline               => 10 ms;
+  Priority               => 6;
+end FF;
+thread AP
+  --  Acceleration Position Acquisition
+features
+  position : in   event data port  Alpha;
+  acc      : in   event data port  Alpha;
+  acc_i    : out  event data port  Alpha;
+  pos_i    : out  event data port  Alpha;
+properties
+  Dispatch_Protocol      => Periodic;
+  Period                 => 10 ms;
+  Compute_Execution_Time => 0 ms .. 1 ms;
+  Deadline               => 10 ms;
+  Priority               => 5;
+end AP;
+processor cpu
+features
+  i2c   : requires bus access i2c_bus;
+end cpu;
+
+process node_a
+features
+  angle    : in   event data port  Alpha;
+  position : in   event data port  Alpha;
+  acc      : in   event data port  Alpha;
+  pos_c    : in   event data port  Alpha;
+  order    : out  event data port  Alpha;
+end node_a;
+process implementation node_a.impl
+subcomponents
+  FF : thread FF;
+  NL : thread NL;
+  NF : thread NF;
+  PL : thread PL;
+  PF : thread PF;
+  FL : thread FL;
+  AP : thread AP;
+connections
+  --  Inter-thread communication
+  V1:port NL.acc_c   -> PL.acc_c;
+  V2:port PL.angle_c -> FL.angle_c;
+  V3:port NF.pos_o   -> NL.pos_o;
+  V4:port PF.acc_o   -> PL.acc_o;
+  V5:port FF.angle_o -> FL.angle_o;
+  V6:port AP.acc_i   -> PF.acc_i;
+  V7:port AP.pos_i   -> NF.pos_i;
+  -- Process/thread communication
+   
+  V8:port pos_c     -> NL.pos_c;
+  V9:port FL.order -> order;
+  V10:port angle    -> FF.angle;
+  V11:port position -> AP.position;
+  V12:port acc       -> AP.acc;
+end node_a.impl;
+device Operator
+features
+  pos_c : out  event data port  Alpha;
+  i2c   : requires bus access i2c_bus;
+end Operator;
+device GPS
+features
+  position : out  event data port  Alpha;
+  i2c   : requires bus access i2c_bus;
+end GPS;
+device IMU
+features
+  angle : out  event data port  Alpha;
+  acc   : out  event data port  Alpha;
+  i2c   : requires bus access i2c_bus;
+end IMU;
+device Platform
+features
+  order : in  event data port  Alpha;
+  i2c   : requires bus access i2c_bus;
+end Platform;
+bus I2C_bus
+  --  I2C bus
+end I2C_bus;
+system fcs 
+end fcs;
+system implementation fcs.impl
+subcomponents
+   node_a   : process   node_a.impl;
+   cpu_rm   : processor cpu;
+   operator : device    Operator;
+   GPS      : device    GPS;
+   IMU      : device    IMU;
+   platform : device    Platform;
+   i2c      : bus       i2c_bus;
+connections
+  V13:port operator.pos_c -> node_a.pos_c
+  { Actual_Connection_Binding => (reference (i2c));};
+  V14:port node_a.order   -> platform.order
+  { Actual_Connection_Binding => (reference (i2c));};
+  V15:port GPS.position   -> node_a.position
+  { Actual_Connection_Binding => (reference (i2c));};
+  V16:port IMU.angle      -> node_a.angle
+  { Actual_Connection_Binding => (reference (i2c));};
+  V17:port IMU.acc        -> node_a.acc
+  { Actual_Connection_Binding => (reference (i2c));};
+
+  V18:bus access i2c -> GPS.i2c;
+  V19:bus access i2c -> IMU.i2c;
+  V20:bus access i2c -> platform.i2c;
+  V21:bus access i2c -> cpu_rm.i2c;
+properties
+   Actual_Processor_Binding => (reference (cpu_rm)) applies to node_a;
+end fcs.impl;
+end FlightControlSystem;

tests/LNT/FCS/MANIFEST

+AADL_VERSION=-aadlv2
+OCARINA_FLAGS= -o - -g lnt
+

tests/LNT/PC/MANIFEST

+AADL_VERSION=-aadlv2
+OCARINA_FLAGS= -o - -g lnt
+

tests/LNT/PC/producer_consumer.aadl

+package Producer_Consumer
+public
+  ----------
+  -- Data --
+  ----------
+
+  data Alpha_Type
+
+  end Alpha_Type;
+
+  -----------------
+  -- Subprograms --
+  -----------------
+
+  subprogram Produce_Spg
+  features
+    Data_Source : out parameter Alpha_Type;
+
+  end Produce_Spg;
+
+  subprogram Consume_Spg
+  features
+    Data_Sink : in parameter Alpha_Type;
+
+  end Consume_Spg;
+
+  -------------
+  -- Threads --
+  -------------
+
+  thread P
+  features
+    Data_Source : out event data port Alpha_Type;
+    --  XXX Data seems corrupted if Data_Source is an out event data port
+  properties
+    Dispatch_Protocol => Periodic;
+    Compute_Execution_Time => 1 ms .. 8 ms;
+    Priority => 1;
+    Period => 10 ms;
+  end P;
+
+  thread implementation P.Impl
+  calls
+    Mycall : {
+    P_Spg : subprogram Produce_Spg;
+    };
+  connections
+    Z1:parameter P_Spg.Data_Source -> Data_Source;
+  end P.Impl;
+
+  thread Q
+  features
+    Data_Sink : in event data port Alpha_Type;
+  properties
+    Dispatch_Protocol => Sporadic;
+    Compute_Execution_Time => 1 ms .. 2 ms;
+    Priority => 2;
+    Period => 15 ms;
+  end Q;
+
+  thread implementation Q.Impl
+  calls
+    Mycall : {
+    Q_Spg : subprogram Consume_Spg;
+    };
+  connections
+    Z2:parameter Data_Sink -> Q_Spg.Data_Sink;
+  end Q.Impl;
+
+  ---------
+  -- Bus --
+  ---------
+
+  bus Ethernet_Bus 
+  end Ethernet_Bus;
+
+  ---------------
+  -- Processor --
+  ---------------
+
+  processor the_processor 
+  features
+    ETH : requires bus access Ethernet_Bus;
+  end the_processor;
+
+  ---------------
+  -- Processes --
+  ---------------
+
+  process A
+  features
+    Alpha : out event data port Alpha_Type;
+  end A;
+
+  process implementation A.Impl
+  subcomponents
+    Producer        : thread P.Impl;
+  connections
+    Z3:port Producer.Data_Source -> Alpha;
+  end A.Impl;
+
+  process B
+  features
+    Beta  : in event data port Alpha_Type;
+  end B;
+
+  process implementation B.Impl
+  subcomponents
+    Consumer        : thread Q.Impl;
+  connections
+    Z4:port Beta -> Consumer.Data_Sink;
+  end B.Impl;
+
+  ------------
+  -- System --
+  ------------
+
+  system PC_Simple
+  end PC_Simple;
+
+  system implementation PC_Simple.Native
+  subcomponents
+    T : data Alpha_Type; 
+    pr_A : process A.Impl;
+    pr_B : process B.Impl;
+
+    CPU     : processor the_processor;
+    the_bus : bus Ethernet_Bus;
+  connections
+    Z5:bus access the_bus -> CPU.ETH;
+
+    Z6:port pr_A.Alpha -> pr_B.Beta
+    {Actual_Connection_Binding => (reference (the_bus));};
+  properties
+    Actual_Processor_Binding => (reference (CPU)) applies to pr_A;
+    Actual_Processor_Binding => (reference (CPU)) applies to pr_B;
+
+  end PC_Simple.Native;
+
+end Producer_Consumer;

tests/LNT/PC/producer_consumer.aadl.out

+------------------------------------------
+---------- Ocarina LNT Generator ---------
+------------------------------------------
+
+producer_consumer.aadl:97:05producer_consumer.aadl:109:05Begin Thread
+Begin Processor
+Begin Types
+Begin Port
+Begin Main
+producer_consumer.aadl:53:05 "Main.bcg"=  divbranching reduction of "PRODUCER_CONSUMER_Main.lnt";
+property PROPERTY_Deadlock is
+   deadlock of "Main.bcg";
+   expected FALSE;
+end property;
+property Scheduling_Test (ID) is
+   "Main_$ID.bcg"="Main.bcg"|=
+   [ true* . "ACTIVATION_$ID !T_Error" ] false;
+   expected TRUE;
+end property;
+module PRODUCER_CONSUMER_Threads (PRODUCER_CONSUMER_Types) is 
+   process Thread_P_Impl [
+   ACTIVATION: LNT_Channel_Dispatch, 
+   AADL_PORT_DATA_SOURCE: LNT_Channel_Data]
+   is 
+      loop 
+         select 
+            select 
+               ACTIVATION (T_Begin)
+               []
+               ACTIVATION (T_End); 
+               AADL_PORT_DATA_SOURCE (AADLDATA)
+               []
+               ACTIVATION (T_All); 
+               AADL_PORT_DATA_SOURCE (AADLDATA)
+               []
+               ACTIVATION (T_Preempt)
+            end select ; 
+            ACTIVATION (T_Ok)
+            []
+            ACTIVATION (T_Error)
+            []
+            ACTIVATION (T_Stop)
+         end select 
+      end loop
+   end process 
+   
+   process Thread_Q_Impl [
+   ACTIVATION: LNT_Channel_Dispatch, 
+   AADL_PORT_DATA_SINK: LNT_Channel_Data]
+   is 
+      loop 
+         select 
+            select 
+               ACTIVATION (T_Begin); 
+               AADL_PORT_DATA_SINK (AADLDATA)
+               []
+               ACTIVATION (T_End)
+               []
+               ACTIVATION (T_All); 
+               AADL_PORT_DATA_SINK (AADLDATA)
+               []
+               ACTIVATION (T_Preempt)
+            end select ; 
+            ACTIVATION (T_Ok)
+            []
+            ACTIVATION (T_Error)
+            []
+            ACTIVATION (T_Stop)
+         end select 
+      end loop
+   end process 
+   
+end module 
+module PRODUCER_CONSUMER_Ports (PRODUCER_CONSUMER_Types) is 
+   process Data_Port [
+   Input: LNT_Channel_Data, 
+   Output: LNT_Channel_Data]
+   is 
+      loop 
+         select 
+            Input (AADLDATA)
+            []
+            Output (AADLDATA)
+         end select 
+      end loop
+   end process 
+   
+   process Event_Port_Periodic [
+   Input: LNT_Channel_Data, 
+   Output: LNT_Channel_Data](
+   Queue_Size: Nat) 
+   is 
+      var 
+         Nb_Input : Nat
+      in 
+         Nb_Input := 0; 
+         loop 
+            select 
+               Input (AADLDATA); 
+               if (Nb_Input <  Queue_Size)
+               then 
+                  Nb_Input := Nb_Input + 1
+               end if
+               []
+               if (Nb_Input >  0)
+               then 
+                  Output (AADLDATA); 
+                  Nb_Input := Nb_Input - 1
+               end if
+            end select 
+         end loop
+      end var
+   end process 
+   
+   process Event_Port_Sporadic [
+   Input: LNT_Channel_Data, 
+   Output: LNT_Channel_Data, 
+   Notify: LNT_Channel_Event](
+   Queue_Size: Nat) 
+   is 
+      var 
+         Nb_Input : Nat, 
+         Is_New : bool
+      in 
+         Nb_Input := 0; 
+         Is_New := false; 
+         loop 
+            select 
+               Input (AADLDATA); 
+               if (Nb_Input <  Queue_Size)
+               then 
+                  Nb_Input := Nb_Input + 1
+               end if; 
+               Is_New := true
+               []
+               if (Nb_Input >  0)
+               then 
+                  Output (AADLDATA); 
+                  Nb_Input := Nb_Input - 1
+               end if
+               []
+               if (Is_New)
+               then 
+                  Notify (Incoming_Event); 
+                  Is_New := false
+               else 
+                  Notify (No_Event)
+               end if
+            end select 
+         end loop
+      end var
+   end process 
+   
+end module 
+module PRODUCER_CONSUMER_Types 
+with "==",  "eq" , "<",  "lt" , "<=",  "le" , ">",  "gt" , ">=",  "ge" is 
+   type LNT_Type_Data is 
+      AADLDATA
+   end type 
+   
+   channel LNT_Channel_Data is 
+      (LNT_Type_Data) 
+   end channel
+   type LNT_Type_Time_Constraint is 
+      range 0 .. 60 of Nat
+   end type 
+   
+   type LNT_Type_Thread is 
+      array [0 .. 11 ]of LNT_Type_Time_Constraint
+   end type 
+   
+   type LNT_Type_Thread_Array is 
+      array [1 .. 2 ]of LNT_Type_Thread
+   end type 
+   
+   type LNT_Type_Dispatch is 
+      T_Begin, T_End, T_All, T_Preempt, T_Stop, T_Error, T_Ok
+   end type 
+   
+   type LNT_Type_Event is 
+      Incoming_Event, No_Event
+   end type 
+   
+   channel LNT_Channel_Dispatch is 
+      (LNT_Type_Dispatch) 
+   end channel
+   channel LNT_Channel_Event is 
+      (LNT_Type_Event) 
+   end channel
+   function Thread_Number : Nat 
+   is 
+      return 2
+   end function 
+   
+   function PPCM_THREAD : LNT_Type_Time_Constraint 
+   is 
+      return LNT_Type_Time_Constraint ( 30)
+   end function 
+   
+   function _+_ (
+      n1: LNT_Type_Time_Constraint, 
+      n2: LNT_Type_Time_Constraint) : LNT_Type_Time_Constraint 
+   is 
+      return LNT_Type_Time_Constraint (Nat (n1) + Nat (n2) mod 60)
+   end function 
+   
+   function _-_ (
+      n1: LNT_Type_Time_Constraint, 
+      n2: LNT_Type_Time_Constraint) : LNT_Type_Time_Constraint 
+   is 
+      if (n1 <  n2)
+      then 
+         return LNT_Type_Time_Constraint (((60 - Nat (n2))  + Nat (n1))  mod 60)
+      else 
+         return LNT_Type_Time_Constraint (Nat (n1) - Nat (n2) mod 60)
+      end if
+   end function 
+   
+   function _*_ (
+      n1: LNT_Type_Time_Constraint, 
+      n2: LNT_Type_Time_Constraint) : LNT_Type_Time_Constraint 
+   is 
+      return LNT_Type_Time_Constraint (Nat (n1) * Nat (n2) mod 60)
+   end function 
+   
+end module 
+module PRODUCER_CONSUMER_Processor (PRODUCER_CONSUMER_Types) is 
+   function Assign (
+      in var Threads: LNT_Type_Thread_Array, 
+      I: Nat, 
+      K: Nat, 
+      Val: LNT_Type_Time_Constraint) : LNT_Type_Thread_Array 
+   is 
+      var 
+         P : LNT_Type_Thread
+      in 
+         P := Threads[I]; 
+         P[K] := Val; 
+         Threads[I] := P
+      end var; 
+      return Threads
+   end function 
+   
+   function Update_Thread (
+      in var Aux_Threads: LNT_Type_Thread_Array, 
+      I: Nat, 
+      TODO: LNT_Type_Time_Constraint) : LNT_Type_Thread_Array 
+   is 
+      var 
+         P : LNT_Type_Thread
+      in 
+         P := Aux_Threads[I]; 
+         if (P[2] ==  LNT_Type_Time_Constraint (0))
+         then 
+            P[6] := LNT_Type_Time_Constraint (1)
+         end if; 
+         P[2] := P[2] + TODO; 
+         P[8] := LNT_Type_Time_Constraint (1); 
+         if ((P[11] ==  LNT_Type_Time_Constraint (1))  and  (P[2] ==  P[0]) )
+         then 
+            P[7] := LNT_Type_Time_Constraint (1); 
+            P[2] := LNT_Type_Time_Constraint (0); 
+            P[4] := P[5]; 
+            P[5] := PPCM_THREAD; 
+            P[10] := LNT_Type_Time_Constraint (0)
+         elsif ((P[11] ==  LNT_Type_Time_Constraint (0))  and  (P[2] ==  P[0]) )
+         then 
+         
+            P[7] := LNT_Type_Time_Constraint (1); 
+            P[2] := LNT_Type_Time_Constraint (0); 
+            P[3] := P[3] + LNT_Type_Time_Constraint (1); 
+            P[4] := P[4] + P[1]; 
+            P[5] := P[3] * P[1]
+         end if; 
+         Aux_Threads[I] := P
+      end var; 
+      return Aux_Threads
+   end function 
+   
+   process Sporadic_Notif [
+   INCOMING_EVENT_GATE: LNT_Channel_Event](
+   in out Threads: LNT_Type_Thread_Array,
+   k: Nat,
+   Counter: LNT_Type_Time_Constraint,
+   in out Is_Activated: bool) 
+   is 
+      select 
+         INCOMING_EVENT_GATE (Incoming_Event); 
+         Threads := Assign (Threads, K, 3, (Threads[k][3] + LNT_Type_Time_Constraint (1)) )
+         []