🚀 go-pugleaf

"havl" <havl83@wp.pl> wrote in message
news:4242da71@newsgroups.borland.com...

> by length i ment the size of data received by read
> operation ...which was caused by waitfordata returning true

Which is exactly the condition you are supposed to be testing for in the
first place.  According to the WinSock API documentation:

    "If the socket is connection oriented and the remote side has shut down
the connection gracefully, a recv will complete immediately with zero bytes
received."

> a single clientthread goes like this

Use this code instead:

    bool __fastcall TMyThread::ReadBuffer(TWinSocketStream *Strm, void
*Buffer, int Count)
    {
        BYTE *pBuf = (BYTE*) Buffer;
        int read;

        try
        {
            while( Count > 0 )
            {
                read = Strm->Read(pBuf, Count);
                if( u < 0 )
                {
                    // socket error
                    return false;
                }
                if( u == 0 )
                {
                    // socket disconnected
                    return false;
                }
                pBuf += read;
                Count -= read;
            }
            return true;
       }
        catch(const Exception &)
        {
            // socket error
            return false;
        }
    }

    bool __fastcall TMyThread::WriteBuffer(TWinSocketStream *Strm, void
*Buffer, int Count)
    {
        BYTE *pBuf = (BYTE*) Buffer;
        int written;

        try
        {
            while( Count > 0 )
            {
                written = Strm->Write(pBuf, Count);
                if( u < 0 )
                {
                    // socket error
                    return false;
                }
                if( u == 0 )
                {
                    // socket disconnected
                    return false;
                }
                pBuf += read;
                Count -= read;
            }
            return true;
       }
        catch(const Exception &)
        {
            // socket error
            return false;
        }
    }

    void __fastcall TMyThread::ClientExecute()
    {
        TWinSocketStream* str = new TWinSocketStream(ClientSocket, timeout);
        while( (!Terminated) && (ClientSocket->Connected) )
        {
            if( str->WaitForData(5) )
            {
                if( !ReadBuffer(str, rbuf, hsize);
                    break;
                // process rbuf as needed...
            }

            if( w )
            {
                if( !WriteBuffer(wbuf, sw) )
                    break;
                // clear buffer
            }
        }
        delete strm;
    }


Gambit