forum.clarionlife.net

Код: Выделить всё

BOOL ReadFile(
  HANDLE hFile,                // handle to file
  LPVOID lpBuffer,             // data buffer
  DWORD nNumberOfBytesToRead,  // number of bytes to read
  LPDWORD lpNumberOfBytesRead, // number of bytes read
  LPOVERLAPPED lpOverlapped    // overlapped buffer
);

Код: Выделить всё

/*!WinAPI-обертка для #WatcherThread_inner, чтобы WatcherThread_inner был членом класса*/
static u_long WINAPI WatcherThreadProc(void* lpData)
{
    TComm *comm = reinterpret_cast<TComm*>(lpData);
    comm->WatcherThread_inner();
    return 0;
}

/* функция потока. код выглядит уродливо, т.к. писался давно, когда я не умел
программировать еще больше, чем не умею сейчас. но работает.
*/
void TComm::WatcherThread_inner()
{
    #define maxBuffer 100
    u_long dwEvMask,dwBytesRead;
    char sBuf[maxBuffer+1];
    OVERLAPPED OvlWatcher;
    HANDLE Handles[2]; // будем ловить 2 события
    
    if (!SetCommMask( hComm, EV_RXCHAR)) return;
    if (!(OvlWatcher.hEvent = CreateEvent(NULL,1,0,NULL))) return;
    
    Handles[0] = hExitClose;  // событие принудительного закрытия порта
    Handles[1] = OvlWatcher.hEvent; // а также событие появления данных в порту

    while (!IsClose())
    {
        // ловим событие на порту
        if (! WaitCommEvent( hComm, &dwEvMask, &OvlWatcher ))
        {
            switch( WaitForMultipleObjects(2,(HANDLE*)&Handles, FALSE, INFINITE) )
            {
             // выход, прерываем цикл (break тут - выход из switch, а не while)
            case WAIT_OBJECT_0: continue;
            case WAIT_OBJECT_0+1: // поймали событие в порту
                // анализируем состояние, заполняя структуру OVERLAPPED
                if (!GetOverlappedResult( hComm, &OvlWatcher, &dwBytesRead, FALSE))
                    continue;
                ResetEvent(OvlWatcher.hEvent); // сбрасываем event в этой структуре
                break;
            }
        }
        if (IsClose()) break;  // флаг закрытия
        
        // на самом деле, ловится много событий.
        // если событие == пришли данные
        if (dwEvMask==EV_RXCHAR)
        do
        {
            dwBytesRead = ReadBlockDirect( sBuf, maxBuffer); // вызывает ReadFile
            if (dwBytesRead<0) break;
            Queue->Write(sBuf, dwBytesRead ); // засемафорено пишем в очередь

            if (port_callback) // если зарегистрирован колбек,
                port_callback(sBuf, dwBytesRead); // то вызываем его

            sBuf[dwBytesRead]=0;
            // пишем в лог. log - экземпляр класса с перегруженным манипулятором endl.
            log << sBuf << endl(DET_DEBUG);
        }
        while(dwBytesRead==maxBuffer);
        SetEvent(hEvent);
    }//while
    
    CloseHandle( OvlWatcher.hEvent );
}

Код: Выделить всё

        PortNumber=GETINI('Communications','PortNumber',4,'.\Wcomm.ini') !Читаем номер порта из ИНИ-файла
        Loc:InBuffer=GETINI('Communications','InBuffer',1024,'.\Wcomm.ini') !Входной буфер
        Loc:OutBuffer=GETINI('Communications','OutBuffer',4096,'.\Wcomm.ini') !Выходной буфер
        DCB:BaudRate=GETINI('Communications','BaudRate',57600,'.\Wcomm.ini')  !Скорость
        DCB:Parity=GETINI('Communications','Parity',0,'.\Wcomm.ini') !Четность в виде числа
        CASE DCB:Parity                                              !Преобразование четности из числа в букву
         OF 1
           Loc:ParityS='Y'
         ELSE
           Loc:ParityS='N'
        END
        DCB:ByteSize=GETINI('Communications','ByteSize',8,'.\Wcomm.ini') !Размер байта
        DCB:StopBits=GETINI('Communications','StopBits',1,'.\Wcomm.ini') !Стоповые биты
        
        
        CTO:ReadIntervalTimeout=GETINI('Communications','TimeOut',5000,'.\Wcomm.ini')        !Тайм-ауты - все по 5 секунд
        CTO:ReadTotalTimeoutMultiplier=GETINI('Communications','TimeOut',5000,'.\Wcomm.ini')
        CTO:ReadTotalTimeoutConstant=GETINI('Communications','TimeOut',5000,'.\Wcomm.ini')
        CTO:WriteTotalTimeoutMultiplier=GETINI('Communications','TimeOut',5000,'.\Wcomm.ini')
        CTO:WriteTotalTimeoutConstant=GETINI('Communications','TimeOut',5000,'.\Wcomm.ini')
        
        Loc:PortString = 'COM' & CLIP(PortNumber) !Текстовое имя порта
        IF Loc:PortHandle < 1
         Loc:PortHandle = CreateFile(Address(Loc:PortString), GENERIC_READ + GENERIC_WRITE, 0, 0, OPEN_EXISTING, 0, NULL)
        END
        IF Loc:PortHandle=-1
         MESSAGE('Невозможно создать порт' & '<10,13>' & Loc:PortHandle)
         RETURN
        ELSE
         !MESSAGE(Loc:PortHandle)
        END
        
        IF Loc:PortHandle <> -1
                                       !Формируем строку порта вида "9600,N,8,1"
         Loc:ControlString=DCB:BaudRate & ',' & Loc:ParityS & ',' & DCB:ByteSize & ',' & DCB:StopBits
         MESSAGE('Loc:ControlString: ' & Loc:ControlString, 'ControlString')
         IF BuildCommDCB(Address(Loc:ControlString), Address(DCB)) <> 0
           Loc:ReturnCode=SetCommState(Loc:PortHandle, Address(DCB))
           IF ~Loc:ReturnCode
            MESSAGE(Loc:ReturnCode)
           END
           Loc:ReturnCode=SetCommTimeOuts(Loc:PortHandle,Address(COMMTIMEOUTS)) !Тайм-ауты. А надо ли их настраивать?
           IF ~Loc:ReturnCode
            MESSAGE(Loc:ReturnCode)
           END
           Loc:ReturnCode=SetupComm(Loc:PortHandle,Loc:InBuffer,Loc:OutBuffer) 
           IF ~Loc:ReturnCode
            MESSAGE(Loc:ReturnCode)
           END
         ELSE
          MESSAGE('ERROR')
         END
        END
        
        Loc:ReturnCode=GetCommState(Loc:PortHandle,Address(DCB))
        IF ~Loc:ReturnCode
         MESSAGE('GetCommState: ' & Loc:ReturnCode,'GetCommState')
        ELSE
         MESSAGE( !
             'BaudRate: ' & DCB:BaudRate & '<13,10>' & !
             'Parity: '   & DCB:Parity   & '<13,10>' & !
             'ByteSize: ' & DCB:ByteSize & '<13,10>' & !
             'StopBits: ' & DCB:StopBits               !
                            ,'GetCommState'            )
        END
        
        
        Loc:OutString='AT +MPBR=?'
        Loc:Len=LEN(Clip(Loc:OutString))
        Loc:ReturnCode = WriteFile(Loc:PortHandle, Address(Loc:OutString), Loc:Len, Address(Loc:BytesWritten), NULL)
        IF Loc:Len <> Loc:BytesWritten
         MESSAGE('Не записали все байты, которые хотели...')
        ELSE
         !MESSAGE('Записано байт: ' & Loc:BytesWritten & ', код возврата: ' & Loc:ReturnCode, 'WriteFile')
        END
        
        Loc:ReturnCode=SetCommMask(Loc:PortHandle, !
                EV_RXCHAR           + !
                EV_RXFLAG           + !
                EV_TXEMPTY          + !
                EV_CTS              + !
                EV_DSR              + !
                EV_RLSD             + !
                EV_BREAK            + !
                EV_ERR              + !
                EV_RING             + !
                EV_PERR             + !
                EV_RX80FULL         + !
                EV_EVENT1           + !
                EV_EVENT2           ) !Устанавливаем маску на все события
        IF ~Loc:ReturnCode
         MESSAGE('SetCommMask: ' & Loc:ReturnCode,'SetCommMask')
        END
                                     
        
        Loc:ReturnCode = WaitCommEvent(Loc:PortHandle, Address(COMMMASK), NULL) !возвращает не ноль, если все нормально
        IF ~Loc:ReturnCode
         MESSAGE('WaitCommEvent: ' & Loc:ReturnCode,'WaitCommEvent')
        END
        
        
        Loc:ReturnCode = ClearCommError(Loc:PortHandle, Address(Loc:PortErrorCode), Address(ComStat))
        IF ~Loc:ReturnCode
         MESSAGE('ClearCommError: ' & Loc:ReturnCode,'ClearCommError')
        END
        MESSAGE('InQue: ' & CS:InQue & '<13,10>OutQue: ' & CS:OutQue)
        
        Loc:BytesToRead=CS:InQue
        Loc:ReturnCode = ReadFile(Loc:PortHandle, Address(Loc:TempInString), Loc:BytesToRead, Address(Loc:BytesRead), NULL)
        IF ~Loc:ReturnCode
         MESSAGE('Loc:ReturnCode: ' & Loc:ReturnCode,'ReadFile')
        ELSE
         IF ~Loc:BytesRead
          MESSAGE('Loc:BytesRead: ' & Loc:BytesRead,'ReadFile')
         ELSE
          Loc:InString = Loc:InString & Loc:TempInString & '<13,10,13,10>' !Дописывание двойного перевода строки
         END
         DISPLAY()