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

Оптимизация асинхронного I/O в COM порт

Coffee — Sun, 05 Mar 2006 20:21:55 +0000

Coffee:

Цитата sploid @ 04.03.06, 21:18

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

Как я уже писал у меня компилятор - BCB 6.0 какие в нем солюшены - я не знаю. И так весь VCL убрал дабы совместимость была, и консоль - по тойже причине.

Цитата sploid @ 04.03.06, 21:18

т.к. порт открыт как оверлапед, то
Цитата
if (!ReadFile(hPort, Buf, dwRead, &dwRead, &OverRead))
{
cout<<"\n\nError reading port\n\n"; Error(); exit(1);
}
если не считалось то нормально и нужно ждать события OverRead.hEvent ( когда считается), а не выходить с ошибкой.

Кстати, валится именно на этом... Может я не так как-то делаю... Сделал так:

if (!ReadFile(hPort, Buf, dwRead, &dwRead, &OverRead))

{

WaitForSingleObject(OverRead.hEvent, INFINITE);

....

}

Теперь вечно висит на WaitForSingleObject ... мда короче. Разбираться еще и разбираться...

Цитата sploid @ 04.03.06, 21:18

в чем проблема, почему не работает на другом компе?

Работаем удаленно - другой комп в другом городе. Сказать 100% точно - не могу. Но 99,9% проблема в том что вышеописанная конструкция - корявая, как впрочем видимо и все остальное. :(

Цитата Ace @ 05.03.06, 10:42

if (!WriteFile(hPort, temp, sizeof(temp),&dwWrite, &OverWrite))

Размер указателя? Ты уверен что так правильно?

Косяк, спасибо, учтем.

Цитата Ace @ 05.03.06, 10:42

OverRead.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
...
WaitForSingleObject(OverRead.hEvent, INFINITE);

У тебя эвент с мануальным сбросом, но, что-то не где не видно чтоб ты его сбрасывал...

Да честно говоря - х.з. смотрел в МСДНе исходники их. Вроде тоже нигде не сбрасывают. А может и сбрасывают, там такое наворочено, что черт ногу сломит. :wall: Буду еще смотреть.

Цитата Ace @ 05.03.06, 10:42

char Buf[100]="";
...
dwRead = ComStat.cbInQue;
...
if (!ReadFile(hPort, Buf, dwRead, &dwRead, &OverRead))

А не ты разве простраивал буффер в 256? Шанс схлопотать исключение не велик, но если схлопочешь - мало не покажется...

Самое малое из моих зол... ;) :D :lool:

Цитата Ace @ 05.03.06, 10:42

BuildCommDCB("baud=9600 parity=N data=8 stop=1",dcb);
А остальные настройки у ваших компов одинаковые?

Да вроде бы да. При таких же параметрах HyperTerminal пашет ...

В общем тему пока закрывать не буду. Попробую еще с исходниками с МСДНа разобраться. Если поставить эти параметры туда, их прога - катит. На этом можно было бы и остановиться, но меня бесят две вещи - уровень собственного понимания этой проблемы (над этим надо работать...) и весь тот зоопарк с ресурсами, критическими секциями, десятью отдельными *.с файлами в проекте и прочей мишурой из МСДН сурсов... >:( Короче работы по горло.
Всем большое спасибо что откликнулись - буду искать дальше. :)

Оптимизация асинхронного I/O в COM порт

Ace — Sun, 05 Mar 2006 10:42:08 +0000

Ace:

if (!WriteFile(hPort, temp, sizeof(temp),&dwWrite, &OverWrite))

Размер указателя? Ты уверен что так правильно? ;)

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

...

WaitForSingleObject(OverRead.hEvent, INFINITE);

У тебя эвент с мануальным сбросом, но, что-то не где не видно чтоб ты его сбрасывал...

char Buf[100]="";

...

dwRead = ComStat.cbInQue;

...

if (!ReadFile(hPort, Buf, dwRead, &dwRead, &OverRead))

А не ты разве простраивал буффер в 256? Шанс схлопотать исключение не велик, но если схлопочешь - мало не покажется...

BuildCommDCB("baud=9600 parity=N data=8 stop=1",dcb);

А остальные настройки у ваших компов одинаковые?

Оптимизация асинхронного I/O в COM порт

sploid — Sat, 04 Mar 2006 21:18:31 +0000

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

т.к. порт открыт как оверлапед, то

Цитата

if (!ReadFile(hPort, Buf, dwRead, &dwRead, &OverRead))

{

cout<<"\n\nError reading port\n\n"; Error(); exit(1);

}

если не считалось то нормально и нужно ждать события OverRead.hEvent ( когда считается), а не выходить с ошибкой.

в чем проблема, почему не работает на другом компе?

Оптимизация асинхронного I/O в COM порт

Coffee — Sat, 04 Mar 2006 16:07:35 +0000

Coffee: И снова приветствую всех!
Есть большая просьба - у кого есть модем внутренний или внешний или подобное оборудование - проверьте пожалуйста, будет ли у вас работать этот код. У меня PCI модем на COM3 у товарища - обычный модем на СОМ2. У меня все прекрасно работает - у него - нет. Понять причину немогу.
Если кто подскажет в чем дело - буду очень признателен.

#include <windows.h>

#include <conio.h>

#include <iostream.h>

#define MAX 1024

DWORD WINAPI ThreadFunc(LPVOID lpParam );

void Error(void);

bool Terminate=TRUE;

HANDLE hPort = NULL;

char *temp;

void main(void)

{

//Запрашивам имя порта

clrscr();

temp=(char*)calloc(MAX,sizeof(char));

strcpy(temp,"\n\nВведите номер открываемого порта, например COM1 или COM3\n\n");

CharToOem((const char*)temp,(char*)temp);

cout<<temp;

memset(temp, '{text}',MAX);

cin>>temp;

//открываем порт

hPort=CreateFile(temp,

GENERIC_WRITE|GENERIC_READ,

NULL,

OPEN_EXISTING,

FILE_FLAG_OVERLAPPED,

NULL);

if(hPort!=INVALID_HANDLE_VALUE){

cout<<"\nOpenPort - ok\n";}

else{

Error();getch();exit(1);

}

//проводим настройку порта

DCB *dcb;

COMMTIMEOUTS ct;

//скорости, четности, битность битов, стоп биты...

dcb=(DCB*)HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,sizeof(DCB));

dcb->DCBlength=sizeof(DCB);

BuildCommDCB("baud=9600 parity=N data=8 stop=1",dcb);

dcb->fNull=TRUE;

//таймауты порта

ct.ReadIntervalTimeout=10;

ct.ReadTotalTimeoutMultiplier=ct.ReadTotalTimeoutConstant=0;

ct.WriteTotalTimeoutMultiplier=ct.WriteTotalTimeoutConstant=0;

SetCommState(hPort,dcb);

SetCommTimeouts(hPort,&ct);

//очистка порта перед работой очищаем все что можно

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

SetupComm(hPort,256,256); //последние два параметра - длина вх.\ вых. буфера

SetCommMask(hPort,EV_RXCHAR); //маска ожидания символа во входном буфере

//Запускаем поток на чтение порта

DWORD lpThreadId;

HANDLE hThread = CreateThread(

(LPSECURITY_ATTRIBUTES) NULL, // pointer to thread security attributes

(DWORD) 0, // initial thread stack size, in bytes

(LPTHREAD_START_ROUTINE) &ThreadFunc, // pointer to thread function

(LPVOID) &hPort, // argument for new thread

(DWORD) 0, // creation flags

(LPDWORD) &lpThreadId // pointer to returned thread identifier

);

//Работаем с пользователем

for(;Terminate==TRUE;)

{

strcpy(temp,"\n\nВведите команду, например ATI1-ATI7 или ATZ\nВыход - восклицательный знак '!'\n");

CharToOem((const char*)temp,(char*)temp);

cout<<temp;

memset(temp, '{text}',MAX);

cin>>temp;

if(strcmp(temp,"!")==0)

{

TerminateThread(hThread,1);

clrscr();

cout<<"\nBye!\n";

exit(0);

}

DWORD dwWrite ;

OVERLAPPED OverWrite;

strcat(temp,"\r\n");

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

if (OverWrite.hEvent == NULL)

{

cout<<"\n\nError creating write event\n\n"; Error(); exit(1);

}

if (!WriteFile(hPort, temp, sizeof(temp),&dwWrite, &OverWrite))

{

if(GetLastError() != ERROR_IO_PENDING)

{

cout<<"\n\nError writing port\n\n"; Error(); exit(1);

}

else

{

cout<<"\n\nWrited to port\n"<<temp;

}

//getch();

}

getch();

}

DWORD WINAPI ThreadFunc(LPVOID lpParam )

{

Terminate=TRUE;

HANDLE hPort=*(HANDLE*)lpParam;

COMSTAT ComStat;

DWORD dwMask, dwError, dwRead;

OVERLAPPED OverRead;

char Buf[100]="";

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

if (OverRead.hEvent == NULL)

{

cout<<"\n\nError creating read event\n\n"; Error(); exit(1);

}

while (Terminate)

{

if (!WaitCommEvent(hPort, &dwMask,(LPOVERLAPPED)&OverRead))

{

if (GetLastError() == ERROR_IO_PENDING){

WaitForSingleObject(OverRead.hEvent, INFINITE);

}

else{

cout<<"\n\nError waiting port event\n\n"; Error(); exit(1);

}

if (!ClearCommError(hPort, &dwError, &ComStat))

{

cout<<"\n\nError clearing port\n\n"; Error(); exit(1);

}

dwRead = ComStat.cbInQue;

if(dwRead > 0)

{

if (!ReadFile(hPort, Buf, dwRead, &dwRead, &OverRead))

{

cout<<"\n\nError reading port\n\n"; Error(); exit(1);

}

// В Buf находятся прочитанные байты

// идет обработка принятых байтов ...

cout<<"\n\n*****************************\n"<<

"DATA_FROM_PORT:\n"<<(char*)Buf<<

"\n*****************************\n";

memset(Buf, '{text}', strlen(Buf) - 1);

}

return 0;

}

void Error(void)

{

LPVOID lpMsgBuf;

FormatMessage(

FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,

NULL,

GetLastError(),

MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),

(LPTSTR) &lpMsgBuf,

NULL);

CharToOem((const char*)lpMsgBuf,(char*)lpMsgBuf);

cout<<"\n\nGetLastError:\n\n"<<(const char*)lpMsgBuf<<"\n\n";

LocalFree( lpMsgBuf );

}

Оптимизация асинхронного I/O в COM порт

Coffee — Wed, 01 Mar 2006 16:40:15 +0000

Coffee:

Цитата Паровоз @ 01.03.06, 13:29

Слушай, а может тебе проверить провода на счет замыкания 2и3 пина. Если они замкнуты, то и ответы будут такими странными. И еще вариант, то, что оборудование такое.

2 exodus все понятно, OVERLAPPED forever :)
2 Паровоз нет, там стоит PCI модем на котором я и извращаюсь, когда получится с ним перейду на другое оборудование. Да и не может быть так, что одни и те же команды работают асинхронно и не работают синхронно. ИМХО - либо кривая прога - либо виндовый механизм синхронного I/O в ХР...

Оптимизация асинхронного I/O в COM порт

Паровоз — Wed, 01 Mar 2006 13:29:28 +0000

Паровоз: Слушай, а может тебе проверить провода на счет замыкания 2и3 пина. Если они замкнуты, то и ответы будут такими странными. И еще вариант, то, что оборудование такое.

Оптимизация асинхронного I/O в COM порт

exodus — Wed, 01 Mar 2006 13:11:08 +0000

exodus: Coffee, в MSDN написано, что синхронно читать/писать можно, но реалии таковы, то это дело работает только на Win95-98, а на линейке NT5 (2k, XP, 2003) не пашет, про NT4 и ранее не в курсе - не пробовал, так что про синхронную работу - забудь. У меня правда получается работать синхронно с WaitCommEvent, при том, что дескриптор порта открыт с флагом OVERLAPPED, но в доке написано, что такой режим не рекомендуется.

Добавлено 01.03.06, 13:13
Собственно вот тема, где обсуждается блокировка при синхронном в/в: [COM-порт]синхронная запись/мониторинг

Оптимизация асинхронного I/O в COM порт

Coffee — Wed, 01 Mar 2006 11:14:26 +0000

Coffee:

Цитата Adil @ 01.03.06, 08:48

Цитата Паровоз @ 01.03.06, 06:44

Асинхронно порт работает только в 98windows, NT/XP вроде только синхронный.

Чушь

Добавлено 01.03.06, 08:50

Цитата Coffee @ 28.02.06, 19:25

Посылаешь ему команду (любую) - во входном буфере ловишь ее имя и все. Никакого тебе ответа от оборудования. Когда делал асинхронно - все было иначе.

Странная и непонятная фраза: что значит "ловить имя команды"? Какой ответ от какого оборудования?

2 Паровоз
"ReadFile не вернет управления, пока не заполнит буфер либо не возникнет сбой/таймаут." - верно, он буфер пока не заполнит, он не вернет, но он чем-то не тем его заполняет... и BC>0 тут не катит... чтобы понять что я имею ввиду см. мой ответ Adil'у

2 Adil
Поясню что это значит.
1. Асинхронный вариант
Посылаю команду ATZ получаю ответ от оборудования - что-то типа "ATZ\r\n\r\nOK\r\n" во входном буфере.
Посылаю команду ATH1 получаю ответ от оборудования - что-то типа "\r\nOK\r\n" во входном буфере и характерный звук модема.

1. Синхронный вариант (исходник см.выше)
Посылаю команду ATZ получаю во входном буфере "ATZ".
Посылаю команду ATH1 получаю во входном буфере "ATH1" и никакого звука от модема.

2 exodus
В одном потоке помоему точно не стоит ;)
Так тот исходник что я кинул будет работать под ХР? или под 2000/ХР синхронная запись/чтение - в моем случае не покатят? Непонимаю... :wall: в мсдн вроде написано мол и то можно и то, только примеры лежат под OVERLAPPED вариант...

Оптимизация асинхронного I/O в COM порт

exodus — Wed, 01 Mar 2006 09:31:02 +0000

exodus:

Цитата Adil @ 01.03.06, 08:48

Чушь

К сожалению, не чушь - сам недавно напоролся на эту фигню. Недавно эту проблему уже обсуждали на форуме.
При попытке записать синхронно в порт, тред, который пишет, - блокируется, пока не разблокируется тред, в котором данные из порта синхронно читаются.
Т.е. пока используется либо только синхронное чтение, либо только синхронная запись - всё ОК, совместно они друг друга блочат.

Пришлось переходить к псевдо-синхронной схеме, т.е. использовать асинхронные вызовы ReadFile/WriteFile, а потом ожидать сигнализации события о завершении операции.

Добавлено 01.03.06, 09:38
Coffee, при таком количестве портов, возможно, имеет смысл не плодить кучу тредов, а создать пул тредов, каждый из которых будет обрабатывать несколько портов. В таком случае, после запуска операции асинхронно, тебе надо будет, например, с помощью GetOverlappedResult пробегаться по списку ивентов, связанных с операциями по каждому порту. Теоритически, можно рискнуть это сделать в одном треде (но у меня есть ощущение, что не будет успевать).

В UNIXах c этим проще - select умеет работать не только с сокетами, но и с дескрипторами обычных файлов и устройств, а в Windows данная возможность не реализована.

Оптимизация асинхронного I/O в COM порт

Adil — Wed, 01 Mar 2006 08:48:24 +0000

Adil:

Цитата Паровоз @ 01.03.06, 06:44

Асинхронно порт работает только в 98windows, NT/XP вроде только синхронный.

Чушь

Добавлено 01.03.06, 08:50

Цитата Coffee @ 28.02.06, 19:25

Странная и непонятная фраза: что значит "ловить имя команды"? Какой ответ от какого оборудования?

Оптимизация асинхронного I/O в COM порт

Паровоз — Wed, 01 Mar 2006 06:44:53 +0000

Паровоз: Используй вместо своей конструкции
WaitCommEvent(hPort,&mask,NULL);
ReadFile(hPort,buf_in,strlen(buf_out),&bc,NULL);
Вот эту
if( ReadFile(hPort, buf_in, strlen(buf_out), &bc, 0)){
if (bc > 0){/*что то делаем*/}
}
ReadFile не вернет управления, пока не заполнит буфер либо не возникнет сбой/таймаут. Совсем необязательно, что буфер будет заполнен, нужно проверять, что bc>0. Асинхронно порт работает только в 98windows, NT/XP вроде только синхронный.

Оптимизация асинхронного I/O в COM порт

Coffee — Tue, 28 Feb 2006 19:25:49 +0000

Coffee: Спасибо всем еще раз, возник такoй вопрос:
Обрисую ситуацию - порядка 30-50 портов, на каждый порт свой поток, пока я данные в порт не отправил и не получил ответ от устройства - делать потоку собственно нечего т.е. дальнейшее выполнение целиком зависит от результатов предыдущих шагов(как я понимаю основная фишка асинхронного метода в продолжении работы потока не заботясь о завершении записи/считывания информации).
В моем случае есть ли какой-либо смысл использовать асинхронный I/O?
Или проще(и проще ли?) использовать в каждом потоке синхронный метод?

И еще одно :) Порылся поиском по сайту, накопал много доков по портам, в одном из них нашел пример, но вот чего я понять не могу(я все-таки пока далеко не эксперт по портам ;) ) - так это почему он так странно работает? Посылаешь ему команду (любую) - во входном буфере ловишь ее имя и все. Никакого тебе ответа от оборудования. Когда делал асинхронно - все было иначе. Вот пример...

Цитата

#include
#include
#include

void main(void)
{
DCB dcb;
COMMTIMEOUTS ct;
HANDLE hPort;
DWORD bc;
DWORD mask;

char *buf_out="ATI3";
char *buf_in;

dcb.DCBlength=sizeof(DCB);
BuildCommDCB("baud=9600 parity=N data=8 stop=1",&dcb);
dcb.fNull=TRUE;

ct.ReadIntervalTimeout=10;
ct.ReadTotalTimeoutMultiplier=ct.ReadTotalTimeoutConstant=0;
ct.WriteTotalTimeoutMultiplier=ct.WriteTotalTimeoutConstant=0;

hPort=CreateFile("COM3",GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,0,NULL);
if(hPort==INVALID_HANDLE_VALUE) {
MessageBox(NULL,"Невозможно открыть последовательный порт","Error",MB_OK);
ExitProcess(1);
}

SetCommState(hPort,&dcb);
SetCommTimeouts(hPort,&ct);
PurgeComm(hPort,PURGE_TXABORT|PURGE_RXABORT|PURGE_TXCLEAR|PURGE_RXCLEAR);
SetupComm(hPort,256,256);

SetCommMask(hPort,EV_RXCHAR);

buf_in=(char*)HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,strlen(buf_out)+1);
cout<<"\nWRITTE\t"< WriteFile(hPort,buf_out,strlen(buf_out),&bc,NULL);
WaitCommEvent(hPort,&mask,NULL);
ReadFile(hPort,buf_in,strlen(buf_out),&bc,NULL);
cout<<"\nREAD\t"<
HeapFree(GetProcessHeap(),0,buf_in);
CloseHandle(hPort);
getch();
}

Оптимизация асинхронного I/O в COM порт

exodus — Mon, 27 Feb 2006 10:14:51 +0000

exodus: sploid, это у тебя для ожидания WaitCommEvent сделано, а для чтения нет, тем более, что можно завершение потока по-другому реализовать, например вручную сигнализировать ивент или просто прибить тред.

Оптимизация асинхронного I/O в COM порт

sploid — Mon, 27 Feb 2006 09:58:40 +0000

sploid: флаг bWait выставляется в фальс, когда надо завершить поток чтения, т.е. когда случится событие pSiem->m_hEventEndThread.

Оптимизация асинхронного I/O в COM порт

exodus — Mon, 27 Feb 2006 08:34:25 +0000

exodus: sploid, я бы чуток упростил программу, учитывая, что ожидание завершения OVERLAPPED-операции может делать сам GetOverlappedResult с флагом bWait = TRUE.

Оптимизация асинхронного I/O в COM порт

Паровоз — Mon, 27 Feb 2006 06:31:46 +0000

Паровоз: Используй ReadFile в отдельных потоках, проверено, работает надежно. Дело в том, что приведенный выше пример немного медленней работает и при высокой скорости работы порта может пропускать байты, вернее буфер порта переполняется и байты теряются.

Оптимизация асинхронного I/O в COM порт

Coffee — Mon, 27 Feb 2006 00:56:11 +0000

Coffee: Спасибо, буду пока разбираться, помоему, то что нужно! :yes:

Оптимизация асинхронного I/O в COM порт

sploid — Sun, 26 Feb 2006 22:12:49 +0000

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

char strNamePort[ 150 ] = { 0 };

sprintf( strNamePort, "COM%d:", nComPort );

m_hComPort = CreateFile( strNamePort,

GENERIC_READ | GENERIC_WRITE,

NULL,

OPEN_EXISTING,

FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED,

NULL );

...........

if ( SetCommMask( m_hComPort, EV_RXCHAR ) )

{

COMMTIMEOUTS TimeOuts;

if ( GetCommTimeouts( m_hComPort, &TimeOuts ) )

{

TimeOuts.ReadIntervalTimeout = 40;

TimeOuts.ReadTotalTimeoutMultiplier = 0;

TimeOuts.ReadTotalTimeoutConstant = 0;

TimeOuts.WriteTotalTimeoutMultiplier = 0;

TimeOuts.WriteTotalTimeoutConstant = 0;

if ( SetCommTimeouts( m_hComPort, &TimeOuts ) )

{

функция чтение крутиться в цикле в отдельном потоке, вот кусок.

// pSiem->m_hComPort - хэндл ком порта

// pSiem->m_hEventEndThread - событие что надо закончить поток чтения.

DWORD nBytesRead = 0;

bool bFlag = true;

while ( bFlag )

{

// если тут, значит все ок и данные записали, читаем ответ

DWORD dwCommEvent;

DWORD dwOvRes = 0;

// ивент события ком порта

OVERLAPPED osStatus = { 0 };

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

if ( osStatus.hEvent == NULL )

{

TRACE( "ERROR: ивет для события ком порта не создался!\n" );

return;

}

if ( !WaitCommEvent( pSiem->m_hComPort, &dwCommEvent, &osStatus ) )

{

if ( GetLastError( ) == ERROR_IO_PENDING )

{

// все ок, ждем события

}

else

{

CloseHandle( osStatus.hEvent );

char message[ 200 ] = { 0 };

sprintf( message, "ERROR: WaitCommEvent failed, error = %d!\n", GetLastError( ) );

TRACE( message );

return;

}

else

{

// плохо, не понятная ошибка

CloseHandle( osStatus.hEvent );

char message[ 200 ] = { 0 };

sprintf( message, "ERROR: WaitCommEvent failed, error = %d!\n", GetLastError( ) );

TRACE( message );

return;

}

// ожидаем события не чтение или закрываем поток на чтение

HANDLE hEv[ 2 ];

hEv[ 0 ] = pSiem->m_hEventEndThread;

hEv[ 1 ] = osStatus.hEvent;

DWORD dwRes = WaitForMultipleObjects( 2, hEv, FALSE, INFINITE );

switch( dwRes )

{

case WAIT_OBJECT_0:

bFlag = false;

// завершаем поток

break;

case WAIT_OBJECT_0 + 1:

if ( !GetOverlappedResult( pSiem->m_hComPort, &osStatus, &dwOvRes, FALSE ) )

{

// плохо, не понятная ошибка

CloseHandle( osStatus.hEvent );

char message[ 200 ] = { 0 };

sprintf( message, "ERROR: GetOverlappedResult failed, error = %d!\n", GetLastError( ) );

TRACE( message );

return;

}

else

{

CloseHandle( osStatus.hEvent );

// ивент чтения

OVERLAPPED osRead = { 0 };

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

if ( osRead.hEvent == NULL )

{

TRACE( "ERROR: инет для чтения не создался!\n" );

return;

}

COMSTAT Comstatus;

DWORD dwError;

ClearCommError( pSiem->m_hComPort, &dwError, &Comstatus );

char * buffer = new char [ Comstatus.cbInQue + 1 ];

memset( buffer, 0, Comstatus.cbInQue + 1 );

if ( !ReadFile( pSiem->m_hComPort, buffer, Comstatus.cbInQue, &nBytesRead, &osRead ) )

{

DWORD dwLastError = GetLastError( );

if( dwLastError != ERROR_IO_PENDING )

{

// ошибка чтения

CloseHandle( osRead.hEvent );

char message[ 200 ] = { 0 };

sprintf( message, "ERROR: ReadFile failed, error = %d!\n", dwLastError );

TRACE( message );

return;

}

else

{

DWORD fRes = WaitForSingleObject( osRead.hEvent, INFINITE );

switch ( fRes )

{

case WAIT_OBJECT_0:

if ( !GetOverlappedResult( pSiem->m_hComPort, &osRead, &nBytesRead, FALSE))

{

// ошибка чтения

CloseHandle( osRead.hEvent );

char message[ 200 ] = { 0 };

sprintf( message, "ERROR: GetOverlappedResult failed, error = %d!\n", GetLastError( ) );

TRACE( message );

return;

}

else

{

// All ok.

}

break;

default:

{

// ошибка чтения

CloseHandle( osRead.hEvent );

char message[ 200 ] = { 0 };

sprintf( message, "ERROR: Хрен знает что за ошибка, error = %d!\n", GetLastError( ) );

TRACE( message );

return;

}

};

}

else

{

// All ok.

}

в конце по идее в переменной buffer будет прочитанные символы
что непонятно спрашивайте.

Оптимизация асинхронного I/O в COM порт

Coffee — Sun, 26 Feb 2006 20:24:02 +0000

Coffee: Доброго времени суток, уважаемые!

Платформа WIN32, ОС ХР, комилятор BCB 6.xx

Собственно в чем вопрос - проблема в том, что в потоке в цикле висит алгоритм который проверяет WaitCommEvent(), ERROR_IO_PENDING, наличие данных в очереди - ComStat.cbInQue ну и так далее, и все такое. Все замечательно, все работает, но очень уж беспокоит то, что загрузка ЦП очень высока. Пока обрабатывается один порт одним потоком, все вроде бы и ничего, но в реальности будет обрабатываться много (примерно 30~50) портов, я так полагю, ситуация значительно ухудшится. :(
Этому есть разумное решение программным способом? ;)