|
DataMuseum.dkPresents historical artifacts from the history of: Rational R1000/400 |
This is an automatic "excavation" of a thematic subset of
See our Wiki for more about Rational R1000/400 Excavated with: AutoArchaeologist - Free & Open Source Software. |
top - metrics - download
Length: 5120 (0x1400)
Types: Ada Source
Notes: 03_class, FILE, R1k_Segment, e3_tag, package body Broker_Umps_Message, seg_027a6b
└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
└─⟦cfc2e13cd⟧ »Space Info Vol 2«
└─⟦this⟧
with Broker_Link_Layer;
with Host_Name;
with Low_Level_Message;
with Mailbox_Msg_To_Send;
with Mailbox_Received_Msg;
with Physical_Layer;
with Protocol;
with Socket_Defs;
with Socket_Port;
with Text_Io;
with Umps_Utilities;
package body Broker_Umps_Message is
-- Create the tasks witch controlled the fifo where are stocked temporary the messages :
Task_Performing_Mailbox_Received_Msg :
Mailbox_Received_Msg.Access_Task_Mailbox :=
new Mailbox_Received_Msg.Task_Mailbox;
Task_Performing_Mailbox_Msg_To_Send :
Mailbox_Msg_To_Send.Access_Task_Mailbox :=
new Mailbox_Msg_To_Send.Task_Mailbox;
Task_Server : Broker_Link_Layer.T_Server;
Task_Client : Broker_Link_Layer.T_Client;
procedure Init is
The_Broker_Listen_Socket_Port : Socket_Port.Object;
The_Broker_Host_Name : Host_Name.Object;
-- for the tests :
Default_Brocker_Host_Name : constant String := "belladone";
begin
Text_Io.Put_Line
("Broker_umps_message manager : Start Server task V.0.1");
-- Read "parameters" file to find the Brocker Listen socket port :
-- TO CHANGE ....
The_Broker_Listen_Socket_Port := Socket_Port.Create (9860);
The_Broker_Host_Name := Host_Name.Create (Default_Brocker_Host_Name);
-- .... TO CHANGE !!!
Task_Server.Start (The_Broker_Listen_Socket_Port,
Task_Performing_Mailbox_Received_Msg);
Task_Client.Start (Task_Performing_Mailbox_Msg_To_Send);
end Init;
procedure Put (Something : in out String; Result : out Boolean) is
The_Msg_To_Send : Low_Level_Message.Object;
begin
The_Msg_To_Send := Low_Level_Message.Create (Something);
Task_Performing_Mailbox_Msg_To_Send.Put (The_Msg_To_Send, Result);
end Put;
procedure Get (Something : in out String;
Number_Of_Characters_Received : out Natural;
Result : in out Boolean) is
Received_Msg : Low_Level_Message.Object;
begin
Task_Performing_Mailbox_Received_Msg.Get (Received_Msg, Result);
if Result = True then
Something := Umps_Utilities.Normalize
(Received_Msg.The_String, Something'Length);
Number_Of_Characters_Received := Received_Msg.The_Size;
end if;
end Get;
end Broker_Umps_Message;
nblk1=4
nid=3
hdr6=6
[0x00] rec0=25 rec1=00 rec2=01 rec3=05a
[0x01] rec0=22 rec1=00 rec2=02 rec3=04c
[0x02] rec0=10 rec1=00 rec2=04 rec3=000
[0x03] rec0=12 rec1=00 rec2=04 rec3=000
tail 0x21721ceb283ac8c65c204 0x42a00088462063203
Free Block Chain:
0x3: 0000 00 00 00 06 80 03 20 20 20 03 20 20 20 20 20 20 ┆ ┆