DataMuseum.dk Presents historical artifacts from the history of: Rational R1000/400

This is an automatic "excavation" of a thematic subset of artifacts from Datamuseum.dk's BitArchive. See our Wiki for more about Rational R1000/400 Excavated with: AutoArchaeologist - Free & Open Source Software.

top - download

⟦6a7ec58f4⟧ Ada Source

    Length: 3072 (0xc00)
    Types: Ada Source
    Notes: 03_class, FILE, R1k_Segment, e3_tag, package body Broker_Msg, seg_02424a

Derivation

└─⟦8527c1e9b⟧ Bits:30000544 8mm tape, Rational 1000, Arrival backup of disks in PAM's R1000
    └─ ⟦cfc2e13cd⟧ »Space Info Vol 2« 
        └─⟦this⟧ 

with Couche_Haute_Msg;  
with Fifo_Msg_To_Send;
with Fifo_Received_Msg;  
with My_Utilities;
with Socket_Defs;
with Text_Io;


package body Broker_Msg is



    -- Create the tasks witch controlled the fifo where are stocked temporary the messages :

    Task_Performing_Fifo_Received_Msg : Fifo_Received_Msg.Access_Task_Fifo :=
       new Fifo_Received_Msg.Task_Fifo;

    Task_Performing_Fifo_Msg_To_Send : Fifo_Msg_To_Send.Access_Task_Fifo :=
       new Fifo_Msg_To_Send.Task_Fifo;






    procedure Init is
        Listen_Socket_Port : Socket_Defs.Socket_Port := -1;
        Service_Socket_Id  : Socket_Defs.Socket_Id;
    begin

        Text_Io.Put_Line ("Server messages performer V.0.1");

        -- Read "parameters" file to find the Brocker Listen socket port :
        -- TO CHANGE ....
        Listen_Socket_Port := 9876;
        -- .... TO CHANGE !!!

        Couche_Haute_Msg.Server_Task.Start (Listen_Socket_Port,
                                            Task_Performing_Fifo_Received_Msg);
        Couche_Haute_Msg.Client_Task.Start
           (Listen_Socket_Port, Task_Performing_Fifo_Msg_To_Send);


        Text_Io.Put_Line ("Init Broker OK.");

    exception
        when others =>
            Text_Io.Put_Line ("broker_msg.init : unknown error");
            raise Socket_Defs.Create_Broker_Error;
    end Init;





    procedure Put (Something : in out String; Result : out Boolean) is
        The_Msg : Socket_Defs.Msg;
    begin
        My_Utilities.Normalize (Something, The_Msg);
        Task_Performing_Fifo_Msg_To_Send.Put (The_Msg, Result);
    end Put;






    procedure Get (Something : in out String; Result : out Boolean) is
        The_Msg : Socket_Defs.Msg;
    begin  
        Task_Performing_Fifo_Received_Msg.Get (The_Msg, Result);
        My_Utilities.Normalize (The_Msg, Something);
    end Get;

end Broker_Msg;

    nblk1=2
    nid=0
    hdr6=4
        [0x00] rec0=28 rec1=00 rec2=01 rec3=00e
        [0x01] rec0=25 rec1=00 rec2=02 rec3=001
    tail 0x2171f62b2839c4a9fc9d7 0x42a00088462063203