DataMuseum.dk

top - download

    Length: 2766 (0xace)
    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 Behavior_Defs;
with Identifier;
with Message;
with Message_Transport;
with Method;
with Parameter;
with Signature;
package body Behavior is

    This : Identifier.Object; -- set once the behavior has been identified

    Registered : Boolean := False;


    procedure Register_Service (Host : String;
                                Socket : Message_Transport.Socket) is separate;


    function Identified (M : String) return Boolean is separate;



    procedure Process_Message (M : String) is
    begin
        Process_Message (Message.Value (M));
    end Process_Message;


    procedure Transport_Start is new Message_Transport.Start_Server
                                        (Register_Service => Register_Service,
                                         Service_Identified => Identified,
                                         Ready_To_Receive => Ready_To_Receive,
                                         Receive_Callback => Process_Message);


    task Server is
        entry Start;
        pragma Os_Task (0); --[to get non blocking socket reads]
    end Server;


    task body Server is
    begin
        accept Start;

        Transport_Start (Local_Socket => 0, Buffer_Size => 1024);
        --
        -- when Local_Socket is 0 the transport layer will invent one


    end Server;


    procedure Send_Message (Message : Standard.Message.Object;
                            Status : out Message_Transport.Status_Code) is

        Addressee : Identifier.Object :=
           Identifier.Value (Standard.Message.Get_Addressee (Message));

        use Standard.Message;
    begin

        if not Registered then
            raise Not_Yet_Registered_Error;
        end if;

        if Standard.Message.Get_Class (Message) = Standard.Message.Forward then
            Message_Transport.Put
               (Message => Standard.Message.Image (Message),
                Remote_Host => Identifier.Get_Host (Identifier.Broker),
                Remote_Socket => Identifier.Get_Socket (Identifier.Broker),
                Number_Of_Retry => 10,
                Retry_Delay => 0.1,
                Status => Status);

        else
            Message_Transport.Put
               (Message => Standard.Message.Image (Message),
                Remote_Host => Identifier.Get_Host (Addressee),  
                Remote_Socket => Identifier.Get_Socket (Addressee),
                Number_Of_Retry => 10,
                Retry_Delay => 0.1,
                Status => Status);

        end if;
    end Send_Message;


    function Get_Identity return Identifier.Object is
    begin  
        if not Registered then
            raise Not_Yet_Registered_Error;
        end if;

        return This;
    end Get_Identity;


begin
    Server.Start;
end Behavior;