タイムアウトパラメータを指定したManualResetEventクラスの使用に問題があります。この問題は、特にWinXP組み込みプラットフォームで発生します。このコードは、他のWindowsプラットフォームでも完全に機能します。TCPサーバーと通信しています。私のクライアントコードでは、サーバーに接続して新しいスレッドを生成します。これは、受信ソケットのデータを継続的に監視することです。メインスレッドでデータを送信します。コードスニペットは以下に添付されています:
internal void initSocket()
{
.....
.....
if (socket.Connected)
{
Tracing.info("Connected to server");
ReceiveThread = new Thread(new ThreadStart(StartReceiving));
ReceiveThread.Start();
}
}
/// <summary>
/// Sends a request to Server and waits for its response.
/// </summary>
/// <param name="msg"></param>
/// <param name="timeout">Timeout time, when </param>
/// <returns></returns>
private CdcMessage sendSync(CdcMessage msg, int timeout)
{
resultMessage = null;
// store current messageId...
resultMessagePackageId = msg.MessageId;
String msgToSend = msg.serialize();
Tracing.debug("SEND : >> " + msgToSend);
socketWriter.WriteLine(msgToSend);
// Wait for response from read thread...
resultReceivedEvent = new ManualResetEvent(false);
bool bReponseSent = resultReceivedEvent.WaitOne(timeout);
if (!bReponseSent)
{
resultMessage = null;
}
return resultMessage;
}
/// <summary>
/// Thread function which continuously checks for the
/// data from server. It will read the data only if it
/// is available
/// </summary>
public void StartReceiving()
{
while (Connected)
{
try
{
Thread.Sleep(100);
String response = socketReader.ReadLine();
Tracing.info("Raw data received = " + response);
resultMessage = CdcMessage.deserialize(response);
Tracing.info("Deserialized response = " + resultMessage);
if (resultMessage == null)
{
continue;
}
else if (resultMessage.IsHeartbeat)
{
Tracing.debug("Heartbeat");
socketWriter.WriteLine(response);
}
else if (!resultMessage.MessageId.Equals(resultMessagePackageId))
{
// not the correct package id...reject...
Tracing.warn("REJECTED: Package-ID: " + resultMessage.MessageId);
continue;
}
else
{
resultReceivedEvent.Set();
Tracing.info("StartReceiving() : Received data");
Tracing.debug("RECEIVED: >> " + response);
}
}
catch (NullReferenceException nre)
{
Tracing.error("StartReceiving(): Socket doesn't exist!", nre);
close();
break;
}
catch (ObjectDisposedException ode)
{
Tracing.error("StartReceiving(): Socket is disposed!", ode);
close();
break;
}
catch (IOException ex)
{
Tracing.error("StartReceiving(): Socket IO-Exception!", ex);
close();
break;
}
}
}
コードの重要な側面を強調しました。ほとんどのWindowsOSで、WaitOne(timeout)関数が問題なく機能することが確認されています。しかし、XP組み込みでは、問題が発生します。WaitOneは、受信スレッドからデータを受信せずに、ほとんどすぐに戻ります。
私がしたことは、WaitOneに-1を渡すことによって、タイムアウトをINFINITEにしたことです。この場合、私は問題を解決することができました。ただし、これにより他の副作用が発生します(たとえば、サーバーがシャットダウンされた場合、WaitOneが戻ることはありません!)
誰かがこの問題を解決するのを手伝ってくれませんか?