И снова работа с COM портом

int SwapData()
{
 // COMHandle - хендл открытого COM порта
 // Data - вектор байт для запроса и ответа
 // eCOM... - константы ошибок обмена
 DWORD dw;
 
 /* Очистка буферов и очередей COM порта */
 if(!PurgeComm(COMHandle, 0x0F)) return eCOMPurge;                              // Не удается очистить буферы COM порта: возвращаю ошибку
 
 /* Отправка данных в COM порт */
 if(!WriteFile(COMHandle, &Data.front(), Data.size(), &dw, NULL) ||             // Не удается отправить данные в COM порт или
     dw != Data.size()) return eCOMWrite;                                       // отправлены не все данные: возвращаю ошибку
 
 /* Чтение данных из COM порта */
}

 // COMHandle - хендл открытого COM порта
 // COMSpeed - скорость COM порта в бит/с
 COMSTATE cs;
 DWORD dw;
 
 /* Цикл ожидания ответа от прибора */
 for(DWORD in = 0, vl = 0, st = GetTickCount();;)
  {
   /* Останавливаю программу на время приема одного байта */
   Sleep(10000 / COMSpeed);
 
   /*  В буфер COM порта поступили новые данные */
   if(ClearCommError(COMHandle, &dw, &cs) && !dw && cs.cbInQue > in)
    {
     in = cs.cbInQue; /* Сохраняю количество данных в буфере COM порта */
     vl = 0; /* Обнуляю количество "пустых циклов" (когда данные не поступили) */
     continue;
    }
 
   /* Прерываю цикл ожидания ответа от прибора если:
      - в буфере COM порта нет данных и время ожидания превысило 3 секунды;
      - в буфере COM порта есть данные и было более одного "пустого цикла" */
   if((!in && ((GetTickCount() - st) > 3000)) || (in && ++vl > 1)) break;
  }
 
 /* Выполняю чтение данных из буфера COM порта */
 if(!cs.cbInQue) return eNotData;
 Data.resize(cs.cbInQue);
 if(!ReadFile(COMHandle, &Data.front(), Data.size(), &dw, NULL) ||
     dw != Data.size())) return eCOMRead;

void DCommThread::ThreadProc(){
 SetEvent(RunEvent);
 SetCommMask(Handle, EV_RXCHAR);
 DWORD dwEvtMask;
 DWORD dwOvRes;
 DWORD dwErrorFlags;
 COMSTAT ComStat;
 while(FConnected){
  dwEvtMask = 0;
  if(!WaitCommEvent(Handle, &dwEvtMask, /*&Overlapped*/NULL)){
   if(GetLastError() == ERROR_IO_PENDING){
    GetOverlappedResult(Handle, &Overlapped, &dwOvRes, true);
   } else {
//    DoError();
    continue;
   }
  }
  if(FConnected==false) break;
  if((dwEvtMask & EV_RXCHAR) != EV_RXCHAR)
   continue;
  ClearCommError(Handle, &dwErrorFlags, &ComStat);
  int n = ComStat.cbInQue;
  if(n > BufferSize) n = BufferSize;
  if(n == 0) continue;
 
//  Lock(); блокирование потока
  if(DataSize+n>BufferSize){
   DWORD d=BufferSize-n;
   if(d) memcpy(Buffer, Buffer+DataSize-d, d);
   DataSize=d;
  }
  if(!ReadFile(Handle, Buffer+DataSize, n, (DWORD *) &n, &Overlapped)){
   if(GetLastError()==ERROR_IO_PENDING){
    WaitForSingleObject(Overlapped.hEvent, INFINITE);
    GetOverlappedResult(Handle, &Overlapped, (DWORD *) &n, true);
   } else {
//    DoError();
   }
  }
  DataSize+=n;
  if(n) 
   Notify((DWORD) Owner); // формирование события наличия данных
//  Unlock(); разблокировка потока
 }
}

bool __dclcall DCommThread::Open(){
 char name[16]="\\\\.\\COM";
 
 itoa(Owner->Port, name+7, 10);
// name[3]=0x30+Owner->Port;
 Handle=CreateFile(name, GENERIC_READ | GENERIC_WRITE, 0,
                    NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL|FILE_FLAG_OVERLAPPED, 0);
 if(Handle==INVALID_HANDLE_VALUE)
  Handle=NULL;
 else {
  DCB CommState;
  GetCommState(Handle, &CommState);
  CommState.BaudRate        = BaudRate;
  CommState.fBinary         = TRUE;
  CommState.fParity         = TRUE;
  CommState.fOutxCtsFlow    = FALSE;
  CommState.fOutxDsrFlow    = FALSE;
  CommState.fDsrSensitivity = FALSE;
  CommState.fNull           = FALSE;
  CommState.ByteSize        = DataBits;
  CommState.Parity          = Parity;
  CommState.StopBits        = StopBits;
  CommState.fRtsControl     = RTS_CONTROL_ENABLE;
  CommState.fDtrControl     = DTR_CONTROL_DISABLE;
  CommState.fAbortOnError   = FALSE;
  SetCommState(Handle, &CommState);
  SetupComm(Handle, 1024, 1024);
  memset(&Overlapped,0,sizeof(Overlapped));
  PurgeComm(Handle, PURGE_RXCLEAR | PURGE_TXCLEAR);
  FConnected=true;
  RunEvent = CreateEvent(0, false, false, NULL);
  Thread=CreateThread(NULL, NULL, &StaticThreadProc, this, 0, &ThreadID);
  WaitForSingleObject(RunEvent, INFINITE);
  CloseHandle(RunEvent);
 }
 return Handle>0;
}
//---------------------------------------------------------------------------
bool __dclcall DCommThread::Close(){
 if(Handle){
  FConnected = false;
  SetCommMask(Handle, EV_BREAK);
  WaitForSingleObject(Thread, INFINITE);
  CloseHandle(Thread);
  CloseHandle(Handle);
  Handle=NULL;
  return true;
 }
 return false;
}
//---------------------------------------------------------------------------