IAsyncResult : how to check a message is completed

[Gian]

Hello, i'm developing a client-server application and now i need to fix my asynchronously receive of messages because sometimes the complete message is not received on a single OnDataReceived call. I've tried for example to send a 18000 bytes long message with a 40000 bytes long receive buffer but there're 2 incoming packets of 13000 and 5000 bytes. My OnDataReceive function is this public void OnDataReceived(IAsyncResult asyn) { try { // SocketPacket is a class with the buffer of packet SocketPacket socketData = (SocketPacket)asyn.AsyncState ; int iRx = 0 ; // Complete the BeginReceive() asynchronous call by EndReceive() method // which will return the number of characters written to the stream // by the client iRx = socketData.m_currentSocket.EndReceive (asyn); if(iRx > 0) { // this get client object/class data (nickname, receive buffer for this client, socket) ClientSocketType client = GetClientSocket(socketData.m_currentSocket); if(client != null) { // create a new receiving buffer for this server/client receive if(client.PacketBuffer == null) client.PacketBuffer = new MemoryStream(); // append received buffers to that buffer BinaryWriter binwrite = new BinaryWriter(client.PacketBuffer); binwrite.Write(socketData.dataBuffer, 0, iRx); // if packets for this message are finished process message // ?!? WORKING ? if(asyn.IsCompleted) { // prepare the stream and send to a parsing function MemoryStream stream = new MemoryStream(client.PacketBuffer.GetBuffer(), 0, client.PacketBuffer.GetBuffer().Length,true, false); ProcessMessage(socketData.m_currentSocket, stream ); // empty client receive buffer client.PacketBuffer = null; } } // Continue the waiting for data on the Socket WaitForData( socketData.m_currentSocket ); } else { ((SocketPacket)asyn.AsyncState).m_currentSocket.Close(); RemoveSocketFromList(((SocketPacket)asyn.AsyncState).m_currentSocket); AddLogMessage("Disconnected user"); } } catch (ArgumentNullException se) { AddLogMessage(se.Message ); } catch (ObjectDisposedException ) { System.Diagnostics.Debugger.Log(0,"1","\nOnDataReceived: Socket has been closed\n"); } catch

[Mike Dimmick]

The TCP stack will not necessarily deliver a whole message like this. You have to be prepared to join message fragments together. You also have to be prepared for multiple messages to be concatenated. For more information, read the Winsock Programmer's FAQ[^]. Stability. What an interesting concept. -- Chris Maunder

[vinu netguy]

Hi mike, Thanks for giving me such a valuable information. Vinu.netguy :-D :-D