Проблемка winapi - C++ - Ответ 2482914

DWORD WINAPI ReadThread(LPVOID)
{
 COMSTAT comstat;       //структура текущего состояния порта, в данной программе используется для определения количества принятых в порт байтов
 DWORD btr, temp, mask, signal; //переменная temp используется в качестве заглушки
 
 overlapped.hEvent = CreateEvent(NULL, true, true, NULL);   //создать сигнальный объект-событие для асинхронных операций
 SetCommMask(COMport, EV_RXCHAR);                               //установить маску на срабатывание по событию приёма байта в порт
 while(1)                       //пока поток не будет прерван, выполняем цикл
  {
   WaitCommEvent(COMport, &mask, &overlapped);                  //ожидать события приёма байта (это и есть перекрываемая операция)
   signal = WaitForSingleObject(overlapped.hEvent, INFINITE);   //приостановить поток до прихода байта
   if(signal == WAIT_OBJECT_0)                      //если событие прихода байта произошло
    {
     if(GetOverlappedResult(COMport, &overlapped, &temp, true)) //проверяем, успешно ли завершилась перекрываемая операция WaitCommEvent
      if((mask & EV_RXCHAR)!=0)                 //если произошло именно событие прихода байта
       {
        ClearCommError(COMport, &temp, &comstat);       //нужно заполнить структуру COMSTAT
        btr = comstat.cbInQue;                              //и получить из неё количество принятых байтов
        if(btr)                                     //если действительно есть байты для чтения
        {
         ReadFile(COMport, bufrd, btr, &temp, &overlapped);     //прочитать байты из порта в буфер программы
         rx_counter+=btr;                                          //увеличиваем счётчик байтов
                                    //вызываем функцию для вывода данных на экран и в файл
        }
       }
    }
  }
}

class Com
{
protected:
static unsigned char rx_buf[BUFSIZE], tx_buf[BUFSIZE];
static unsigned char tx_count, rx_index, rx_count;
public:
void open(void);
void pclose(void);
void write(unsigned char data);
void send(void);
unsigned char read(void);
void clear_data(void);
};

unsigned char Com::read(void)
{
unsigned char data;
if(!rx_count)
{
COMSTAT comstat;
DWORD btr, temp, mask, signal;
overlapped.hEvent = CreateEvent(NULL, true, true, NULL);
SetCommMask(COMport, EV_RXCHAR);
 
 do{
    WaitCommEvent(COMport, &mask, &overlapped);
    signal = WaitForSingleObject(overlapped.hEvent, INFINITE);
    if(signal == WAIT_OBJECT_0)
     {
      if(GetOverlappedResult(COMport, &overlapped, &temp, true))
       if((mask & EV_RXCHAR)!=0)
        {
         ClearCommError(COMport, &temp, &comstat);
         btr = comstat.cbInQue;
         if(btr)
         {
          ReadFile(COMport, rx_buf, btr, &temp, &overlapped);
          rx_count+=btr;
 
         }
        }
     }
 
 }while(!rx_count);
CloseHandle(overlapped.hEvent);
}
data=rx_buf[rx_index++];
if(!--rx_count)rx_index=0;
return data;
}

DWORD WINAPI MyroboThread(LPVOID)
{
Robo r;
Com c;
 
 
if(nead_read)
  {
   switch (c.read())
   {
   case 0:
   r.synchronization();
   break;
   case 1:
   param1=c.read();
   param2=c.read();
   r.radar_read(param1,param2);
   break;
   case 2:
   r.read_sensor(c.read());
   break;
   case 3:
   break;
   case 4:
   break;
   case 5:
   break;
   case 6:
   ls.show_deg();
   break;  // */
   default:
   r.synchronization();
   break;
   }
  nead_read--;
  }
}
}