diff options
Diffstat (limited to 'cpukit/include/adainclude/rtems-message_queue.adb')
| -rw-r--r-- | cpukit/include/adainclude/rtems-message_queue.adb | 243 |
1 files changed, 243 insertions, 0 deletions
diff --git a/cpukit/include/adainclude/rtems-message_queue.adb b/cpukit/include/adainclude/rtems-message_queue.adb new file mode 100644 index 0000000000..67abf48baf --- /dev/null +++ b/cpukit/include/adainclude/rtems-message_queue.adb @@ -0,0 +1,243 @@ +-- +-- RTEMS / Body +-- +-- DESCRIPTION: +-- +-- This package provides the interface to the RTEMS API. +-- +-- +-- DEPENDENCIES: +-- +-- +-- +-- COPYRIGHT (c) 1997-2011. +-- On-Line Applications Research Corporation (OAR). +-- +-- The license and distribution terms for this file may in +-- the file LICENSE in this distribution or at +-- http://www.rtems.org/license/LICENSE. +-- + +package body RTEMS.Message_Queue is + + -- + -- Message Queue Manager + -- + + procedure Create + (Name : in RTEMS.Name; + Count : in RTEMS.Unsigned32; + Max_Message_Size : in RTEMS.Unsigned32; + Attribute_Set : in RTEMS.Attribute; + ID : out RTEMS.ID; + Result : out RTEMS.Status_Codes) + is + -- XXX broken + function Create_Base + (Name : RTEMS.Name; + Count : RTEMS.Unsigned32; + Max_Message_Size : RTEMS.Unsigned32; + Attribute_Set : RTEMS.Attribute; + ID : access RTEMS.ID) + return RTEMS.Status_Codes; + pragma Import + (C, + Create_Base, + "rtems_message_queue_create"); + ID_Base : aliased RTEMS.ID; + begin + + Result := + Create_Base + (Name, + Count, + Max_Message_Size, + Attribute_Set, + ID_Base'Access); + ID := ID_Base; + + end Create; + + procedure Ident + (Name : in RTEMS.Name; + Node : in RTEMS.Unsigned32; + ID : out RTEMS.ID; + Result : out RTEMS.Status_Codes) + is + function Ident_Base + (Name : RTEMS.Name; + Node : RTEMS.Unsigned32; + ID : access RTEMS.ID) + return RTEMS.Status_Codes; + pragma Import + (C, + Ident_Base, + "rtems_message_queue_ident"); + ID_Base : aliased RTEMS.ID; + begin + + Result := Ident_Base (Name, Node, ID_Base'Access); + ID := ID_Base; + + end Ident; + + procedure Delete + (ID : in RTEMS.ID; + Result : out RTEMS.Status_Codes) + is + function Delete_Base + (ID : RTEMS.ID) + return RTEMS.Status_Codes; + pragma Import + (C, + Delete_Base, + "rtems_message_queue_delete"); + begin + + Result := Delete_Base (ID); + + end Delete; + + procedure Send + (ID : in RTEMS.ID; + Buffer : in RTEMS.Address; + Size : in RTEMS.Unsigned32; + Result : out RTEMS.Status_Codes) + is + function Send_Base + (ID : RTEMS.ID; + Buffer : RTEMS.Address; + Size : RTEMS.Unsigned32) + return RTEMS.Status_Codes; + pragma Import (C, Send_Base, "rtems_message_queue_send"); + begin + + Result := Send_Base (ID, Buffer, Size); + + end Send; + + procedure Urgent + (ID : in RTEMS.ID; + Buffer : in RTEMS.Address; + Size : in RTEMS.Unsigned32; + Result : out RTEMS.Status_Codes) + is + function Urgent_Base + (ID : RTEMS.ID; + Buffer : RTEMS.Address; + Size : RTEMS.Unsigned32) + return RTEMS.Status_Codes; + pragma Import + (C, + Urgent_Base, + "rtems_message_queue_urgent"); + begin + + Result := Urgent_Base (ID, Buffer, Size); + + end Urgent; + + procedure Broadcast + (ID : in RTEMS.ID; + Buffer : in RTEMS.Address; + Size : in RTEMS.Unsigned32; + Count : out RTEMS.Unsigned32; + Result : out RTEMS.Status_Codes) + is + function Broadcast_Base + (ID : RTEMS.ID; + Buffer : RTEMS.Address; + Size : RTEMS.Unsigned32; + Count : access RTEMS.Unsigned32) + return RTEMS.Status_Codes; + pragma Import + (C, + Broadcast_Base, + "rtems_message_queue_broadcast"); + Count_Base : aliased RTEMS.Unsigned32; + begin + + Result := + Broadcast_Base (ID, Buffer, Size, Count_Base'Access); + Count := Count_Base; + + end Broadcast; + + procedure Receive + (ID : in RTEMS.ID; + Buffer : in RTEMS.Address; + Option_Set : in RTEMS.Option; + Timeout : in RTEMS.Interval; + Size : in out RTEMS.Unsigned32; + Result : out RTEMS.Status_Codes) + is + function Receive_Base + (ID : RTEMS.ID; + Buffer : RTEMS.Address; + Size : access RTEMS.Unsigned32; + Option_Set : RTEMS.Option; + Timeout : RTEMS.Interval) + return RTEMS.Status_Codes; + pragma Import + (C, + Receive_Base, + "rtems_message_queue_receive"); + Size_Base : aliased RTEMS.Unsigned32; + begin + + Size_Base := Size; + + Result := + Receive_Base + (ID, + Buffer, + Size_Base'Access, + Option_Set, + Timeout); + Size := Size_Base; + + end Receive; + + procedure Get_Number_Pending + (ID : in RTEMS.ID; + Count : out RTEMS.Unsigned32; + Result : out RTEMS.Status_Codes) + is + function Get_Number_Pending_Base + (ID : RTEMS.ID; + Count : access RTEMS.Unsigned32) + return RTEMS.Status_Codes; + pragma Import + (C, + Get_Number_Pending_Base, + "rtems_message_queue_get_number_pending"); + Count_Base : aliased RTEMS.Unsigned32; + begin + + Result := Get_Number_Pending_Base (ID, Count_Base'Access); + Count := Count_Base; + + end Get_Number_Pending; + + procedure Flush + (ID : in RTEMS.ID; + Count : out RTEMS.Unsigned32; + Result : out RTEMS.Status_Codes) + is + function Flush_Base + (ID : RTEMS.ID; + Count : access RTEMS.Unsigned32) + return RTEMS.Status_Codes; + pragma Import + (C, + Flush_Base, + "rtems_message_queue_flush"); + Count_Base : aliased RTEMS.Unsigned32; + begin + + Result := Flush_Base (ID, Count_Base'Access); + Count := Count_Base; + + end Flush; + +end RTEMS.Message_Queue; |