|
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, procedure Orb, seg_05743d
└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
└─⟦5a81ac88f⟧ »Space Info Vol 1«
└─⟦this⟧
with Bal;
with Sub_Contrat;
with Sub_Registration;
with Identification;
with Message;
with Trans;
with Text_Io;
with Orb_Tools;
with Ident_Link;
procedure Orb is
M : Message.Tmessage;
Orb_Id : constant Identification.Tclient_Id := 0;
L_Contrat : Sub_Contrat.Contrat_List.List;
L_Subs : Sub_Contrat.Sub_List.List;
procedure Moulinette (M : in out Message.Tmessage) is
Commander : Message.Command_Type;
Contract : Sub_Contrat.Tcontrat;
N_Contrat : Sub_Contrat.Tnom_Contrat;
Subs : Sub_Contrat.Tsubscription;
Origin, Destination : Identification.Tclient_Id;
Message_T_S : Bal.Tmess_To_Send;
Content, My_Contrat : Orb_Tools.Content_String;
begin
Message.Unfill_Command (M, Commander);
case Commander is
when Message.Registration =>
-- renvoyer son id au client
Text_Io.Put_Line ("Orb : received a Registration");
Sub_Registration.Alloc_Ident (M, Destination);
Orb_Tools.Copy
(Source => Identification.Tclient_Id'Image (Destination),
Target => Content);
Message.Fill_Content (M, Content);
Message.Fill_Command (M, Message.Identify);
Message_T_S.Mess := M;
Message_T_S.Id := Orb_Id;
Identification.Search_Object (Destination, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
when Message.Unregistration =>
-- retirer l'objet de la liste
Text_Io.Put_Line ("Orb : received an unregistration");
Message.Unfill_Origin (M, Origin);
Sub_Registration.Desalloc_Ident (Origin);
when Message.Queries =>
null;
-- pas implemente
when Message.Request =>
Text_Io.Put_Line ("Orb : received a request...");
Message.Unfill_Content (M, N_Contrat);
Message.Unfill_Origin (M, Origin);
-- Chercher si le contrat existe
if Sub_Contrat.Contrat_Exists (L_Contrat, N_Contrat) then
Destination := Sub_Contrat.Contrat_Provider
(L_Contrat, N_Contrat);
Sub_Contrat.Switch_Status (L_Contrat, Destination, True);
Ident_Link.Enter_New_Link (Traiteur => Destination,
To_Who => Origin,
Contrat => N_Contrat);
Message.Fill_Command (M, Message.Request);
Message.Fill_Origin (M, Orb_Id);
Message_T_S.Mess := M;
Message_T_S.Id := Destination;
Identification.Search_Object (Destination, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
else
-- renvoyer un message d'erreur
Message.Fill_Command (M, Message.Rfailed);
Message.Fill_Origin (M, Orb_Id);
Message_T_S.Mess := M;
Message_T_S.Id := Origin;
Identification.Search_Object (Origin, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
end if;
when Message.Notification =>
null;
-- pas implemente
when Message.Publication =>
Text_Io.Put_Line ("Orb : received a publication");
Sub_Contrat.Fill_Contrat (M, Contract);
Sub_Contrat.Add_Contrat (L_Contrat, Contract);
when Message.Unpublication =>
Text_Io.Put_Line ("Orb : received an unpublication");
Message.Unfill_Origin (M, Origin);
Sub_Contrat.Remove_Contrat (L_Contrat, Origin);
when Message.Forward =>
Text_Io.Put_Line ("Orb : Received a forward");
Message.Unfill_Origin (M, Origin);
-- Rechercher a qui cette reponse est destinee
Ident_Link.Search_Link (Traiteur => Origin,
To_Who => Destination,
Contrat => My_Contrat);
Sub_Contrat.Switch_Status (L_Contrat, Origin, False);
Message.Fill_Command (M, Message.Forward);
Message.Fill_Origin (M, Orb_Id);
Message_T_S.Mess := M;
Message_T_S.Id := Destination;
Identification.Search_Object (Destination, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
Ident_Link.Delete_Link (Destination);
-- Rechercher un subscripter de la reponse
if Sub_Contrat.Subscription_Exists (L_Subs, My_Contrat) then
Destination := Sub_Contrat.Subscripter (L_Subs, My_Contrat);
Message_T_S.Mess := M;
Message_T_S.Id := Destination;
Identification.Search_Object (Destination, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
end if;
when Message.Subscription =>
Text_Io.Put_Line ("Orb : received a subscription.");
Message.Unfill_Content (M, N_Contrat);
if Sub_Contrat.Contrat_Exists (L_Contrat, N_Contrat) then
Sub_Contrat.Fill_Sub (L_Contrat, M, Subs);
Sub_Contrat.Add_Sub (L_Subs, Subs);
else
Message.Unfill_Origin (M, Origin);
Message.Fill_Command (M, Message.Rfailed);
Message.Fill_Origin (M, Orb_Id);
Message_T_S.Mess := M;
Message_T_S.Id := Origin;
Identification.Search_Object (Origin, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
end if;
when Message.Unsubscription =>
Text_Io.Put_Line ("Orb : received an unsubscription");
Sub_Contrat.Fill_Sub (L_Contrat, M, Subs);
Sub_Contrat.Remove_Sub (L_Subs, Subs.Who);
when Message.Filtration =>
null;
-- pas implemente
when Message.Unfiltration =>
null;
-- pas implemente
when Message.Identify =>
null;
-- sans signification pour l'orb
when Message.Rfailed =>
Text_Io.Put_Line
("Orb : received an error on returning a request");
Message.Unfill_Origin (M, Origin);
Message.Unfill_Content (M, N_Contrat);
Destination := Sub_Contrat.Contrat_Provider
(L_Contrat, N_Contrat);
if Identification.Tclient_Id'Image (Destination) =
Identification.Tclient_Id'Image (Origin) then
Ident_Link.Search_Link (Traiteur => Origin,
To_Who => Destination,
Contrat => My_Contrat);
Message.Fill_Origin (M, Orb_Id);
Message_T_S.Mess := M;
Message_T_S.Id := Destination;
Identification.Search_Object (Destination, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
Ident_Link.Delete_Link (Destination);
Sub_Contrat.Switch_Status (L_Contrat, Origin, False);
else
Message.Fill_Origin (M, Orb_Id);
Message.Fill_Command (M, Message.Request);
Message_T_S.Mess := M;
Message_T_S.Id := Destination;
Identification.Search_Object (Destination, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
Ident_Link.Search_Link (Traiteur => Origin,
To_Who => Destination,
Contrat => My_Contrat);
Ident_Link.Delete_Link (Destination);
Ident_Link.Enter_New_Link (Traiteur => Message_T_S.Id,
To_Who => Destination,
Contrat => My_Contrat);
end if;
when Message.Ifailed =>
Text_Io.Put_Line ("Orb : received an error : message lost.);");
end case;
end Moulinette;
begin
Text_Io.Put_Line ("ORB : ready...");
loop
if not Bal.Is_Empty_Rm then
Bal.Get_Rm (M);
Moulinette (M);
end if;
end loop;
end Orb;
nblk1=c
nid=0
hdr6=18
[0x00] rec0=25 rec1=00 rec2=01 rec3=066
[0x01] rec0=1c rec1=00 rec2=04 rec3=01a
[0x02] rec0=11 rec1=00 rec2=02 rec3=09c
[0x03] rec0=1b rec1=00 rec2=06 rec3=054
[0x04] rec0=00 rec1=00 rec2=0b rec3=00a
[0x05] rec0=17 rec1=00 rec2=03 rec3=000
[0x06] rec0=14 rec1=00 rec2=08 rec3=026
[0x07] rec0=1c rec1=00 rec2=09 rec3=01a
[0x08] rec0=00 rec1=00 rec2=0c rec3=00a
[0x09] rec0=11 rec1=00 rec2=05 rec3=014
[0x0a] rec0=16 rec1=00 rec2=0a rec3=04a
[0x0b] rec0=09 rec1=00 rec2=07 rec3=000
tail 0x2154e005e87c774b6d46f 0x42a00088462060003