|
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: 12288 (0x3000)
Types: Ada Source
Notes: 03_class, FILE, R1k_Segment, e3_tag, package body Broker_Link_Layer, seg_027f85
└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
└─⟦cfc2e13cd⟧ »Space Info Vol 2«
└─⟦this⟧
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_Manager;
with Umps_Utilities;
with Text_Io;
--with message_parser;
package body Broker_Link_Layer is
task body T_Server is
The_Broker_Listen_Socket_Port : Socket_Port.Object;
The_Broker_Host_Name : Host_Name.Object;
The_Broker_Listen_Socket_Id : Socket_Defs.Socket_Id;
The_Task_Performing_Mailbox_Received_Msg :
Mailbox_Received_Msg.Access_Task_Mailbox;
begin
accept Start (Broker_Listen_Socket_Port : Socket_Port.Object;
Task_Performing_Mailbox_Received_Msg :
Mailbox_Received_Msg.Access_Task_Mailbox) do
Text_Io.Put ("(Broker_Link_Layer).Server : Start.");
The_Broker_Listen_Socket_Port := Broker_Listen_Socket_Port;
The_Task_Performing_Mailbox_Received_Msg :=
Task_Performing_Mailbox_Received_Msg;
-- Init of the allocator number :
Socket_Port_Manager.Init_Number;
The_Broker_Listen_Socket_Id := Physical_Layer.Create_Server
(The_Broker_Listen_Socket_Port);
Text_Io.Put ("(Broker_Link_Layer).Server : End start.");
end Start;
declare
The_Broker_Service_Socket_Id : Socket_Defs.Socket_Id;
The_Buffer_To_Receive : Low_Level_Message.Object;
The_Number_Of_Caracteres_Received : Integer;
Result : Boolean;
begin
loop
-- Connection to get a message :
Text_Io.Put
("(Broker_Link_Layer).Server : Wait for a connection ... ");
The_Broker_Service_Socket_Id :=
Physical_Layer.Server_Wait_For_A_Connection
(The_Broker_Listen_Socket_Id);
Text_Io.Put_Line ("(Broker_Link_Layer).Server : I got it !");
Physical_Layer.Receive_String
(The_Broker_Service_Socket_Id, The_Buffer_To_Receive,
The_Number_Of_Caracteres_Received);
Text_Io.Put_Line (The_Buffer_To_Receive.The_String
(1 .. The_Number_Of_Caracteres_Received));
-- Examine the message to intercept a Behavior creation asking :
if Protocol.Is_A_Kind_Of (The_Buffer_To_Receive) then
Text_Io.Put_Line
("(Broker_Link_Layer).Server : it s a protocol message...");
if Protocol.Is_A_Request_For_A_Behavior_Socket_Port
(The_Buffer_To_Receive) then
Text_Io.Put_Line
("(Broker_Link_Layer).Server : it s a request for a behavior port number.");
Protocol.Give_A_Behavior_Socket_Port
(The_Broker_Service_Socket_Id,
The_Buffer_To_Receive);
else
Text_Io.Put_Line
("(Broker_Link_Layer).Server : it s an unknown message !");
end if;
else
-- Normal process : send the message to the received_message_fifo :
Text_Io.Put_Line
("(Broker_Link_Layer).Server : it s a normal message.");
The_Task_Performing_Mailbox_Received_Msg.Put
(The_Buffer_To_Receive, Result);
if Result = False then
Text_Io.Put_Line
("(Broker_Link_Layer).Server : Putting message into received messages fifo is impossible");
end if;
end if;
Physical_Layer.Close_Socket (The_Broker_Service_Socket_Id);
end loop;
end;
end T_Server;
task body T_Client is
The_Task_Performing_Mailbox_Msg_To_Send :
Mailbox_Msg_To_Send.Access_Task_Mailbox;
The_Msg : Low_Level_Message.Object;
Result : Boolean := False;
Service_Socket_Id : Socket_Defs.Socket_Id;
Number_Of_Characters_Sent : Integer;
The_Behavior_Socket_Port : Socket_Port.Object;
The_Behavior_Host_Name : Host_Name.Object;
begin
accept Start (Task_Performing_Mailbox_Msg_To_Send :
Mailbox_Msg_To_Send.Access_Task_Mailbox) do
The_Task_Performing_Mailbox_Msg_To_Send :=
Task_Performing_Mailbox_Msg_To_Send;
end Start;
loop
select -- Active wait ....
The_Task_Performing_Mailbox_Msg_To_Send.Get (The_Msg, Result);
if Result = True then
--Look for the Behavior socket port : it lies in the fourth field of the message :
-------------
-- Ne sait pas si cette fonction marche.
-------------
-- The_Behavior_Socket_Port :=
-- Message_Parser.Get_Handler (The_Msg.The_String);
--
-- Look for the Behavior host name :
Socket_Port_Manager.Show_Value
(The_Behavior_Socket_Port,
The_Behavior_Host_Name, Result);
if Result = False then
Text_Io.Put_Line
("Broker_Link_Layer.Client : Getting Handler host-name from messages is impossible");
else
Service_Socket_Id :=
Physical_Layer.Join_Server
(The_Behavior_Host_Name,
The_Behavior_Socket_Port);
if Service_Socket_Id < 0 then
raise Socket_Defs.Join_Server_Error;
end if;
Physical_Layer.Send_String
(Service_Socket_Id, The_Msg,
Number_Of_Characters_Sent);
Physical_Layer.Close_Socket (Service_Socket_Id);
end if;
end if;
else
null;
end select;
end loop;
end T_Client;
end Broker_Link_Layer;
nblk1=b
nid=2
hdr6=12
[0x00] rec0=21 rec1=00 rec2=01 rec3=058
[0x01] rec0=00 rec1=00 rec2=03 rec3=004
[0x02] rec0=1f rec1=00 rec2=04 rec3=01e
[0x03] rec0=14 rec1=00 rec2=0b rec3=02e
[0x04] rec0=13 rec1=00 rec2=0a rec3=028
[0x05] rec0=1f rec1=00 rec2=09 rec3=058
[0x06] rec0=21 rec1=00 rec2=07 rec3=044
[0x07] rec0=18 rec1=00 rec2=06 rec3=014
[0x08] rec0=04 rec1=00 rec2=05 rec3=000
[0x09] rec0=09 rec1=00 rec2=06 rec3=000
[0x0a] rec0=09 rec1=00 rec2=06 rec3=000
tail 0x21722058c83ad7ec703a2 0x42a00088783c7f403
Free Block Chain:
0x2: 0000 00 08 00 db 00 00 00 00 3c 20 20 20 20 20 20 20 ┆ < ┆
0x8: 0000 00 00 00 0e 80 0b 20 20 20 20 20 20 20 20 20 20 ┆ ┆