|
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: 13312 (0x3400)
Types: Ada Source
Notes: 03_class, FILE, R1k_Segment, e3_tag, package body Little_Orb, seg_055195
└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
└─⟦cfc2e13cd⟧ »Space Info Vol 2«
└─⟦this⟧
with Transport_Defs;
with Communication;
with Message;
with Our_Constantes;
use Our_Constantes;
with Text_Io;
package body Little_Orb is
-- *********************************************
function Registration
(The_Host : Transport_Defs.Host_Id;
The_Socket : Transport_Defs.Socket_Id) return Boolean is
The_Message : Message.Type_Of_Message;
The_Connection : Connection_Data;
begin
The_Message.The_Command := The_Registration;
The_Message.The_Host_Machine_Send := The_Host;
The_Message.The_Socket_Send := The_Socket;
Communication.Connection_Transmitter (The_Message, The_Connection);
Communication.Transmitter (The_Message, The_Connection);
Communication.Disconnection (The_Connection);
return
True; -- receiver ... if Is_Ok then return true;else return false; end if;
end Registration;
-- *********************************************
function Unregistration
(The_Host : Transport_Defs.Host_Id;
The_Socket : Transport_Defs.Socket_Id) return Boolean is
The_Message : Message.Type_Of_Message;
The_Connection : Connection_Data;
begin
The_Message.The_Command := The_Unregistration;
The_Message.The_Host_Machine_Send := The_Host;
The_Message.The_Socket_Send := The_Socket;
Communication.Connection_Transmitter (The_Message, The_Connection);
Communication.Transmitter (The_Message, The_Connection);
Communication.Disconnection (The_Connection);
return
True; -- receiver ... if Is_Ok then return true;else return false; end if;
end Unregistration;
-- ********************************************************
procedure Query is
begin
[statement]
end Query;
-- ********************************************************
procedure Request (The_Data : Our_String.Variable_String;
The_Host_Send : Transport_Defs.Host_Id;
The_Socket_Send : Transport_Defs.Socket_Id;
The_Host_To_Execute : Transport_Defs.Host_Id;
The_Socket_To_Execute : Transport_Defs.Socket_Id;
The_Connection_Data : in out
Our_Constantes.Connection_Data) is
The_Message : Message.Type_Of_Message;
The_Host_Receive : Transport_Defs.Host_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Host;
The_Socket_Receive : Transport_Defs.Socket_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Socket;
begin
The_Message.The_Command := The_Request;
The_Message.The_Host_Machine_Send := The_Host_Send;
The_Message.The_Host_Machine_Receive := The_Host_Receive;
The_Message.Data := The_Data;
The_Message.The_Socket_Send := The_Socket_Send;
The_Message.The_Socket_Receive := The_Socket_Receive;
The_Message.The_Host_Machine_To_Execute := The_Host_To_Execute;
The_Message.The_Socket_To_Execute := The_Socket_To_Execute;
Communication.Connection_Transmitter (The_Message, The_Connection_Data);
Communication.Transmitter (The_Message, The_Connection_Data);
Communication.Disconnection (The_Connection_Data);
end Request;
-- ********************************************************
procedure Notification (The_Data : Our_String.Variable_String;
The_Connection_Data : in out
Our_Constantes.Connection_Data) is
The_Message : Message.Type_Of_Message;
The_Host_Receive : Transport_Defs.Host_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Host;
The_Socket_Receive : Transport_Defs.Socket_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Socket;
begin
The_Message.The_Command := The_Notification;
The_Message.Data := The_Data;
Communication.Connection_Transmitter (The_Message, The_Connection_Data);
Communication.Transmitter (The_Message, The_Connection_Data);
Communication.Disconnection (The_Connection_Data);
Text_Io.Put_Line (" envoi Ok");
end Notification;
-- ********************************************************
procedure Forward (The_Data : Our_String.Variable_String;
The_Host_Send : Transport_Defs.Host_Id;
The_Socket_Send : Transport_Defs.Socket_Id;
The_Host_To_Execute : Transport_Defs.Host_Id;
The_Socket_To_Execute : Transport_Defs.Socket_Id;
The_Connection_Data : in out
Our_Constantes.Connection_Data) is
The_Message : Message.Type_Of_Message;
The_Host_Receive : Transport_Defs.Host_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Host;
The_Socket_Receive : Transport_Defs.Socket_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Socket;
begin
The_Message.The_Command := The_Forward;
The_Message.The_Host_Machine_Send := The_Host_Send;
The_Message.The_Host_Machine_Receive := The_Host_Receive;
The_Message.Data := The_Data;
The_Message.The_Socket_Send := The_Socket_Send;
The_Message.The_Socket_Receive := The_Socket_Receive;
The_Message.The_Host_Machine_To_Execute := The_Host_To_Execute;
The_Message.The_Socket_To_Execute := The_Socket_To_Execute;
Communication.Connection_Transmitter (The_Message, The_Connection_Data);
Communication.Transmitter (The_Message, The_Connection_Data);
Communication.Disconnection (The_Connection_Data);
Text_Io.Put_Line (" envoi Ok");
end Forward;
-- ********************************************************
procedure Subscription (The_Data : Our_String.Variable_String;
The_Socket_Send : Transport_Defs.Socket_Id;
The_Host_Send : in Transport_Defs.Host_Id;
The_Connection_Data : in out
Our_Constantes.Connection_Data) is
The_Message : Message.Type_Of_Message;
The_Host_Receive : Transport_Defs.Host_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Host;
The_Socket_Receive : Transport_Defs.Socket_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Socket;
begin
The_Message.The_Command := The_Subscription;
The_Message.The_Host_Machine_Send := The_Host_Send;
The_Message.The_Host_Machine_Receive := The_Host_Receive;
The_Message.Data := The_Data;
The_Message.The_Socket_Send := The_Socket_Send;
The_Message.The_Socket_Receive := The_Socket_Receive;
Communication.Connection_Transmitter (The_Message, The_Connection_Data);
Communication.Transmitter (The_Message, The_Connection_Data);
Communication.Disconnection (The_Connection_Data);
Text_Io.Put_Line (" envoi Ok");
end Subscription;
-- ********************************************************
procedure Unsubscription (The_Data : Our_String.Variable_String;
The_Socket_Send : Transport_Defs.Socket_Id;
The_Host_Send : in Transport_Defs.Host_Id;
The_Connection_Data : in out
Our_Constantes.Connection_Data) is
The_Message : Message.Type_Of_Message;
The_Host_Receive : Transport_Defs.Host_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Host;
The_Socket_Receive : Transport_Defs.Socket_Id (1 .. 4) :=
Our_Constantes.The_Orb.The_Socket;
begin
The_Message.The_Command := The_Unsubscription;
The_Message.The_Host_Machine_Send := The_Host_Send;
The_Message.The_Host_Machine_Receive := The_Host_Receive;
The_Message.Data := The_Data;
The_Message.The_Socket_Send := The_Socket_Send;
The_Message.The_Socket_Receive := The_Socket_Receive;
Communication.Connection_Transmitter (The_Message, The_Connection_Data);
Communication.Transmitter (The_Message, The_Connection_Data);
Communication.Disconnection (The_Connection_Data);
Text_Io.Put_Line (" envoi Ok");
end Unsubscription;
-- ********************************************************
procedure Filtration is
begin
[statement]
end Filtration;
-- ********************************************************
procedure Unfiltration is
begin
[statement]
end Unfiltration;
end Little_Orb;
nblk1=c
nid=c
hdr6=16
[0x00] rec0=1f rec1=00 rec2=01 rec3=03a
[0x01] rec0=1d rec1=00 rec2=08 rec3=06e
[0x02] rec0=19 rec1=00 rec2=0b rec3=022
[0x03] rec0=18 rec1=00 rec2=07 rec3=028
[0x04] rec0=07 rec1=00 rec2=09 rec3=06c
[0x05] rec0=16 rec1=00 rec2=05 rec3=028
[0x06] rec0=1e rec1=00 rec2=02 rec3=050
[0x07] rec0=03 rec1=00 rec2=06 rec3=028
[0x08] rec0=1e rec1=00 rec2=04 rec3=022
[0x09] rec0=19 rec1=00 rec2=0a rec3=026
[0x0a] rec0=19 rec1=00 rec2=03 rec3=000
[0x0b] rec0=f4 rec1=80 rec2=00 rec3=000
tail 0x2175ec30e87bc4fadd929 0x42a00088462060003
Free Block Chain:
0xc: 0000 00 00 00 4b 80 0c 3a 3d 20 54 68 65 5f 44 61 74 ┆ K := The_Dat┆