9-ти битная передача через COM port

bool SerialPort::CreateCOM(string name)
{
    LPCWSTR NameCom = StdStrToLpt(name);
    hCom = CreateFile(NameCom, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);
 
    SetReadTimeout(1);
    SetWriteTimeout(1);
    SetSpeed(9600);
    SetParity(4);
    SetOtherSettings();
 
    SetupComm(hCom, 2000, 2000);
 
    PurgeComm(hCom, PURGE_RXCLEAR);
 
    if (hCom == INVALID_HANDLE_VALUE)
    {
        return false;
    }
    return true;
}
 
bool SerialPort::DestroyCOM()
{
    CloseHandle(hCom);
    return true;
}
 
bool SerialPort::CheckPortOpen()
{
    if (hCom == INVALID_HANDLE_VALUE)
    {
        return false;
    }
    return true;
}
 
void SerialPort::InitReadOverllaped()
{
    overlapped.hEvent = CreateEvent(NULL, true, true, NULL);    //создать сигнальный объект-событие для асинхронных операций
    SetCommMask(hCom, EV_RXCHAR);                               //установить маску на срабатывание по событию приёма байта в порт
}
 
void SerialPort::InitWriteOverllaped()
{
    overlappedwr.hEvent = CreateEvent(NULL, true, true, NULL);        //создать событие
}
 
void SerialPort::SetReadTimeout(int time)
{
    COMMTIMEOUTS touts;
    GetCommTimeouts(hCom, &touts);
    touts.ReadIntervalTimeout =  time * 1000;
    touts.ReadTotalTimeoutMultiplier = time * 1000;
    touts.ReadTotalTimeoutConstant = time * 1000;
    SetCommTimeouts(hCom, &touts);
}
 
void SerialPort::SetWriteTimeout(int time)
{
    COMMTIMEOUTS touts;
    GetCommTimeouts(hCom, &touts);
    touts.WriteTotalTimeoutMultiplier = time * 1000;
    touts.WriteTotalTimeoutConstant = time * 1000;
    SetCommTimeouts(hCom, &touts);
}
 
void SerialPort::SetSpeed(int speed)
{
    DCB dcb;
 
    bool wasChange = GetCommState(hCom, &dcb);
 
 
    if(speed == 9600)
    {
        dcb.BaudRate = CBR_9600;
    }
    else if (speed == 19200)
    {
        dcb.BaudRate = CBR_19200;
    }
    else if (speed == 38400)
    {
        dcb.BaudRate = CBR_38400;
    }
    else if (speed == 57600)
    {
        dcb.BaudRate = CBR_57600;
    }
    else if (speed == 115200)
    {
        dcb.BaudRate = CBR_115200;
    }
    else
    {
        dcb.BaudRate = CBR_9600;
    }
 
    if(wasChange)
    {
        wasChange = SetCommState(hCom, &dcb);
    }
 
}
 
void SerialPort::SetParity(int parity)
{
    DCB dcb;
 
    bool wasChange = GetCommState(hCom, &dcb);
 
    dcb.Parity = parity;
 
    if(wasChange)
    {
        wasChange = SetCommState(hCom, &dcb);
    }
 
}
 
void SerialPort::SetOtherSettings()
{
    DCB dcb;
 
    bool wasChange = GetCommState(hCom, &dcb);
 
    dcb.fBinary = FALSE;                                   //включаем двоичный режим обмена
    dcb.fParity = TRUE;                                   // разрешение контроля четности
    dcb.fOutxCtsFlow = FALSE;                              //выключаем режим слежения за сигналом CTS
    dcb.fOutxDsrFlow = FALSE;                              //выключаем режим слежения за сигналом DSR
    dcb.fDtrControl = DTR_CONTROL_DISABLE;                 //отключаем использование линии DTR
    dcb.fDsrSensitivity = FALSE;                           //отключаем восприимчивость драйвера к состоянию линии DSR
    dcb.fErrorChar = FALSE;
    dcb.fNull = FALSE;                                     //разрешить приём нулевых байтов
    dcb.fRtsControl = RTS_CONTROL_DISABLE;                 //отключаем использование линии RTS
    dcb.fAbortOnError = FALSE;                             //отключаем остановку всех операций чтения/записи при ошибке
    dcb.ByteSize = 8;                                      //задаём 9 бит в байте
    //dcb.Parity = 0;                                        //отключаем проверку чётности
    dcb.StopBits = 0;                                      //задаём один стоп-бит
 
 
    if(wasChange)
    {
        wasChange = SetCommState(hCom, &dcb);
    }
}
 
bool SerialPort::WriteToCOM(string mess)
{
    DWORD temp, signal; //temp - переменная-заглушка
 
    char* buf = new char[mess.length()];
    memcpy(buf, mess.c_str(), mess.length());
    bool writed = WriteFile(hCom, buf, mess.length(), &temp, &overlappedwr);
 
    signal = WaitForSingleObject(overlappedwr.hEvent, INFINITE);      //приостановить поток, пока не завершится перекрываемая операция WriteFile
    return !writed;
}
 
bool SerialPort::ReadFromCOM(string & mess, int bits, int timeout)
{
    COMSTAT comstat;        //структура текущего состояния порта, в данной программе используется для определения количества принятых в порт байтов
    DWORD btr = 1, temp, mask, signal;  //переменная temp используется в качестве заглушки
 
    timeout *= 1000;
    Sleep(timeout);
 
    WaitCommEvent(hCom, &mask, &overlapped);                //ожидать события приёма байта (это и есть перекрываемая операция)
    signal = WaitForSingleObject(overlapped.hEvent, 1); //приостановить поток до прихода байта
    if(signal == WAIT_OBJECT_0)                     //если событие прихода байта произошло
    {
        if(GetOverlappedResult(hCom, &overlapped, &temp, true)) //проверяем, успешно ли завершилась перекрываемая операция WaitCommEvent
        {
            if((mask & EV_RXCHAR)!=0)                   //если произошло именно событие прихода байта
            {
                ClearCommError(hCom, &temp, &comstat);      //нужно заполнить структуру COMSTAT
                btr = comstat.cbInQue;                              //и получить из неё количество принятых байтов
 
                if(btr)                                     //если действительно есть байты для чтения
                {
                    int leng = (int)btr;
                    char* buf = new char[leng];
                    string bufer = "";
                    for(int i = 0; i < leng; i++)
                    {
                        ReadFile(hCom, buf, 1, &temp, &overlapped);     //прочитать байты из порта в буфер программы
                        bufer += buf[0];
                    }
                    counter += leng;                                          //увеличиваем счётчик байтов
                    mess = string(bufer);
                    //mess = mess.substr(0, mess.length()-3);
 
                    if(bits < mess.length());
                    {
                        mess = mess.substr(0, bits-1);
                    }
 
 
                    return true;                            //вызываем функцию для вывода данных на экран и в файл
                }
             }
         }
     }
 
     return false;
}
 
void SerialPort::CloseReadOverllaped()
{
    CloseHandle(overlapped.hEvent);
}
 
void SerialPort::CloseWriteOverllaped()
{
    CloseHandle(overlappedwr.hEvent);
}
 
void SerialPort::PurgeCOM()
{
    PurgeComm(hCom, PURGE_RXCLEAR);
    PurgeComm(hCom, PURGE_TXCLEAR);             //очистить передающий буфер порта
}