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

⟦8a08b74d0⟧ Ada Source

    Length: 4096 (0x1000)
    Types: Ada Source
    Notes: 03_class, FILE, R1k_Segment, e3_tag, package body Behavior, seg_050871

Derivation

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

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;

    nblk1=3
    nid=0
    hdr6=6
        [0x00] rec0=22 rec1=00 rec2=01 rec3=082
        [0x01] rec0=25 rec1=00 rec2=02 rec3=020
        [0x02] rec0=20 rec1=00 rec2=03 rec3=000
    tail 0x2154aee04878e4ce935a1 0x42a00088462060003