🚀 go-pugleaf

Hi all,
I'm developing a simple audio streamer over LAN.
I have a TServerSocket in non-blocking listening on port 5678.
Then I have a TClientSocket that connect to the server.
When one or more connections are ready, the server receive 1000 byte chunk 
of wav data from the sound card and send to all the connected clients.
On the client side when a 1000 byte chunk is received it's buffered, then 
sent to the sound card.
It seems to work fine for some time, then the error 10053 appears.
What I'm doing wrong?

Thanks in advance.

Lapo

-------------------------------

this is the snip of the code

SERVER SIDE:
when a 1000 bytes chunk arrives, Data point to the buffer and BytesReaded is 
the size (usually 1000)
if(TCPLive->Socket->ActiveConnections>0) {
  for(int i=0;i<TCPLive->Socket->ActiveConnections;i++) {
   TCustomWinSocket *Client=TCPLive->Socket->Connections[i];
    if(Client!=NULL) {
      try {
        if(Client->Connected) {
          Client->SendBuf(Data, BytesReaded);
        }
      }
      catch(Exception &e) {
        LogLine("Error sending to "+Client->RemoteHost+": "+e.Message);
      }
    }
  }
}


CLIENT SIDE:
TLiveBuffer is a simple class with two members: BufferSize with the buffer 
length and Buffer that will point to a membuffer.
TLiveWaveOut is a class that read TLiveBuffer list, send to the soundcard 
and free the buffers.

void __fastcall TForm1::TCPRead(TObject *Sender, TCustomWinSocket *Socket)
{
  int BuffersCount=0;
  int len=Socket->ReceiveLength();

  if(len>=LiveWaveOut->BufferSize)
    len=LiveWaveOut->BufferSize;

  char *buffer=new char[len];
  char *subbuffer=buffer;

  try {
    Socket->ReceiveBuf(buffer, len);

    TList *Buffers=BuffersList->LockList();
    try {
      while(len>0) {
        TLiveBuffer *Chunk=new TLiveBuffer;
        if(len>=LiveWaveOut->BufferSize) {
          Chunk->BufferSize=LiveWaveOut->BufferSize;
          Chunk->Buffer=new char [LiveWaveOut->BufferSize];
          memcpy(Chunk->Buffer, subbuffer, LiveWaveOut->BufferSize);
        }
        else {
          Chunk->BufferSize=len;
          Chunk->Buffer=new char [Chunk->BufferSize];
          memcpy(Chunk->Buffer, subbuffer, Chunk->BufferSize);
        }
        BuffersCount=Buffers->Add(Chunk);
        len-=Chunk->BufferSize;
        subbuffer+=Chunk->BufferSize;
      }
    }
    __finally {
      BuffersList->UnlockList();
    }

  }
  __finally {
    delete buffer;
  }
}