DataMuseum.dk

top - metrics - download

    Length: 2144 (0x860)
    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 Signature;
with Parameter;

separate (Broker)
procedure Registration (M : Message.Object) is
    Mes : Message.Object;
    Met : Method.Object;
    Sig : Signature.Object;
    Host : Parameter.Object;
    Socket : Parameter.Object;
    Par : Parameter.Object;

    Id : Identifier.Object;

    Iter : Signature.Iterator;

    S : Message_Transport.Status_Code;

    use Message_Transport;
begin  
    New_Line;
    Put_Line ("+++ Received registration " &
              Method.Image (Message.Get_Method (M)));

    Sig := Method.Get_Signature (Message.Get_Method (M));

    Signature.Init (Iter, Sig);

    Host := Signature.Value (Iter);

    Signature.Next (Iter);

    Socket := Signature.Value (Iter);


    Id := Identifier.Register (Host => Parameter.Get_Value (Host),
                               Socket => Message_Transport.Socket'Value
                                            (Parameter.Get_Value (Socket)));



    Par := Parameter.Create (Name => Behavior_Defs.Identification_Parameter,
                             Class => Behavior_Defs.Identification_Class,
                             Value => Natural'Image (Identifier.Hash (Id)));

    Sig := Signature.Create;
    Signature.Add (To_Signature => Sig, The_Parameter => Par, At_Position => 1);

    Met := Method.Create
              (Name => Behavior_Defs.Identification_Name, Signature => Sig);

    Mes := Message.Create (Class => Message.Notification,
                           Addressee => Identifier.Hash (Id),
                           Sender => Identifier.Hash (Identifier.Broker),
                           Method => Met);

    Message_Transport.Put (Message => Message.Image (Mes),
                           Remote_Host => Identifier.Get_Host (Id),
                           Remote_Socket => Identifier.Get_Socket (Id),
                           Number_Of_Retry => 10,
                           Retry_Delay => 0.1,
                           Status => S);

    if S = Message_Transport.Ok then
        Put_Line ("+++ Behavior registered");
    else
        Put_Line ("*** Behavior not registered");
    end if;

end Registration;