Асинхронное чтение с СОМ-порта

[Tuborg]

создаю хэндл порта:

Код:

CreateFile(sPort, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);

читаю порт (пока один раз на запуске)

Код:

void CSerialPort::ReadEx(void* lpBuf, DWORD dwCount)
{
  ASSERT(IsOpen());

  OVERLAPPED* pOverlapped = new OVERLAPPED;
  ZeroMemory(pOverlapped, sizeof(OVERLAPPED));
  pOverlapped->hEvent = (HANDLE) this;
  if (!ReadFileEx(m_hComm, lpBuf, dwCount, pOverlapped, _OnCompletion))
  {
    delete pOverlapped;
    TRACE(_T("Failed in call to ReadFileEx\n"));
    AfxThrowSerialException();
  }
}

Хочу чтобы как только приходил какой-нибудь байтик в порт, тут же запускалась CALL-BACK  функция _OnCompletion:

Код:

void CSerialPort::_OnCompletion(DWORD dwErrorCode, DWORD dwCount, LPOVERLAPPED lpOverlapped)
{
  //Validate our parameters
  ASSERT(lpOverlapped);

  //Convert back to the C++ world
  CSerialPort* pSerialPort = (CSerialPort*) lpOverlapped->hEvent;
  ASSERT(pSerialPort->IsKindOf(RUNTIME_CLASS(CSerialPort)));

  //Call the C++ function
  pSerialPort->OnCompletion(dwErrorCode, dwCount, lpOverlapped);
}

ставлю внутрь _OnCompletion breakpoint но управление к этой функции так и не передается, что я не пытаюсь запихнуть в порт.
В Синхронном режиме всё работает нормально.

Где я не прав?

[v2]

//?? Тут вроде должен быть Event

Код:

 pOverlapped->hEvent = (HANDLE) this;

Из MSDN

Код:

VOID [b]CALLBACK[/b] FileIOCompletionRoutine(
  DWORD dwErrorCode,
  DWORD dwNumberOfBytesTransfered,
  LPOVERLAPPED lpOverlapped
);

PS.
IOCompletionRoutine не лучший вариант.

[Tuborg]

почему
IOCompletionRoutine не лучший вариант? Что вместо этого можно ещё использовать?

[v2]

Например WaitForMultipleObjects в отдельном потоке, куда и указатель передать можно.

/**/
startTh pVoid

readEv,commEv,sendEv,endEv

WaitCommEvent
ReadFile

while 1
 WaitForMultipleObjects
  sendEv -> OnSendEn;
  readEv -> OnReadEn, ReadFile;
  commEv -> OnCommEv, WaitCommEvent;
  endEv  -> break;

CloseHandles
endTh
/**/



 

[Tuborg]

Понятно... а ещё такой вопрос.... как передать данные во время чтения по ком-порту в ДОСе я понимаю... а в винде в режиме асинхронного чтения такое можно? или я зря парюсь?

[v2]

Да, с этим проблем нет.

[Tuborg]

приватные переменные класса:

Код:

DWORD dwEvtMask;
OVERLAPPED m_overlapped;
 HANDLE m_hComm;

при открытии порта делаю следующее:

Код:

    bool Open(...){

        m_hComm = CreateFile(sPort, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED);

	m_overlapped.hEvent = CreateEvent(
									NULL,   // default security attributes 
									FALSE,  // auto reset event 
									FALSE,  // not signaled 
									NULL    // no name
								  );
    

			 // Intialize the rest of the OVERLAPPED structure to zero.
			m_overlapped.Internal = 0;
			m_overlapped.InternalHigh = 0;
			m_overlapped.Offset = 0;
			m_overlapped.OffsetHigh = 0;
....
}

в параллельном потоке на каждый из ком-портов (4 их у меня) делаю следующее:

Код:

if (WaitCommEvent(m_hComm, &dwEvtMask, &m_overlapped)) 
    {
		printf("I/O ...\n");
        if (dwEvtMask & EV_RXCHAR) 
        {
             // To do.
			 
        }

        if (dwEvtMask & EV_TXEMPTY) 
        {
            // To do. 
        }
    }
    else
    {
        DWORD dwRet = GetLastError();
        if( ERROR_IO_PENDING == dwRet)
        {
            printf("I/O is pending...\n");

            // To do.
        }
        else 
            printf("Wait failed with error %d.\n", GetLastError());
    }

при посылки байтиков в ком-порт строка printf("I/O ...\n"); не работает, ставил туда даже breakpoint. Всё время переходит по else.

Почему не работает? О чём я забыл?

[Scorp__)]

По-моему, SetCommMask неплохо бы еще сделать При инициализации.

[Tuborg]

Я тут подумал головой... и сделал так:
Сначала взвёл событие
WaitCommEvent(m_hComm, &dwEvtMask, &m_overlapped)

где dwEvtMask=EV_RXCHAR;

а потом поставил

WaitForSingleObject(m_hComm, INFINITE);

и оно сработало =)

как-то странно... вот если читать мсдн, то в примере для WaitCommEvent (For an example, see Monitoring Communications Events.)

всё написано так, как я писал в предыдущем посте... никакого WaitForSingleObject там нет... в чём подвох? или это всё капиталистические происки? Хотя если подумать головой то ожидание событие просто необходимо.... кто может пояснить пример из мсдн?

[v2]

А в M$ только ошибки ждут

Код:

    
...
else
    {
        DWORD dwRet = GetLastError();
        if( ERROR_IO_PENDING == dwRet)
        {
            printf("I/O is pending...\n");

            // To do.
        }
...

Если у тебя много портов, смотри в сторону CreateIoCompletionPort и задай timeouts чтобы не дергаться за каждым байтом.

[v2]

ERROR_IO_PENDING эта "ошибка" почти всегда после OVERLAPPED Read/Write/.. 

[Tuborg]

Для истории (вдруг кто ещё будет это искать) есть приличная инфа по этому поводу - http://www.caxapa.ru/lib/comwinnt.html#_ftn1

[lag]

я не применяю здесь объекты ядра, а делаю так:

  COMMTIMEOUTS cto;
  cto.ReadIntervalTimeout         = 1;
  cto.ReadTotalTimeoutConstant    = g_dwCommTimeout;
  cto.ReadTotalTimeoutMultiplier  = 0;
  cto.WriteTotalTimeoutConstant   = 30;
  cto.WriteTotalTimeoutMultiplier = 0;
  SetCommTimeouts(g_hComm, &cto);

g_dwCommTimeout - задает константу, в миллисекундах, используемую для вычисления
общего тайм-аута операции чтения.

ReadIntervalTimeout - максимальное время, в миллисекундах, допустимое между двумя
последовательными символами считываемыми с коммуникационной линии.

Определив таким образом, делаю просто - WriteFile и сразу ReadFile. Конечно в моем
случае я знаю, что данные (ответ) должны быть получены не более чем через g_dwCommTimeout
миллисекунд.

Если же я просто слушаю порт, то в отдельном потоке:

  while (!ReadFile(...))
    Sleep(1);  // чтобы не нагружать процессор

[Алексей++]

lag, while (!ReadFile(...)) - потеряешь первый (как минимум) байт. Тогда уж надо его запомнить - и добавить в начало буфера, куда будешь читать остальное

[lag]

Ну так я и не стал дописывать, что я делаю после приема данных.
У каждого ведь свои задачи после чтения. Реально я собираю данные и
разбираю по пакетам. Затем анализирую каждый пакет и выделяю нужное
в соответствии с протоколом. Я описываю, что не всегда надо задействовать
WaitFor...Object - компорт нам сам дает возможность принять все данные
за g_dwCommTimeout миллисекунд. Надо только грамотно установить таймауты.
По крайней мере меня устраивает, как это работает в моей задаче и с моим
протоколом.

[Алексей++]

а я тоже так делаю, кстати ) Без событий - просто суюсь в порт и смотрю, идёт что нибудь или нет. События пока даже не приходилось использовать

[SergI]

Для истории (вдруг кто ещё будет это искать) есть приличная инфа по этому поводу - http://www.caxapa.ru/lib/comwinnt.html#_ftn1

 А по-моему это порочное руководство.
 Почитай тут :http://lord-n.narod.ru/walla.html
 Вот это:
    П.Агуров.
Последовательные интерфейсы ПК.
Практика программирования.
объём файла - 4'338'122 byte
http://lord-n.narod.ru/download/books/walla/programming/P.Agurov.Posledovatelnie.interfacy.PK.Practica.programmirovania.rar

+ CD к книге
http://lord-n.narod.ru/download/books/walla/programming/CD.for.book.Pavel.Agyrov.Interfaces.zip

 После прочтения станет понятно, почему алгоритм, приведенный на Сахаре, не очень хорош.