DataMuseum.dk

top - download

    Length: 1860 (0x744)
    Types: TextFile
    Names: »B«

└─⟦149519bd4⟧ Bits:30000546 8mm tape, Rational 1000, !projects 93-07-13
    └─ ⟦124ff5788⟧ »DATA« 
        └─⟦this⟧ 
└─⟦a7d1ea751⟧ Bits:30000550 8mm tape, Rational 1000, !users!projects 94_04_11
    └─ ⟦129cab021⟧ »DATA« 
        └─⟦this⟧ 
└─⟦f64eaa120⟧ Bits:30000752 8mm tape, Rational 1000, !projects 93 02 16
    └─ ⟦6f12a12be⟧ »DATA« 
        └─⟦this⟧ 
└─⟦2f6cfab89⟧ Bits:30000547 8mm tape, Rational 1000, !projects 94-01-04
    └─ ⟦d65440be7⟧ »DATA« 
        └─⟦this⟧ 

TextFile

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;