🚀 go-pugleaf

Alfred wrote:
> I am making a client/server application with
> TClientSocket/TServerSocket and i have a little problem.
> - when the server read I can have only a part of the full package
> (for lag, fragmentation... ) so my idea is to make my package I send
> from client to server like it : "1234xxxxxxxxx" so 1234 is the full
> lenght of the data the server need to riceve and xxxxx are the data.
> Here is the problem , for example :
> - server get only half package, if i read the "1234"
> (Socket->ReceiveBuf(buf,4);)  and i check Socket->ReceiveLength() I
> can see the package is not complete, but If I wait till next
> ClientSocketRead for a full package I cannot read again the length
> for another check before process it. This can not be a problem with a
> single client becouse i can save the lenght into a string somewhere
> but it is a problem with a high traffic server i think. I dont like
> indy, i like to make all by myself..
> Any idea ?

How about this:

In the header file, add this:
struct TDataStruct
{
    int Length;
    TMemoryStream *DataStream;
};

In your OnClientConnect write this:
{
    TDataStruct *Data = new TDataStruct;
    Data->Length = -1;
    Data->DataStream = new TMemoryStream;
    Socket->Data = Data;
}

Then in your OnClientRead
{
    int DataLength;
    TDataStruct *Data = static_cast<TDataStruct>( Socket->Data );

    if( Data->Length == -1 )
        Socket->ReceiveBuf( &(Data->Length), sizeof( int ) );

    DataLength = min( Socket->ReceiveLength(), Data->Length );
    if( DataLength > 0 )
    {
        char *Buffer = new char[ DataLength ];

        Socket->ReceiveBuf( Buffer, DataLength );
        Data->DataStream->Write( Buffer, DataLength );

        delete[] Buffer;
    }

    Data->Length -= DataLength;
    if( Data->Length == 0 )
    {
        // process your command here.
        // it is stored in Data->DataStream.
        // the stream is cleared once you've finished.

        Data->Length = -1;
        DataStream->Clear();
    }
}

In your OnClientDisconnect
{
    TDataStruct *Data = static_cast<TDataStruct>( Socket->Data );
    delete Data;

    Socket->Data = NULL;
}

Jonathan