Function TcpReceiveMessage

source/tcpcon.cpp:178–287

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

}
//---------------------------------------------------------------------------
void TcpReceiveMessage(void)
{
  int rl;
  TSyslogdTcpConn * c;
  MSocket * p;
  for(int i=0; i<tcp_cons->Count; i++)
  {
    c = (TSyslogdTcpConn *)tcp_cons->Items[i];
    p = c->Socket;

    if( p->Poll(true, false, false, 0) ) // wait 0 msec
    {
      rl = p->ReadLength();

      if( rl > 0 )
      {
        // Ready to receive rl bytes
        if( p->Read(c->GetBufferSize(rl), rl) )
        {
          c->DataSize += rl;
        }
        else
        {
          if( p->bytes > 0 && p->bytes < rl )
          {
            c->DataSize += p->bytes;
            WriteToLogError("WARNING\tTCP received %ld, wait %ld, error=%ld", p->bytes, rl, p->errcode);
          }
          else
          {
            if( p->errcode==WSAESHUTDOWN )
            {
              WriteToLogError("WARNING\tTCP shutdown from %s", p->GetRemoteAddrPort().c_str());
              TcpDeleteConnection(i--);
              continue;
            }
            else
            {
              WriteToLogError("ERROR\tTCP read(rl=%ld) from %s\tbytes=%ld error=%ld",
                p->GetRemoteAddrPort().c_str(), rl, p->bytes, p->errcode);
            }
          }
        }
      }
      else // Readed 0 bytes !
      {
        BYTE b;
        if( ! p->Read(&b, 1) )
        {
          if( p->errcode==0 && p->bytes==0 )
          {
            // Good disconnect
            TcpDeleteConnection(i--);
            continue;
          }
          else
          {
            WriteToLogError("ERROR\tTCP error from %s: %s [%d]",