Socket server problems

[Pete Davis]

I'm trying to do async socket IO in a socket server in C# and I'm having
trouble on the receive side of things.

I've tried variations of the code below and I just can't seem to get it to
work. I think my _receiveEvent.S et() calls may be misplaced among other
things. EndReceive() gets called when the first message is sent.

What I want it to do is to continue to receive until the entire message has
arrived. I'm not really sure how to accomplish that. Once a full message has
arrived, I want to process the message (which generally involves a reply)
and then continue receiving.

Thanks for any help anyone can provide.

Pete Davis
private void CommunicationTh read()
{
Monitor.Enter(_ socketStates);
SocketState sockState = (SocketState) _socketStates[Thread.CurrentT hread];
sockState.Conne cted = true;
Monitor.Exit(_s ocketStates);

try
{
_receiveEvent.R eset();
sockState.Remot eSocket.BeginRe ceive(sockState .ReceiveBuffer, 0,
SocketState.Buf ferSize, 0, new AsyncCallback(t his.ReadCallbac k), sockState);
_receiveEvent.W aitOne();
}
catch(SocketExc eption se)
{
sockState.Conne cted = false;
LogException(se );
}
catch(System.Ex ception ex)
{
sockState.Conne cted = false;
LogException(ex );
}
return;
}

private void ReadCallback(IA syncResult asyncResult)
{
SocketState socketState = (SocketState) asyncResult.Asy ncState;
int bytesRead = 0;
try
{
bytesRead = socketState.Rem oteSocket.EndRe ceive(asyncResu lt);
Debug.WriteLine ("SocketServer. ReadCallback: EndReceive completed");
}
catch (SocketExceptio n se)
{
// Likely the socket timed out.
LogException(se );
_receiveEvent.S et();
return;
}

Debug.WriteLine (String.Format( "SocketServer.R eadCallback: End receive with
{0} bytes", bytesRead));
// Append new data until all data received
if (bytesRead > 0)
{
socketState.Dat aReceived = bytesRead;
socketState.Buf ferUpdate();
sockState.Remot eSocket.BeginRe ceive(socketSta te.ReceiveBuffe r, 0,
SocketState.Buf ferSize, 0, new AsyncCallback(t his.ReadCallbac k),
socketState);
_receiveEvent.S et();
return;
}
// All data received. Handle message
else
{
HandleMessage(s ocketState);
}
_receiveEvent.S et();
}