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

⟦4d499921a⟧ Ada Source

    Length: 6144 (0x1800)
    Types: Ada Source
    Notes: 03_class, FILE, R1k_Segment, e3_tag, package body Com_Orb, seg_055112

Derivation

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

E3 Source Code



with Transport, Transport_Defs, Text_Io, Utils, Byte_Defs, Host_Id_Io, Com_Defs;

package body Com_Orb is

    procedure Init_Orb (Init_Connection : in out Transport.Connection_Id;
                        Init_Host_Orb : in Transport_Defs.Host_Id;
                        Init_Host_Response : in out Transport_Defs.Host_Id;
                        Init_Socket_Orb : in Transport_Defs.Socket_Id;
                        Init_Response_Socket : in out
                           Transport_Defs.Socket_Id) is

        Status : Transport_Defs.Status_Code;
        Network_Name : constant Transport_Defs.Network_Name := "TCP/IP";
        Count : Natural;
        Receive_Socket_Data : Byte_Defs.Byte_String (1 .. 2);
        Receive_Host_Data : Byte_Defs.Byte_String (1 .. 4);
    begin
        loop
            Transport.Open (Init_Connection, Status,
                            Network_Name, Init_Socket_Orb);  
            exit when Transport.Is_Open (Init_Connection) = True;
        end loop;
        Text_Io.Put_Line ("Orb is opened");
        loop
            Transport.Connect (Init_Connection, Status, Duration'Last);
            exit when Transport.Is_Connected (Init_Connection) = True;
        end loop;
        Text_Io.Put_Line ("Orb is passive connected");
        Transport.Receive (Init_Connection, Status,
                           Receive_Socket_Data, Count, Duration'Last);
        Init_Response_Socket := Transport_Defs.Socket_Id (Receive_Socket_Data);
        Transport.Receive (Init_Connection, Status,
                           Receive_Host_Data, Count, Duration'Last);
        Init_Host_Response := Transport_Defs.Host_Id (Receive_Host_Data);
        --Init_Response_Socket := Transport.Remote_Socket (Init_Connection);
        --Init_Response_Host := Transport.Remote_Host (Init_Connection);
        --Text_Io.Put ("Socket esclave : ");
        --Text_Io.Put_Line (Utils.Byte_String_To_String
        -- (Byte_Defs.Byte_String (Init_Response_Socket));
        --Text_Io.Put ("Machine esclave : ");
        --Text_Io.Put_Line (Host_Id_Io.Image (Init_Response_Host));
        Transport.Disconnect (Init_Connection);  
        Text_Io.Put_Line ("Orb is disconnected");
        loop
            Transport.Connect (Init_Connection, Status, Init_Host_Response,
                               Init_Response_Socket, Duration'Last);
            exit when Transport.Is_Connected (Init_Connection) = True;
        end loop;
        --loop
        --   Transport.Connect (Init_Connection, Status,
        --                      Init_Response_Host,
        --                      Init_Response_Socket, Duration'Last);
        --   exit when Transport.Is_Connected (Init_Connection) = True;
        -- end loop;
        Text_Io.Put_Line ("Orb is active connected");
        Transport.Disconnect (Init_Connection);  
        Text_Io.Put_Line ("Orb is disconnected");
        --Transport.Close (Init_Connection);
        --Text_Io.Put_Line ("Orb is closed");
    end Init_Orb;


    task body Orb_Machine is
        Connection : Transport.Connection_Id;
        Network_Name : constant Transport_Defs.Network_Name := "TCP/IP";
        Host_Orb : constant Transport_Defs.Host_Id :=
           Transport.Local_Host (Network_Name);
        Host_Response : Transport_Defs.Host_Id (1 .. 4);
        Socket_Orb : Transport_Defs.Socket_Id (1 .. 2) := (10, 49);
        Socket_Response : Transport_Defs.Socket_Id (1 .. 2);
        Data_Message : constant String := "hello world";
        Data_Message_Orb : Byte_Defs.Byte_String (1 .. Data_Message'Last) :=
           Utils.String_To_Byte_String (Data_Message);
        Data_Flag_Orb : Byte_Defs.Byte := 0;
        Data_Transmit_Orb : Byte_Defs.Byte_String
                               (1 .. (Data_Message'Last + 1)) :=
           Byte_Defs."&" (Data_Flag_Orb, Data_Message_Orb);
        Status_Orb : Boolean;
        Status : Transport_Defs.Status_Code;
        Count : Natural;
    begin
        Init_Orb (Connection, Host_Orb, Host_Response,
                  Socket_Orb, Socket_Response);
        loop  
            Transport.Connect (Connection, Status, Host_Response,
                               Socket_Response, Duration'Last);
            exit when Transport.Is_Connected (Connection) = True;
        end loop;
        Text_Io.Put_Line ("I am trying to transmit the message");
        Transport.Transmit (Connection, Status, Data_Transmit_Orb,
                            Count, Duration'Last);
        Text_Io.Put_Line (Transport_Defs.Image (Status));
        Transport.Disconnect (Connection);
        Transport.Close (Connection);
    end Orb_Machine;
end Com_Orb;

E3 Meta Data

    nblk1=5
    nid=0
    hdr6=a
        [0x00] rec0=16 rec1=00 rec2=01 rec3=082
        [0x01] rec0=12 rec1=00 rec2=02 rec3=056
        [0x02] rec0=14 rec1=00 rec2=03 rec3=01c
        [0x03] rec0=15 rec1=00 rec2=04 rec3=006
        [0x04] rec0=11 rec1=00 rec2=05 rec3=000
    tail 0x2175da78287b88776dcb8 0x42a00088462060003