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

⟦c04b3c94f⟧ Ada Source

    Length: 5120 (0x1400)
    Types: Ada Source
    Notes: 03_class, FILE, R1k_Segment, e3_tag, generic, package Message_Transport_Dess, seg_050859

Derivation

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

E3 Source Code



with Transport;  
with Unbounded_String;
package Message_Transport_Dess is
    package Unlimited_String is new Unbounded_String (1000);
    type Socket is range 0 .. 65535;

    type Status_Code is (Ok, Number_Of_Retry_Exceeded,
                         Incomplete_Transmission, Connection_Failed);

    type Stream_Id is private;

    Connection_Error : exception;

    procedure Create (Remote_Host : String;
                      Remote_Socket : Socket;
                      Number_Of_Retry : Positive := 1;
                      Retry_Delay : Duration := 0.1;
                      Stream : out Stream_Id;
                      Status : out Status_Code);

    procedure Close (Stream : Stream_Id);

    procedure Put (Stream : Stream_Id;
                   Message : String;
                   Status : out Status_Code);

    procedure Put (Stream : Stream_Id;
                   Message : Unlimited_String.Variable_String;
                   Status : out Status_Code);

    procedure Put (Stream : Stream_Id;
                   Message : in String;
                   Response : out Unlimited_String.Variable_String;
                   Status : out Status_Code);

    procedure Put (Stream : Stream_Id;
                   Message : in String;
                   Response : out String;
                   Status : out Status_Code);

    function Hash (Stream : Stream_Id) return Natural;

    generic
        with procedure Register_Service (Host : String;
                                         Local_Socket : Socket;
                                         Stream : out Stream_Id);
        with function Service_Identified (Message : String) return Boolean;
        with procedure Ready_To_Receive;
        with procedure Receive_Callback (Stream : Message_Transport.Stream_Id;
                                         Message : String);

    procedure Start_Server (Local_Socket : Socket;
                            Buffer_Size : Positive;
                            Wait_For_Identification : Boolean := True);
    -- raises Connection_Error when a built-in transport layer operation fails

    function Identifie_Connection (Stream : Stream_Id)
                                  return Transport.Connection_Id;
    function Create_Null return Stream_Id;

    function Is_Null (Stream : Stream_Id) return Boolean;

    function Create (With_A : Transport.Connection_Id) return Stream_Id;



private
    type Stream_Id is
        record
            Connect_Id : Transport.Connection_Id :=
               Transport.Null_Connection_Id;
        end record;
end Message_Transport_Dess;


E3 Meta Data

    nblk1=4
    nid=0
    hdr6=8
        [0x00] rec0=1e rec1=00 rec2=01 rec3=03a
        [0x01] rec0=04 rec1=00 rec2=04 rec3=072
        [0x02] rec0=16 rec1=00 rec2=02 rec3=07a
        [0x03] rec0=14 rec1=00 rec2=03 rec3=000
    tail 0x2154aea80878e476d7c4c 0x42a00088462060003