COM イベント受信 並列

Question

COMポートを開放し、受信イベントを並列で行いたいです。
流れ
外部機器Aから受信し、処理
外部機器Aを受信している最中に外部機器Bから受信したら外部機器Aの受信処理をとめる

openmpで並列化させ、受信イベントを２つ作成しても、ひとつしか正常に受信できません。

Answer 1

COMポートは１つだけ（例えばCOM１だけ）ですか？一つのCOMポートに２つの外部機器という１：多は無理だと思います。
それとも外部機器AとCOM1、外部機器BとCOM２という風にCOMポートを二つ仕様ですか？

できれば該当部分のソース記載お願い致します。

追記

visual studio Comunity 2015のコンソールアプリケーションとしてビルド

// ConsoleApplication1.cpp : コンソール アプリケーションのエントリ ポイントを定義します。
//

#include "stdafx.h"
#include <windows.h>

int mainthread(void);

DWORD WINAPI ThreadFunc(LPVOID arg)
{
	HANDLE hPort;
	char cRcv;
	DWORD dwSendSize;
	DWORD lRead;

	hPort = CreateFile(
		_T("COM2"),
		GENERIC_READ | GENERIC_WRITE,
		0,
		NULL,
		OPEN_EXISTING,
		FILE_ATTRIBUTE_NORMAL,
		NULL
	);


	while (1)
	{
		WriteFile(hPort, _T("2"), 1, &dwSendSize, NULL);

		Sleep(100);

		cRcv = '\0';

		ReadFile(hPort, &cRcv, 1, &lRead, NULL);

		if (lRead > 0)
			printf("%c", cRcv);

		Sleep(100);
	}


	return 0;
}



int main()
{
	HANDLE hThread;
	DWORD dwThreadId;

	//スレッド起動
	hThread = CreateThread(
		NULL,
		0,
		ThreadFunc,
		NULL,
		0,
		&dwThreadId);

	mainthread();
	return 0;
}
int mainthread()
{
	HANDLE hPort;
	char cRcv;
	DWORD dwSendSize;
	DWORD lRead;

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


	while (1)
	{
		WriteFile(hPort,_T("1"),1,&dwSendSize,NULL);

		Sleep(100);

		cRcv = '\0';

		ReadFile(hPort,&cRcv,1,&lRead,NULL);
		
		if(lRead > 0)
			printf("%c", cRcv);

		Sleep(100);
	}

	return 1;

}

・追記の補足

酔った状態で回答してから翌日あまりにもはしょりすぎたサンプルなので少しだけ補足させてください。

各シリアルポートがたったこれだけで送信受信しているのはループバックアダプタを各COMポートの先につけているから、ボーレート等すべて同じ事が保証されているからで、実際に外部の機器と通信する場合はそのあたりの設定をしてください。

記載したソースはどちらかというとコメントのやりとりでスレッドを作成してマルチスレッドで動作するやり方があまりご存知でないという事でしたのでスレッドの作り方のサンプルとしてみていただければと、、、

骨組みだけ記載しておくと

// サブスレッド
DWORD WINAPI ThreadFunc(LPVOID arg)
{
    while(!iFlg)
    {
       // サブスレッドの処理
    }

    return 1;
}

int main()
{
    HANDLE hThread;
    DWORD dwThreadId;
    int iFlg = 0; // たとえばこれを終了するためのフラグとする

	//サブスレッド作成
	hThread = CreateThread(
		NULL,
		0,
		ThreadFunc,
		NULL,
		0,
		&dwThreadId);
    
　　　// 割り込みでもなんでも良いのですが、何か外的要因でiFlgを1に変更するとプログラムが終了できる
     while(!iFlg)
     {
       // mainスレッドでの処理

　　　　// 現在このmainスレッドとサブスレッドが並行して実行されている段階
     }

　　// サブスレッドがiFlgを検知して終了するまでまつ
　　// これをしなくとも不具合があるとはいいきれないけど（変な終了してメモリリークとかなってもあれなので。。）
　　// あくまでメインスレッドはサブスレッドの終了をまってから終了する
　　WaitForSingleObject(hThread, INFINITE);

    return 0;
}

今回、メインとサブスレッドの２つですが、COM1をサブスレッド１、COM2をサブスレッド2というふうにメインスレッド、サブスレッド１、サブスレッド２と３スレッド構成で各サブスレッドは通信するためだけのスレッド、メインスレッドは各サブスレッドのハンドルを管理し、調停役のような役割で組んでも良いと思います。

Comments

[xasax0404]

そうです、COMポートは２つ使ってます。

#pragma omp parallel
#pragma omp sections
{
#pragma omp section
{
while (i <= sousin){
//データ受信
// COMポートの受信イベント作成
OVERLAPPED ovRead2;
memset(&ovRead2, 0, sizeof(ovRead2));
ovRead2.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
if (ovRead2.hEvent == NULL){
printf("RS232C CreateEvent Error\n");
//return -1;
}

// COMポートの受信イベントマスク
if (SetCommMask(Rs232c2, EV_RXCHAR) == FALSE){
printf("RS232C SetCommMask Error\n");
//return -1;
}

// COMポートの受信待ち
DWORD EvtMask = 0;
DWORD Transfer = 0;
if (WaitCommEvent(Rs232c2, &EvtMask, &ovRead2) == FALSE){
if (GetLastError() == ERROR_IO_PENDING) {
GetOverlappedResult(Rs232c2, &ovRead2, &Transfer, TRUE);
}
else{
printf("RS232C WaitCommEvent Error\n");
//return -1;
}
}

// COMポートの受信イベントチェック
if ((EvtMask & EV_RXCHAR) == EV_RXCHAR){
// COMポートの受信データチェック
COMSTAT comstZ;
DWORD dwErrZ;
ClearCommError(Rs232c2, &dwErrZ, &comstZ);

// COMポートからデータ受信
if (ReadFile(Rs232c2, RcvBuf, comstZ.cbInQue, &dwSize, &ovRead2) == FALSE){
printf("RS232C ReadFile Error\n");
//return -1;
}
else{
// 受信成功
printf("%d\n", i);
}
}
i++;
}
}
#pragma omp section
{
// COMポートの受信待ち
DWORD dwEvtMask = 0;
DWORD dwTransfer = 0;
if (WaitCommEvent(Rs232c1, &dwEvtMask, &ovRead) == FALSE){
if (GetLastError() == ERROR_IO_PENDING) {
GetOverlappedResult(Rs232c1, &ovRead, &dwTransfer, TRUE);
}
else{
printf("RS232C WriteFile Error\n");
//return -1;
}
}
// COMポートの受信イベントチェック
if ((dwEvtMask & EV_RXCHAR) == EV_RXCHAR){
// COMポートの受信データチェック
COMSTAT comst;
DWORD dwErr;
ClearCommError(Rs232c1, &dwErr, &comst);

// COMポートからデータ受信
if (ReadFile(Rs232c1, RcvBuf, comst.cbInQue, &dwSize, &ovRead) == FALSE){
printf("RS232C ReadFile Error\n");
//return -1;
}
else{
// 受信成功
printf("%s", RcvBuf);
}
}
}
}
こんな感じで書いてます。

[hiim]

現在、実行環境が無い為、先ほどからソースレベルで追っていますが（まだ未解決）、その前に確認していただきたいのですが、
COM１、とCOM２を仕様していると想定したとして
この並列処理ですが、Rs232c1、Rs232c2のそれぞれを並列でなくシングルで走らせた場合は正常動作していますか？また
プログラム起動前にmodeコマンドでCOM状態を確認しCOM1、COM2ともに利用可能状態、、プログラム起動後はmodeコマンドでCOM１もCOM２も表示されない（使用中）になりますか？

[xasax0404]

シングルで走らせたら正常に動いています。
modeコマンドでそこの確認は出来ました。

[hiim]

ソースレベルで追っているだけではどこでこけているのかわからない為、帰宅後もしくは後日windows機（今手元にはmacのみ）で試してみます。

ところで根本的な疑問ですが、
CreateThreadをで一報を別スレッドにして、メインスレッドでCOM1もう一方のスレッドでCOM２というのではダメなのでしょうか？
あくまでopenmpの並列でという条件でしょうか？

[xasax0404]

ありがとうございます。よろしくお願いします。
すみません。。。スレッドを別にするやり方や意味？がよく分かっていないため試していないどころか思いつきもしてません。
目的の動作さえ出来ればいいとばかり考えていたので。。。
openmp以外の手法で他にあるならそれでも大丈夫です

[hiim]

後日確認して回答すると言っておきながらおそくなりすいません。
ここ６，７年は完全にwindowsから離れlinux。web系の事ばかりしているため、windows環境の構築から行わないといけなかったり、会社の飲み会等でなかなかwindows機を開くことができずおそくなりました。

さきほどまで会社の飲み会だったため、酔っ払いながらのコーディングなので細かい設定、エラー処理等まったくすっとばして、単にメインスレッドからサブスレッドを立てそれぞれのスレッドで各ポートでループバック通信しているだけのソースになりますが、COM1、COM２で同時に並列に通信はしております。

またこの各すれっどの関数をopenmpの#pragma omp sectionに書いても並列で通信できているのは確認いたしましたのでご参考にしてください。

ただし飲酒コーディングなので細かい所は適宜直してください。。。

[hiim]

CreateThread等でマルチスレッドとしてプログラムを組むときは変数の扱い等、スレッドセーフに気をつけて使用してください、同じリソースを両スレッドから使う場合、つぶしあわないように。。。。

[hiim]

昨夜は酔った状態でのかなりはしょりすぎのサンプルだったため少しだけ補足をいれさせていただきました