|
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: 6144 (0x1800)
Types: Ada Source
Notes: 03_class, FILE, R1k_Segment, e3_tag, procedure Orb, seg_055228
└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
└─⟦cfc2e13cd⟧ »Space Info Vol 2«
└─⟦this⟧
with Bal;
with Sub_Contrat;
with Sub_Registration;
with Identification;
with Message;
with Trans;
with Text_Io;
procedure Orb is
M : Message.Tmessage;
procedure Moulinette (M : in out Message.Tmessage) is
Commander : Message.Command_Type;
Contract : Sub_Contrat.Tcontrat;
L_Contrat : Sub_Contrat.Contrat_List.List;
N_Contrat : Sub_Contrat.Tnom_Contrat;
Subs : Sub_Contrat.Tsubscription;
L_Subs : Sub_Contrat.Sub_List.List;
Id_Tmp : Identification.Tclient_Id;
Message_T_S : Bal.Tmess_To_Send;
begin
Message.Unfill_Command (M, Commander);
case Commander is
when Message.Registration =>
Text_Io.Put_Line
("Message recu par ORB comme un registration...");
-- Sub_Registration.Alloc_Ident (M, Id_Tmp);
-- renvoyer son id au client
when Message.Unregistration =>
null;
Message.Unfill_Origin (M, Id_Tmp);
Sub_Registration.Desalloc_Ident (Id_Tmp);
when Message.Queries =>
null;
when Message.Request =>
Message.Unfill_Content (M, N_Contrat);
if Sub_Contrat.Contrat_Exists (L_Contrat, N_Contrat) then
Id_Tmp := Sub_Contrat.Contrat_Provider
(L_Contrat, N_Contrat);
M.Command := Message.Forward;
Message_T_S.Mess := M;
Message_T_S.Id := Id_Tmp;
--Identification.Search_Object (Id_Tmp, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
end if;
when Message.Notification =>
null;
-- pas implemente
when Message.Publication =>
Sub_Contrat.Fill_Contrat (M, Contract);
Sub_Contrat.Add_Contrat (L_Contrat, Contract);
when Message.Unpublication =>
Message.Unfill_Content (M, N_Contrat);
Sub_Contrat.Remove_Contrat (L_Contrat, N_Contrat);
when Message.Forward =>
-- faire le reply a l'objet
if Sub_Contrat.Subscription_Exists (L_Subs, M.Origin) then
Id_Tmp := Sub_Contrat.Subscripter (L_Subs, M.Origin);
M.Command := Message.Forward;
Message_T_S.Mess := M;
Message_T_S.Id := Id_Tmp;
--Identification.Search_Object (Id_Tmp, Message_T_S.Des);
Bal.Put_Mts (Message_T_S);
end if;
when Message.Subscription =>
Sub_Contrat.Fill_Sub (M, Subs);
Sub_Contrat.Add_Sub (L_Subs, Subs);
when Message.Unsubscription =>
Sub_Contrat.Fill_Sub (M, Subs);
Sub_Contrat.Remove_Sub (L_Subs, Subs.Who);
when Message.Filtration =>
null;
-- pas implemente
when Message.Unfiltration =>
null;
-- pas implemente
end case;
end Moulinette;
begin
loop
if not Bal.Is_Empty_Rm then
Bal.Get_Rm (M);
Moulinette (M);
end if;
end loop;
end Orb;
nblk1=5
nid=2
hdr6=8
[0x00] rec0=20 rec1=00 rec2=01 rec3=00c
[0x01] rec0=19 rec1=00 rec2=05 rec3=024
[0x02] rec0=17 rec1=00 rec2=03 rec3=012
[0x03] rec0=13 rec1=00 rec2=04 rec3=000
[0x04] rec0=0f rec1=00 rec2=02 rec3=000
tail 0x2175f214a87bc7c49994b 0x42a00088462060003
Free Block Chain:
0x2: 0000 00 00 01 44 80 08 70 6c 65 6d 65 6e 74 65 08 00 ┆ D plemente ┆