|
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 - download
Length: 10240 (0x2800)
Types: Ada Source
Notes: 03_class, FILE, R1k_Segment, e3_tag, package body My_Broker, seg_055c3b
└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
└─ ⟦5a81ac88f⟧ »Space Info Vol 1«
└─⟦this⟧
with Text_Io;
with Orb_Tools;
with Const_Orb;
with Queue_Generic;
with Bounded_String;
with My_Message;
package body My_Broker is
task Collecting_Task is
entry Start;
end Collecting_Task;
task Buffering_Task is
entry Start;
entry Write_In_Buffering_Fifo (Message : in My_Message.Object);
entry Read_From_Buffering_Fifo (Message : out My_Message.Object);
end Buffering_Task;
task Dispatching_Task is
entry Start;
end Dispatching_Task;
task body Collecting_Task is
Message_To_Fifo : My_Message.Object;
Orb_Local_Id : My_Message.My_String;
begin
accept Start;
Bounded_String.Copy (Orb_Local_Id, Const_Orb.Broker_Id);
loop
My_Message.Receive (Message_To_Fifo, Orb_Local_Id);
My_Broker.Buffering_Task.Write_In_Buffering_Fifo (Message_To_Fifo);
end loop;
end Collecting_Task;
task body Buffering_Task is
package My_Fifo is new Queue_Generic (Element => My_Message.Object);
Buffering_Fifo : My_Fifo.Queue;
begin
accept Start;
loop
select
accept Write_In_Buffering_Fifo
(Message : in My_Message.Object) do
My_Fifo.Add (Buffering_Fifo, Message);
end Write_In_Buffering_Fifo;
or
when not (My_Fifo.Is_Empty (Buffering_Fifo)) =>
accept Read_From_Buffering_Fifo
(Message : out My_Message.Object) do
Message := My_Fifo.First (Buffering_Fifo);
My_Fifo.Delete (Buffering_Fifo);
end Read_From_Buffering_Fifo;
end select;
end loop;
end Buffering_Task;
task body Dispatching_Task is
Message_From_Fifo : My_Message.Object;
Message_Type : My_Message.Kind_Of_Message;
begin
Orb_Tools.Initialize_Data_Structures;
accept Start;
loop
My_Broker.Buffering_Task.Read_From_Buffering_Fifo
(Message_From_Fifo);
Message_Type := My_Message.Get_Operation (Message_From_Fifo);
case Message_Type is
when My_Message.Registration =>
Orb_Tools.Registrate (Message_From_Fifo);
when My_Message.Unregistration =>
Orb_Tools.Unregistrate (Message_From_Fifo);
when My_Message.Request =>
Orb_Tools.Require (Message_From_Fifo);
when My_Message.Notification =>
Orb_Tools.Notify (Message_From_Fifo);
when My_Message.Publication =>
Orb_Tools.Publicate (Message_From_Fifo);
when My_Message.Publication_Filter =>
Orb_Tools.Publicate_Filter (Message_From_Fifo);
when My_Message.Unpublication =>
Orb_Tools.Unpublicate (Message_From_Fifo);
when My_Message.Unpublication_Filter =>
Orb_Tools.Unpublicate_Filter (Message_From_Fifo);
when My_Message.Subscription =>
Orb_Tools.Subscript (Message_From_Fifo);
when My_Message.Unsubscription =>
Orb_Tools.Unsubscript (Message_From_Fifo);
when My_Message.Filtration =>
Orb_Tools.Filtrate (Message_From_Fifo);
when My_Message.Unfiltration =>
Orb_Tools.Unfiltrate (Message_From_Fifo);
when My_Message.Query =>
Orb_Tools.Query (Message_From_Fifo);
when My_Message.Reply =>
Orb_Tools.Reply (Message_From_Fifo);
when My_Message.Content =>
Orb_Tools.Content (Message_From_Fifo);
when My_Message.Reply_Filtration =>
Orb_Tools.Reply_Filtration (Message_From_Fifo);
when others =>
null;
end case;
end loop;
end Dispatching_Task;
procedure Start_My_Broker is
begin
My_Broker.Buffering_Task.Start;
My_Broker.Collecting_Task.Start;
My_Broker.Dispatching_Task.Start;
Text_Io.Put_Line ("BROKER OK");
end Start_My_Broker;
end My_Broker;
nblk1=9
nid=3
hdr6=a
[0x00] rec0=2b rec1=00 rec2=01 rec3=004
[0x01] rec0=1d rec1=00 rec2=05 rec3=010
[0x02] rec0=17 rec1=00 rec2=06 rec3=036
[0x03] rec0=12 rec1=00 rec2=02 rec3=032
[0x04] rec0=16 rec1=00 rec2=09 rec3=000
[0x05] rec0=16 rec1=00 rec2=02 rec3=054
[0x06] rec0=0a rec1=00 rec2=07 rec3=001
[0x07] rec0=a8 rec1=7b rec2=c7 rec3=157
[0x08] rec0=ca rec1=a2 rec2=80 rec3=007
tail 0x2154d802087c054469312 0x42a00088462060003
Free Block Chain:
0x3: 0000 00 07 01 40 80 06 20 6c 6f 6f 70 3b 06 00 00 00 ┆ @ loop; ┆
0x7: 0000 00 04 01 3a 00 33 20 20 20 20 20 20 20 20 54 65 ┆ : 3 Te┆
0x4: 0000 00 08 00 1a 00 17 20 20 20 20 20 20 20 20 20 20 ┆ ┆
0x8: 0000 00 00 00 17 80 07 20 20 20 20 20 6f 72 07 00 0a ┆ or ┆