Форум на Исходниках.RU

COM-порт и таймауты

emp — Mon, 18 Apr 2005 11:25:56 +0000

emp: спасибо, ViGOur
Эту статью я читал несколько раз и изначально следовал ей... там все классно написано, но к своему обмену я не могу ее применить почему-то...
вот после этого и стал искать помощи на этом форуме

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

а синхронный обмен, с которым у меня нет проблем, мне ТОЧНО не подходит, а жаль... :(

но разобраться мне очень надо. Из всех моих знакомых-программистов в миру, а не в нете, никто не занимается портами так что вживую и спросить не у кого

COM-порт и таймауты

ViGOur — Mon, 18 Apr 2005 10:27:57 +0000

ViGOur: Думаю будет интересно почитать, смотри аттач...

COM-порт и таймауты

emp — Mon, 18 Apr 2005 07:42:46 +0000

emp: почему нету монстров в етом вопросе ? :(

COM-порт и таймауты

emp — Mon, 18 Apr 2005 05:50:56 +0000

emp: мдя... для всех это такая тяжелая тема?

ну спасибки всем за помощь!

Добавлено 18.04.05, 06:01
а может есть кто продвинутый, кто может подсказать как исправить мой код, а не советовать "поищи в инете" или "ты в этом ничего не понимаешь, даже не берись за это"... а я хочу понимать! и мне надо разобраться

жду советов...

COM-порт и таймауты

AlexSm — Fri, 15 Apr 2005 13:38:41 +0000

AlexSm:

Цитата emp @ 15.04.05, 13:14

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

Ооо...Вон оно как...Уж прости, что отнял у тебя драгоценное время. Больше тут писАть не буду. :huh:

COM-порт и таймауты

emp — Fri, 15 Apr 2005 13:14:30 +0000

emp: я бы топик не создавал если бы тчо то нашел
да и кроме того я вижу что ты тоже не совсем понимаешь... не буду комментррировать что именно

топик не закрываю!
жду предложений еще
народ поднапрягите умы !! :)

COM-порт и таймауты

AlexSm — Fri, 15 Apr 2005 12:11:19 +0000

AlexSm: 1) Всёж таймауты надоб так:

tm.ReadTotalTimeoutConstant = 500; // Таймаут в мс на чтение по ReadFile

tm.ReadIntervalTimeout = MAXDWORD; // Между байтами может быть какой угодно интервал

Ты вроде 500 мс хотел...

2) После успешного WriteFile (без ухода в состояние IO_PENDING) у тебя будет диалог с ошибкой :D
3) Перепутал WAIT_OBJECT_0 и WAIT_TIMEOUT. WAIT_OBJECT_0 -> Произошло событие на указанном хэндле
4) &dataFromPort - амперсанд тут зачем?
5) То, что ReadFile с параметром оверлаппеда вернула FALSE - ещё не значит что произошла уж такая критичная ошибка. Нада проверить на ERROR_IO_PENDING

ЗЫ. После основного вызова асинх. операции проверяй что ты действительно попал в состояние IO_PENDING.
И далее можешь делать либо синхронно:

BOOL fOK = GetOverlappedResult(...., TRUE);

или

BOOL fOK = WaitForSingleObject(..., timeout) == WAIT_OBJECT_0;

либо асинхронно:

BOOL fOK;

while( !(fOK = GetOverlappedResult(..., FALSE)) && GetLastError() == ERROR_IO_INCOMPLETE)

{

; // что-то делаешь ещё.

}

или

DWORD dwWaitCode;

while( (dwWaitCode = WaitForSingleObject( ..., 5 /* ждать по 5 мс */)) == WAIT_TIMEOUT)

{

; // что-то делаешь ещё

}

Добавлено 15.04.05, 12:13
ЗЫЗЫ. И воспользуйся поиском по совету SVK. Тем дофига было о работе с ком-портами.Может чего интересного подчерпнёшь...

COM-порт и таймауты

emp — Fri, 15 Apr 2005 11:50:48 +0000

emp: сделаю небольшие пояснения для чего мне это все надо:

1. во-первых, я хочу разобраться с асинхронным вводом-выводом
2. во-вторых, программа будет работать следующим образом:
до завершения работы программы будет крутиться в отдельном потоке вышеприведенный код и по расшифрованным принятым данным (они будут отображаться на далоге) пользователем будут приниматься те или иные действия, в число которых будет приостанавливаться этот постоянный цикл опроса девайса.
3. да и в-третьх, почму асинхронный? да потому, что каждый раз ожидая ответа от девайса я не знаю сколько данных придет (от 12 до 245 байт - в этих пределах)

еще раз прошу, лучше помогите разобраться с асинхронным вводом/выводом раз и навсегда :)
этому желанию и служит же данный форум, правда ?

COM-порт и таймауты

AlexSm — Fri, 15 Apr 2005 11:30:29 +0000

AlexSm: olddiller: Да, c режимом эвента я переборщил :lol:

emp: Я тебя пытался подтолкнуть к мысле, что по предоставленному тобой коду, тут вполне мона обойтись без асинхронной возможности работы через оверлаппед интерфейс (тем более если ты не до конца понимаешь как оно работает). У тебя шаги выполняются последовательно, и никаких дополнительных действий (помимо работы с портом) ты не предпринимаешь (реакция прекращения работы потока/приложения/etc). Ну дык и зачем использовать оверлаппед? Сделай проще, синхронно:
1) Открыть порт без оверлаппед
2) Настроить таймауты с учетом цитаты из мсдн, что я приводил выше
3) Вызвать синхронный WriteFile
4) В случае успеха вызвать ReadFile
5) После ReadFile имеешь либо нормальный ответ, либо ошибку чтения. Причины уже отдельно определяешь...
6) Закрываешь порт

В случае, если считывать нада порциями, либо нада по самим данным определять конец посылки - в шаги 4-5 вставляешь обработку этого. Возможно по ClearCommError/WaitCommEvent/etc.

COM-порт и таймауты

emp — Fri, 15 Apr 2005 11:19:07 +0000

emp: 2AlexSm: В прошлом своем посте я погорячился раньше времени, сорри за это.

товарищи я проанализировал все ваши советы и вот к чему пришел (насколько это правильно с вашей точки зрения и чего не хватает мне?). Хто возьмется проверить код и подсказать исчо чего нить ? %)

void OnDOWNLOAD()

{

int count = 0;

unsigned char dataInPort[6]; // буфер для записи

unsigned char dataFromPort[256];// буфер для чтения

for ( int i=0 ; i<6 ; i++ )

dataInPort[i] = 0;

for ( int j=0 ; j<6 ; j++ )

dataFromPort[j] = 0;

HANDLE hPort = {0}; // дескриптор порта

DCB dcbPort = {0}; // свойства порта

COMMTIMEOUTS tm = {0}; // таймауты

OVERLAPPED over = {0}; // параметры асинхронной передачи

COMSTAT state = {0}; // параметры приема/передачи

CFile magEvents; // файл, куда записываются данные

DWORD dwWrite = 0; // фактическое число записанных байт

DWORD dwRead = 0; // фактическое число прочитанных байт

DWORD dwWait = 0;

DWORD readed = 0;

DWORD eventMask = 0;

DWORD errorMask = 0;

DWORD timeout = 500;

// открытие порта

hPort = CreateFile("COM1",

GENERIC_WRITE | GENERIC_READ,

NULL,

OPEN_EXISTING,

FILE_FLAG_OVERLAPPED,

NULL);

if ( hPort==INVALID_HANDLE_VALUE )

AfxMessageBox("Ошибка инициализации порта");

else

{

// очистка порта от старой информации

int pc = PurgeComm(hPort, PURGE_TXABORT|PURGE_RXABORT|PURGE_TXCLEAR|PURGE_RXCLEAR);

if ( pc==0 )

AfxMessageBox("Ошибка PurgeComm()");

else

{

int gcs = GetCommState(hPort, &dcbPort);

if ( gcs==0 )

AfxMessageBox("Ошибка GetCommState()");

else

{

dcbPort.BaudRate = CBR_9600;

dcbPort.fBinary = TRUE; // двоичный режим обмена

dcbPort.fNull = FALSE; // нулевые байты не отбрасываются при передаче

dcbPort.Parity = NOPARITY; // бит четности отсутствует

dcbPort.ByteSize = 8; // число бит в байте

dcbPort.StopBits = ONESTOPBIT;// один стоп-бит

int scs = SetCommState(hPort, &dcbPort);

if ( scs==0 )

AfxMessageBox("Ошибка SetCommState()");

else

{

int gct = GetCommTimeouts(hPort, &tm);

if ( gct==0 )

AfxMessageBox("Ошибка GetCommTimeouts()");

else

{

tm.ReadIntervalTimeout = 4;

tm.ReadTotalTimeoutConstant = 100; // из диалога настроек порта

tm.ReadTotalTimeoutMultiplier = 0;

tm.WriteTotalTimeoutConstant = 0;

tm.WriteTotalTimeoutMultiplier = 4;

int sct = SetCommTimeouts(hPort, &tm);

if ( sct==0 )

AfxMessageBox("Ошибка SetCommTimeouts()");

else

{

dataInPort[0] = 0x01;

dataInPort[1] = 0x18;

dataInPort[2] = 0x00;

dataInPort[3] = 0x00;

unsigned short controlSum = 0;

controlSum = calcCRC((unsigned char *)dataInPort, 4);

dataInPort[4] = (controlSum >> 8);

dataInPort[5] = (unsigned char)controlSum;

// запись

over.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);

if ( over.hEvent == NULL )

AfxMessageBox("Ошибка CreateEvent()");

else

{

BOOL scm = SetCommMask(hPort, EV_RXCHAR);

if ( scm==FALSE )

AfxMessageBox("Ошибка SetCommMask()");

else

{

dwWrite = 0;

dwWait = 0;

BOOL wf = WriteFile(hPort, &dataInPort, 6 ,&dwWrite, &over);

if ( wf==TRUE )

AfxMessageBox("Ошибка WriteFile()");

else

{

int wce = WaitCommEvent(hPort, &eventMask, &over);

if ( (!wce) && (GetLastError()==ERROR_IO_PENDING) )

{

DWORD wfso = WaitForSingleObject(hPort, timeout);

switch ( wfso )

{

case WAIT_ABANDONED:

{

// не знаю что это такое

AfxMessageBox("WaitForSingleObject: abandon");

} break;

case WAIT_OBJECT_0:

{

// не разобрался для чего это надо

AfxMessageBox("че-та происходит");

} break;

case WAIT_TIMEOUT:

{

// считываем данные, если они есть

if ( eventMask & EV_RXCHAR )

{

dwRead = 0;

readed = 0;

int cce = ClearCommError(hPort, &errorMask, &state);

if ( cce==0 )

AfxMessageBox("Ошибка ClearCommError()");

else

{

BOOL rf = ReadFile(hPort, &dataFromPort, state.cbInQue, &dwRead, &over);

if ( rf==FALSE )

AfxMessageBox("Ошибка ReadFile()");

else

{

if ( dwRead==0 )

{

// правильно?

AfxMessageBox("таймаут истек");

}

else

{

// типа тут можно начинать обработку принятых данных?

AfxMessageBox("можно начинать обработку данных...");

}

else

{

//где правда ?

AfxMessageBox("device not response");

}

} break;

case WAIT_FAILED:

{

AfxMessageBox("Ошибка WaitForSingleObject()");

} break;

}

else

{

AfxMessageBox("Ошибка WaitCommEvent()");

}

CloseHandle(over.hEvent);

CloseHandle(hPort);

}

протестил вышенаписанное - все работает так как надо, но может есть замечания о некорректности?
и мне неясны з МСДН некоторые вещи (в коде означены комментариями)

COM-порт и таймауты

SVK — Fri, 15 Apr 2005 09:27:25 +0000

SVK:

Цитата emp @ 15.04.05, 05:53

я рад за тебя, AlexSm

Ты лучше сделай поиск с выражением: COM+GetCommState - и тебе всё станет ясно, я надеюсь; можно ещё в FAQ заглянуть!

Также, >>>ещё<<< можно глянуть на сообщение под №8 ;D

COM-порт и таймауты

olddiller — Fri, 15 Apr 2005 09:02:22 +0000

olddiller: AlexSm

Цитата AlexSm @ 14.04.05, 15:00

Функция WaitCommEvent в оверлаппед-структуре требует наличия manual-reset эвента, а ты какой создал?

так он , вроде , такой и создал... :rolleyes:
emp по-моему, не стоит смешивать таймауты и асинхронные операции .... надо использовать либо то, либо другое.

COM-порт и таймауты

emp — Fri, 15 Apr 2005 05:53:01 +0000

emp: я рад за тебя, AlexSm, что ты такой умный....только вот так вот разговаривать не надо ни с кем!
Чем вот так пальцы веером пускать, лучше бы помог разобраться как все это сделать действительно корректно и правильно!!

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

COM-порт и таймауты

AlexSm — Thu, 14 Apr 2005 15:00:26 +0000

AlexSm: Вопрос 1)
Да уж...корректного я тут не увидел. Уж прости :whistle:

При вызове WaitCommEvent ты теряешь статус завершённости асинх. операции записи.
А запись вообще завершилась? что-то я этого не вижу...
А если она отвалила с ошибкой записи последнего байта, то чего-же ты будешь ждать на WaitCommEvent?
На той стороне понимают незавершённые запросы? Да, в твоём случае ты легко можешь пролететь
по всему твоему циклу, и повторить запись. Но это разве корректно???
Функция WaitCommEvent в оверлаппед-структуре требует наличия manual-reset эвента, а ты какой создал?
При ожидании на WaitForSingleObject(hPort, 500) ты ждёшь завершения WaitCommEvent? Ты в этом
точно уверен??? А может PFILE_OBJECT::hEvent всё ещё настроен после вызова WriteFile?
Шансы зайти в обработку условия (eventMask & EV_RXCHAR) согласен огромные, но c учётом ранее написанного -
они разве 100%?
Такое смелое указывание state.cbInQue при возможном превышении sizeof( dataFromPort) c хоть и малой,
но возможной долей вероятности схлопотать ошибку доступа на запись - это тож корректно?
Указывание употреблённой, и не прочищенной оверлаппед-структуры (с непонятным статусом hEvent) в ReadFile - это корректно?
GetOverlappedResult с указанным флагом FALSE (не дожидатся завершения асинх. операции) тут для чего? Ты разве
определяешь, что операция ещё ERROR_IO_INCOMPLETE? А уж последующий вызов ResetEvent на возможно не установленный,
и находящийся в прогрессе выполнения ReadFile - это вообще шедевр...

Помойму ты достаточно плохо понимаешь асинхронные вызовы. Почиталб что-нить на эту тему... :yes:

Вопрос 2)
Насчет таймаутов - внимательно прочти следующее:

Цитата

If an application sets ReadIntervalTimeout and ReadTotalTimeoutMultiplier to MAXDWORD and sets ReadTotalTimeoutConstant to a value greater than zero and less than MAXDWORD, one of the following occurs when the ReadFile function is called:

If there are any characters in the input buffer, ReadFile returns immediately with the characters in the buffer.
If there are no characters in the input buffer, ReadFile waits until a character arrives and then returns immediately.
If no character arrives within the time specified by ReadTotalTimeoutConstant, ReadFile times out.

COM-порт и таймауты

CheshireCat — Thu, 14 Apr 2005 12:54:18 +0000

CheshireCat: Хм, в чем проблема-то? Если функция SetPortTimeouts() отработала успешно, а за положенное таймаутами время из порта не был получен байт/пакет (см.в MSDN), то функция ReadFile() вернет FALSE. Вот и проверяй результат - коли ЛОЖЬ, то девайс тебе не ответил, коли ПРАВДА, то обмен идет успешно.
Кстати, зачем ты в каждой итерации открываешь и закрываешь порт? Имхо достаточно сделать это один раз перед началом обмена и закрыть после окончания обмена.

COM-порт и таймауты

emp — Thu, 14 Apr 2005 12:28:25 +0000

emp: неужели никто ничего не подскажет ? :)
понятно что лень даже до конца читать пост :)

ps: не использовать таймауты нельзя :( надо один раз просто с этим разобраться !

COM-порт и таймауты

emp — Thu, 14 Apr 2005 11:08:26 +0000

emp: Доброго дня всем!
Спешу к вам за помощью.

Вопрос касается организации приема/передачи данных из COM-порта в использованием таймаутов.

Перед выполнением нижеследующей функции я устанавливаю следующие параметры порта:

// установка параметров порта

GetCommState(hPort, &dcbPort);

dcbPort.BaudRate = CBR_9600;

dcbPort.fBinary = TRUE;

dcbPort.fNull = FALSE;

dcbPort.Parity = NOPARITY;

dcbPort.ByteSize = 8;

dcbPort.StopBits = ONESTOPBIT;

SetCommState(hPort, &dcbPort);

// таймауты не использую

Вначале приведу работающий кусок кода из моей программы без использования таймаутов:

void OnDOWNLOAD()

{

int count = 0;

unsigned char dataInPort[6]; // буфер для записи

unsigned char dataFromPort[256];// буфер для чтения

for ( int i=0 ; i<6 ; i++ )

dataInPort[i] = 0;

for ( int j=0 ; j<256 ; j++ )

dataFromPort[j] = 0;

HANDLE hPort = {0}; // дескриптор порта

DCB dcbPort = {0}; // свойства порта

COMMTIMEOUTS tm = {0}; // таймауты

OVERLAPPED over = {0}; // параметры асинхронной передачи

COMSTAT state = {0}; // параметры приема/передачи

CFile magEvents; // файл, куда записываются данные

DWORD dwWrite = 0;

DWORD dwRead = 0;

DWORD readed = 0;

DWORD dwWait = 0;

DWORD errorMask = 0;

DWORD eventMask = 0;

for ( ; ; )

{

dataInPort[0] = 0x01;

dataInPort[1] = 0x18;

dataInPort[2] = 0x00;

dataInPort[3] = 0x00;

dataInPort[4] = 0x81;

dataInPort[5] = 0xDF;

HANDLE hPort; // дескриптор порта

DCB dcbPort; // дескриптор структуры свойств порта

OVERLAPPED over = {0};

COMSTAT state = {0};

CFile magEvents;

DWORD errorMask = 0;

hPort = CreateFile("COM1", GENERIC_WRITE | GENERIC_READ, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);

if ( hPort==INVALID_HANDLE_VALUE )

{

AfxMessageBox("Порт не настроен!\nДля настройки воспользуйтесь меню:\n\"Настройки\COM-порт\".");

CloseHandle(hPort);

break;

}

else

{

PurgeComm(hPort, PURGE_TXABORT|PURGE_RXABORT|PURGE_TXCLEAR|PURGE_RXCLEAR);

GetCommState(hPort, &dcbPort);

// запись в порт

dwWrite = 0;

WriteFile(hPort, &dataInPort, 6, &dwWrite, &over);

// чтение из порта

SetCommMask(hPort, EV_RXCHAR);

over.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);

eventMask = 0;

int wce = WaitCommEvent(hPort, &eventMask, &over);

if ( (!wce) && (GetLastError()==ERROR_IO_PENDING) )

WaitForSingleObject(hPort, 500/*см. ниже "вопрос 1"*/);

if ( eventMask & EV_RXCHAR )

{

dwRead = 0;

readed = 0;

ClearCommError(hPort, &errorMask, &state);

ReadFile(hPort, &dataFromPort, state.cbInQue, &dwRead, &over);

GetOverlappedResult(hPort, &over, &readed, FALSE);

ResetEvent(over.hEvent);

unsigned short registerCount = 0;

unsigned short byteCount = 0;

registerCount = (dataFromPort[4] <<8 | dataFromPort[5]);

byteCount = (dataFromPort[2] <<8 | dataFromPort[3]);

if ( registerCount==0 && count==0 )

{

AfxMessageBox("Данных в журнале нет");

CloseHandle(hPort);

break;

}

if ( registerCount == 0 )

{

AfxMessageBox("Журнал сохранен");

CloseHandle(hPort);

break;

}

count += 1;

///////////////////////// сортировка данных и сохранение их в файл

//не обращайте внимания на этот кусок

unsigned char* data;

data = new unsigned char[255];

for ( int count=0 ; count<=( (int)byteCount-2 ) ; count++ )

data[count] = dataFromPort[count+6];

magEvents.Open("events.mag", CFile::modeCreate | CFile::modeNoTruncate | CFile::modeWrite, NULL);

magEvents.Seek(0, CFile::end);

magEvents.Write(data, ((int)byteCount-2) );

magEvents.Close();

delete data;

//////////////////////////////////////////////////////////////////

}

PurgeComm(hPort, PURGE_TXABORT|PURGE_RXABORT|PURGE_TXCLEAR|PURGE_RXCLEAR);

CloseHandle(hPort);

}

Вопрос 1:
У меня данных максимум может идти до 256 байт,
так вот за эти 500 мс я успеваю (в случае прихода всех 256 байт) полностью их успеть прочитать при скорости 9600.
Вопрос 2: (вытекает из вопроса 1)
использование вышеприведенной реализации функции с использованием 500мс (см. вопрос 1) не совсем то, что мне надо (хотя все
работает корректно!!). Появилась на необходимость использования таймаутов и с ними я никак :( ваще никак не могу раобраться
. Помогите в етом плиз.

Там де я заполняю структуру DCB там же я устанавливаю значения тайимаутов, например такие:

// установка таймаутов (для скорости 9600)

GetCommTimeouts(hPort, &tm);

tm.ReadIntervalTimeout = 4;

tm.ReadTotalTimeoutConstant = 100;

tm.ReadTotalTimeoutMultiplier = 0;

tm.WriteTotalTimeoutConstant = 0;

tm.WriteTotalTimeoutMultiplier = 4;

SetCommTimeouts(hPort, &tm);

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

Нужно мне все это для того, чтобы:
1. если девайс не отвечает, программа не висла. Типа ждем заданный интервал времени и если байт не появляется, выдаем нечто
типа: m_static.SetWindowText("Девайс не отвечает"); и повторять это сообщение надо до тех пор пока девайс не станет отвечать.
В случае, если девайс отвечает и идет обмен данными, выводить типа: m_static.SetWindowText("Девайс в работе");
2. ну и для того, чтобы удовлетворить моего руководителя. :) . Хотя пункт 1 - это для самоудовлетворения :)