DataStreamExch, exchanges data between two I/O streams

PROGRAM ST_DataStreamExch_v1
VAR
    Sp : SysSerialPort; (* Serial port management *)
    Sk : SysTCPServer; (* Socket server *)
    Fp : FILEP; (* File pointer *)
    DExch : DataStreamExch_v1; (* Data exchange *)
END_VAR

// *****************************************************************************
// PROGRAM "ST_DataStreamExch_v1"
// *****************************************************************************
// This program acts as a Ethernet to serial converter, the data received from
// the ethernet connection are forwarded to serial and vice versa.
// -----------------------------------------------------------------------------

    // -------------------------------------------------------------------------
    // INITIALIZATION
    // -------------------------------------------------------------------------
    // Program initializations.

    IF (SysFirstLoop) THEN

        // Initialize serial port.

        Sp.COM:=ADR('COM0'); //Serial port
        Sp.Baudrate:=115200; //Baud rate
        Sp.Parity:='E'; //Parity
        Sp.DataBits:=8; //Data bits
        Sp.StopBits:=1; //Stop bits
        Sp.DTRManagement:=DTR_AUTO_WO_TIMES; //DTR management

        // Initialize socket server.

        Sk.FilesArr:=ADR(Fp); //File array
        Sk.MaxConn:=1; //Number of connections accepted
        Sk.LocalAdd:=ADR('0.0.0.0'); //Local address
        Sk.LocalPort:=2000; //Local port
        Sk.LifeTm:=60; //TSocket life time (S)
        Sk.FlushTm:=10; //Socket flush time (mS)
        Sk.RxSize:=1024; //Rx size buffer
        Sk.TxSize:=1024; //Tx size buffer

        // Initialize data stream exchange.

        DExch.DBMax:=2048; //Data buffer maximum size
        DExch.DBLife:=5.0; //Data buffer life (S)
    END_IF;

    // -------------------------------------------------------------------------
    // DATA STREAM EXCHANGE
    // -------------------------------------------------------------------------
    // Execute the data stream exchange.

    Sp(Open:=TRUE); //Serial port management
    Sk(Enable:=TRUE); //TCP server management
    DExch.FpA:=Fp; //File pointer        
    DExch.FpB:=Sp.File; //File pointer
    DExch(Enable:=(Sk.ConnPeers <> 0)); //Data exchange

// [End of file]