🚀 go-pugleaf

>Uh, I hope this will work

Yes, It worked perfectly...

I have read one of your posts some time ago...

> the client-side code you currently have will not work
> as-is if you are using non-blocking mode, because you
> are not checking for when SendBuffer() fails to send
> any data due to blocking.  When that happens, you have
> to wait for the OnWrite event to trigger before you can
> send more data again.  Otherwise, you are going to corrupt
> your data stream because not all of the data will be sent
> correctly.

... and I have the same situation in NonBlocking mode. How
can I addopt the code I have, to work synchronized with
OnWrite(), or I have to take a completely different approach?

Should that change also affect the servers receiving mechanism?

   BYTE Buffer [ BUFFER_SIZE ];
   int CurrentPosition = 0;
   int Delta;
   while ( ( Delta = OutboxDataBuffer->Size - CurrentPosition ) > 0 )
   {
      int NumberOfBytesRead = ( Delta < BUFFER_SIZE ? Delta : BUFFER_SIZE );
      OutboxDataBuffer->Seek( CurrentPosition, soFromBeginning );
      OutboxDataBuffer->ReadBuffer( Buffer, NumberOfBytesRead );
      int NumberOfBytesSent = ClientSocket->Socket->SendBuf( Buffer, NumberOfBytesRead );
      if ( NumberOfBytesSent < 1 ) // <--- this happens in non-blocking mode after 8K
         return; // Error ...
      CurrentPosition += NumberOfBytesSent;
    }


Just one more thing:

I thought that within Open/Close...

   ClientSocket->Open()
      ClientSocket->Socket->SendBuf()
   ClientSocket->Close()   

... I am addressing the same unique ServerSocketClientRead
instance:
 
   void __fastcall TserverForm::ServerSocketClientRead(TObject *Sender,
         TCustomWinSocket *Socket)
   {
      // ...
      int NewSize;
      // ... NewSize increases ...
      this->Caption = IntToStr ( NewSize );
   }

... but when Closed() and again Opened(), 'NewSize' continues
counting like it is static! In fact 'NewSize' continues counting
for all clients' connections when sending. I realize that this
must have some sense and I'm trying to figure it out. Is that
in connection with servers' blocking modes?

All this I need to find out the way how to:

* Deploy and recognize connection of a speciffic client and
somehow make it's own TMemoryStream for receiving, decoding
and adding to the shared list (with critical section involved).

* Inform the server what stream size to expect (embed that
into stream, for example first 10 bytes ASCII, or a separate
call)




Best regards,
Vladimir Stefanovic