🚀 go-pugleaf

Using c++builder 6 I build a very simple client, which call a thread to 
connect to a server.
The first connection works well, while when I try to close the thread 
with Terminate and waitFor
I got a system error code 6.
Here a snippet of the log with the example and after tha sample code I 
used.
For the connection I use the standard TClientSocket component, used in 
blocking mode
There is something wrong when I close the thread but I can't gues what.
Please, can someone give me some hint on where I wrong .
Regards, Enzo


[22/02/2007 10.47.12] [ThrID=00E8] [Execute] Nuova connessione: 
192.168.200.218:2023 --> 192.168.200.47:19001
[22/02/2007 10.47.19] [ThrID=00E8] [Execute] END  [ connessione: 
192.168.200.218:2023 --> 192.168.200.47:19001 ]
[22/02/2007 10.47.19] [ThrID=00E8] [ThClientSocket::~ThClientSocket] 
END
[22/02/2007 10.47.23] [BtnConnect-KillConn]ERRORE System Error.  Code: 
6.

Handle non valido


***************************


ThClientSocket * thClntSckt;


void __fastcall TForm1::BtnConnectClick(TObject *Sender)
{
   try
   {
      // -------------------------------------------------------
      try
      {
          if( thClntSckt )
          {
             thClntSckt->Terminate();
             thClntSckt->WaitFor();
             thClntSckt = 0;
             return;
          }
      }
      catch( const Exception & ex )
      {
         String serr = Format( "[BtnConnect-KillConn]ERRORE %s ", 
ARRAYOFCONST(( ex.Message )) );
         Util::mylog( serr );
         return;
      }
      // -------------------------------------------------------
      try
      {
          thClntSckt = new ThClientSocket( true );
          thClntSckt->FreeOnTerminate = true;
          thClntSckt->IPAddress = EditHost->Text;
          thClntSckt->Port      = StrToIntDef( EditPort->Text, 0 );
          thClntSckt->Resume();
      }
      catch( const Exception & ex )
      {
         String serr = Format( "[BtnConnect-NewConn]ERRORE %s ", 
ARRAYOFCONST(( ex.Message )) );
         Util::mylog( serr );
      }
      // -------------------------------------------------------
   }
   catch( const Exception & ex )
   {
      String serr = Format( "[BtnConnect]ERRORE %s ", ARRAYOFCONST(( 
ex.Message )) );
      Util::mylog( serr );
   }
}



/******************************************************
  TClientSocket * mySocket
 ******************************************************/
__fastcall ThClientSocket::ThClientSocket(bool CreateSuspended)
        : TThread(CreateSuspended)
{
    mySocket = new TClientSocket( NULL );
}



/******************************************************
 ******************************************************/
__fastcall ThClientSocket::~ThClientSocket()
{
   String stmp;
   try
   {
       if( mySocket )
       {
          if( mySocket->Active )
          {
              stmp = Format( "[Execute] Chiudi connessione: %s:%d --> 
%s:%d ",
                       ARRAYOFCONST(( mySocket->Socket->LocalAddress,
                                      mySocket->Socket->LocalPort,
                                      mySocket->Socket->RemoteAddress,
                                      mySocket->Socket->RemotePort )));
              mylog( stmp );
          }
          mySocket->Close();
          while( mySocket->Active )
          {
             mylog( "[ThClientSocket::~ThClientSocket] END close 
Socket" );
             Sleep( 500 );
          }
          while( mySocket->Socket->Connected )
          {
             mylog( "[ThClientSocket::~ThClientSocket] END close 
winSocket" );
             Sleep( 500 );
          }
          delete mySocket;
          mySocket = 0;
       }
   }
   catch( const Exception & ex )
   {
      String serr = Format( "[ThClientSocket::~ThClientSocket]ERRORE %s 
", ARRAYOFCONST(( ex.Message )) );
      Util::mylog( serr );
   }
   mylog( "[ThClientSocket::~ThClientSocket] END " );
}



void __fastcall ThClientSocket::Execute()
{

   int fSocketTimeout = 30;
   TWinSocketStream * pStream = 0;
   char buffer[BUFFERSIZE];
   int nloop = 0;
   String sMsg, sMsgInp, stmp;
   int dt1, dt2;

   try
   {
       // -------------------------------------------------------
       if( ! mySocket->Active )
       {
          mySocket->Address = fIPAddress;
          mySocket->Port    = fPort;
          mySocket->ClientType = ctBlocking;
          mySocket->Open();

          stmp = Format( "[Execute] Nuova connessione: %s:%d --> %s:%d 
",
                   ARRAYOFCONST(( mySocket->Socket->LocalAddress,
                                  mySocket->Socket->LocalPort,
                                  mySocket->Socket->RemoteAddress,
                                  mySocket->Socket->RemotePort )));
          mylog( stmp );
       }
       // -------------------------------------------------------
       while( !Terminated && mySocket->Active )
       {
          if( pStream == 0 )
          {
             pStream = new TWinSocketStream(mySocket->Socket, 
fSocketTimeout );
          }

          *********          Here the working code     ********
          *********  but is commented for this example ********


       }
       // -------------------------------------------------------
       stmp = Format( "[Execute] END  [ connessione: %s:%d --> %s:%d 
]",
                 ARRAYOFCONST(( mySocket->Socket->LocalAddress,
                                mySocket->Socket->LocalPort,
                                mySocket->Socket->RemoteAddress,
                                mySocket->Socket->RemotePort )));
       mylog( stmp );
       // -------------------------------------------------------
       if( pStream )
       {
           pStream->WaitForData(fSocketTimeout);
           delete pStream;
           pStream = 0;
       }
       mySocket->Close();
       // -------------------------------------------------------
   }
   catch( const Exception & ex )
   {
      String serr = Format( "[ThClientSocket::Execute]ERRORE %s ", 
ARRAYOFCONST(( ex.Message )) );
      mylog( serr );
      mySocket->Close();
   }

}