|
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: 7168 (0x1c00)
Types: Ada Source
Notes: 03_class, FILE, R1k_Segment, e3_tag, package body My_Broker, seg_055291
└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
└─⟦cfc2e13cd⟧ »Space Info Vol 2«
└─⟦this⟧
with Text_Io;
with Generic_Tools_Server;
with Const_Orb;
with Queue_Generic;
with Bounded_String;
package body My_Broker is
task body Collecting_Task is
Message_To_Fifo : My_Message.Object;
begin
accept Start;
Text_Io.Put_Line ("Collecting_Task has started to run");
loop
My_Message.Receive (Message_To_Fifo,
Bounded_String.Value (Const_Orb.Broker_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;
Text_Io.Put_Line ("Buffering_Task has started to run");
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;
Text_Io.Put_Line ("Dispatching_Task has started to run");
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.Reply
| My_Message.Forward_Reply =>
Generic_Tools_Server.Print (Message_From_Fifo);
when My_Message.Forward =>
declare
procedure Reply_Of_The_Server is
new Generic_Tools_Server.Reply
(Service => Service_Server);
begin
Reply_Of_The_Server
(Mess_Received => Message_From_Fifo);
end;
when others =>
null;
end case;
end loop;
end Dispatching_Task;
end My_Broker;
nblk1=6
nid=6
hdr6=6
[0x00] rec0=27 rec1=00 rec2=01 rec3=058
[0x01] rec0=1e rec1=00 rec2=02 rec3=048
[0x02] rec0=18 rec1=00 rec2=03 rec3=000
[0x03] rec0=04 rec1=00 rec2=06 rec3=008
[0x04] rec0=12 rec1=00 rec2=05 rec3=01c
[0x05] rec0=0c rec1=00 rec2=04 rec3=001
tail 0x2175ef95687bc6cf908f8 0x42a00088462060003
Free Block Chain:
0x6: 0000 00 04 00 0c 80 06 72 6f 6b 65 72 3b 06 00 00 00 ┆ roker; ┆
0x4: 0000 00 05 01 0a 80 05 69 66 6f 29 3b 05 00 28 20 20 ┆ ifo); ( ┆
0x5: 0000 00 00 03 fc 80 3b 20 20 20 20 20 20 20 20 20 20 ┆ ; ┆