void TestNetworkWorker::Run(EventLoop         * pEventLoop,
                            CoroBase          * pCoroMain,
                            CoroBase          * pCoroWorker,
                            ClientCoroSocket  * pClientSocket)
{
    const UINT_32 iBufSize = 65536;
    CHAR_P sBuffer = (CHAR_P)malloc(iBufSize);

    CoroSocketPoll oPoll(pCoroMain, pCoroWorker);
    Poll::PollRec oPollRec;
    oPollRec.socket = pClientSocket;

    for(;;)
    {
        UINT_64 iReadBytes = 0;
        UINT_64 iSentBytes = 0;

        oPollRec.events = Poll::READ;
        oPoll.Poll(&oPollRec, 1, 1000);
        pClientSocket -> Read(sBuffer, iBufSize, iReadBytes);

        oPollRec.events = Poll::WRITE;
        oPoll.Poll(&oPollRec, 1, 1000);

        pClientSocket -> Write(sBuffer, iReadBytes, iSentBytes);
    }
    free(sBuffer);
}

void TestNetworkWorker::Run(ClientSocket  * pClientSocket)
{
    const UINT_32 iBufSize = 65536;
    CHAR_P sBuffer = (CHAR_P)malloc(iBufSize);

    SocketPoll oPoll;
    Poll::PollRec oPollRec;
    oPollRec.socket = pClientSocket;

    for(;;)
    {
        UINT_64 iReadBytes = 0;
        UINT_64 iSentBytes = 0;

        oPollRec.events = Poll::READ;
        oPoll.Poll(&oPollRec, 1, 1000);
        pClientSocket -> Read(sBuffer, iBufSize, iReadBytes);

        oPollRec.events = Poll::WRITE;
        oPoll.Poll(&oPollRec, 1, 1000);

        pClientSocket -> Write(sBuffer, iReadBytes, iSentBytes);
    }
    free(sBuffer);
}