DataMuseum.dk

top - download

    Length: 2467 (0x9a3)
    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 Broker_Link_Layer;
with Host_Name;
with Low_Level_Message;
with Mailbox_Msg_To_Send;
with Mailbox_Received_Msg;
with Physical_Layer;
with Protocol;
with Socket_Defs;
with Socket_Port;
with Text_Io;
with Umps_Utilities;


package body Broker_Umps_Message is


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

    Task_Performing_Mailbox_Received_Msg :
       Mailbox_Received_Msg.Access_Task_Mailbox :=
       new Mailbox_Received_Msg.Task_Mailbox;

    Task_Performing_Mailbox_Msg_To_Send :
       Mailbox_Msg_To_Send.Access_Task_Mailbox :=
       new Mailbox_Msg_To_Send.Task_Mailbox;


    Task_Server : Broker_Link_Layer.T_Server;
    Task_Client : Broker_Link_Layer.T_Client;

    procedure Init is
        The_Broker_Listen_Socket_Port : Socket_Port.Object;
        The_Broker_Host_Name          : Host_Name.Object;

        -- for the tests :
        Default_Brocker_Host_Name : constant String := "belladone";

    begin

        Text_Io.Put_Line
           ("Broker_umps_message manager : Start Server task V.0.1");

        -- Read "parameters" file to find the Brocker Listen socket port :

        -- TO CHANGE ....

        The_Broker_Listen_Socket_Port := Socket_Port.Create (9860);  
        The_Broker_Host_Name := Host_Name.Create (Default_Brocker_Host_Name);

        -- .... TO CHANGE !!!

        Task_Server.Start (The_Broker_Listen_Socket_Port,
                           Task_Performing_Mailbox_Received_Msg);

        Task_Client.Start (Task_Performing_Mailbox_Msg_To_Send);

    end Init;


    procedure Put (Something : in out String; Result : out Boolean) is
        The_Msg_To_Send : Low_Level_Message.Object;
    begin

        The_Msg_To_Send := Low_Level_Message.Create (Something);
        Task_Performing_Mailbox_Msg_To_Send.Put (The_Msg_To_Send, Result);

    end Put;


    procedure Get (Something                     : in out String;
                   Number_Of_Characters_Received : out    Natural;
                   Result                        : in out Boolean) is
        Received_Msg : Low_Level_Message.Object;

    begin

        Task_Performing_Mailbox_Received_Msg.Get (Received_Msg, Result);
        if Result = True then
            Something := Umps_Utilities.Normalize
                            (Received_Msg.The_String, Something'Length);
            Number_Of_Characters_Received := Received_Msg.The_Size;
        end if;
    end Get;

end Broker_Umps_Message;