loopback.c

Go to the documentation of this file.

//#define FILE_LOG_SILENCE
#include "appmod/loopback/loopback.h"

#define TX_RX_MAX_BUF_SIZE  2048


int8 data_buf[TX_RX_MAX_BUF_SIZE];

void loopback_tcps(uint8 sock, uint16 port)
{
    int32 ret;
    int32 SendLen, ReSendLen;

    ret = TCPRecv(sock, data_buf, TX_RX_MAX_BUF_SIZE);

    if(ret > 0){                // Received
        SendLen = TCPSend(sock, data_buf, ret);

        if(SendLen < ret){
            while(SendLen != ret){
                ReSendLen = TCPReSend(sock);

                if(ReSendLen > 0){
                    SendLen += ReSendLen;

                } else if(ReSendLen == SOCKERR_WINDOW_FULL){
                    LOG("Window Full");
                    TCPClose(sock);
                    DBG("TCP Socket Close");
                    while(1);

                } else{
                    break;
                }
            }
        }

    } else if(ret == SOCKERR_NOT_TCP){  // Not TCP Socket, It's UDP Socket
        DBG("UDP Socket Close");
        UDPClose(sock);
    } else if(ret == SOCKERR_CLOSED){       // Socket Closed
        LOGA("TCP Loop-Back Started - sock(%d)",(uint16)sock);
        TCPServerOpen(sock, port);
    }

    if(GetTCPSocketStatus(sock) == SOCKSTAT_CLOSE_WAIT){    // Close waiting
        TCPClose(sock);
    }
}

void loopback_udp(uint8 sock, uint16 port)
{
    int32 ret;
    uint32 destip = 0;
    uint16 destport;

    ret = UDPRecv(sock, data_buf, TX_RX_MAX_BUF_SIZE, (uint8*)&destip, &destport);

    if(ret > 0){                // Received
        ret = UDPSend(sock, data_buf, ret, (uint8*)&destip ,destport);

        if(ret == SOCKERR_TIME_OUT){
            ERR("Timeout");
            UDPClose(sock);
            DBG("UDP Socket Close");
        }

    } else if(ret == SOCKERR_NOT_UDP){  // Not UDP Socket, It's TCP Socket
        DBG("TCP Socket Close");
        TCPClose(sock);
    } else if(ret == SOCKERR_CLOSED){       // Socket Closed
        LOGA("UDP Loop-Back Started - sock(%d)",(uint16)sock);
        UDPOpen(sock, port);
    }
}