COMポートとして認識されているUSBデバイスがあります。COMポートに情報取得のコマンドを書き込むとUSBデバイスが状態を応答を返すようになっています。USBデバイスには動作指示のコマンドと情報取得のコマンドの2種類があり、動作指示はコマンドを書き込むことでUSBデバイスが意図した通りに動作しています。
一方の情報取得のコマンドは書き込みは成功しています。情報取得のコマンドを書き込んだ後に、読み込みを行うと応答がありません。USBデバイスが不調と思い、Teratermを利用して情報取得のコマンドを書き込むと意図した応答を得られます。応答は体感で1秒に満たない時間で得られます。
Teratermと同等のことをVC++から行いたいと考えています。
最初はWriteFileでCOMポートに書き込んだ直後にReadFileでCOMポートを読んでみると、0バイトでした。調べていくとSetCommMaskで受信イベントを扱う方法があると分かったので、WaitCommEventでイベントの待ち合わせを開始したら、別スレッドで情報取得コマンドの書き込みを行う様にしました。そうした結果、WaitForSingleObjectに指定した3秒のタイムアウト時間を超過し、タイムアウトしました。
処理タイミングが問題だとは思っていますが、どのように修正を行うのがいいのかが分かりません。情報取得を行うメソッドを抜粋したものが下のコードになります。非同期I/Oのセオリー的な情報などでも非常に助かります。
SetLastError(NO_ERROR);
// COMポートのオープンに成功すると プロパティ m_hComPort にハンドルが設定されている
this->Open();
// openに失敗していたら終了
if ( this->m_hComPort == INVALID_HANDLE_VALUE )
{
return ;
}
OVERLAPPED overlapped;
ZeroMemory(&overlapped, sizeof(overlapped));
overlapped.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
// COMポートの受信イベントマスク
if (SetCommMask(this->m_hComPort,EV_RXCHAR) == FALSE){
OutputDebugString("SetCommMaskに失敗\n");
}
// COMポートの受信待ち
DWORD dwEvtMask = 0;
DWORD dwTransfer = 0;
if (WaitCommEvent(this->m_hComPort,&dwEvtMask,&overlapped) == FALSE)
{
if (GetLastError() != ERROR_IO_PENDING)
{
OutputDebugString("WaitCommEventがERROR_IO_PENDING以外になった \n");
goto end;
}
// 書き込み処理を別スレッドで起動する
CWinThread* pReadThread = AfxBeginThread(ReadDeviceIdSendThread, this);
DWORD waitResult;
if ( (waitResult = WaitForSingleObject(overlapped.hEvent, 3000)) != WAIT_OBJECT_0 )
{
switch( waitResult )
{
case WAIT_TIMEOUT:
// took longer than 3 second - cancel it and give up
CancelIo(this->m_hComPort);
OutputDebugString("EV_RXCHARイベント WAIT_TIMEOUT\n");
break;
case WAIT_ABANDONED:
OutputDebugString("EV_RXCHARイベント WAIT_ABANDONED\n");
break;
default:
break;
}
}
}
if ( dwEvtMask == 0 )
{
OutputDebugString("WaitCommEventで発生したイベントでエラーが起きた\n");
goto end;
}
// -------------------------------------
// 読み込んだデバイスID
BYTE deviceId = 0x00;
// 読み込んだサイズ
DWORD dwReadSize;
// COMポートの受信イベントチェック
if ((dwEvtMask & EV_RXCHAR) == EV_RXCHAR)
{
// COMポートの受信データチェック
COMSTAT comst;
DWORD dwErr;
OutputDebugString("COMポートから受信した\n");
ClearCommError(this->m_hComPort,&dwErr,&comst);
// COMポートからデータ受信
if(ReadFile(this->m_hComPort,&deviceId, sizeof(deviceId), &dwReadSize, &overlapped) == FALSE)
{
if (GetLastError() == ERROR_IO_PENDING)
{
// コマンド送信が完了するまで待機します
GetOverlappedResult(this->m_hComPort, &overlapped, &dwReadSize, TRUE);
CString msg;
msg.Format("読み込みが成功しました。readsize=[%d], device_id=[%x]\n",dwReadSize, deviceId);
this->m_bCommand[0] = deviceId;
}
OutputDebugString("ReadFile に失敗した\n");
}else{
// 受信成功
OutputDebugString("ReadFile に成功した\n");
}
}
CString msg;
msg.Format("デバイスIDを読み込みのが成功しました。readsize=[%d], device_id=[%x]\n",dwReadSize, deviceId);
OutputDebugString(msg);
end:
// TODO CloseHandleを追加する
this->Close();
