C / C++ / MFC

ScotDolan wrote:

Is there any way, i can verify how much space is available in the outgoing write buffer

if( TxQueue.Pop( &temp_packet ) == true )
{ 
   BYTE *pCurSendByte = (BYTE *)&temp_packet;
   int iBytesRemaining = sizeof(temp_packet);
 
   while (iBytesRemaining > 0)
   {
      iResults = send( client_socket, (char *)pCurSendByte, iBytesRemaining, NULL );
      if( iResults != SOCKET_ERROR )
      {
         iBytesRemaining -= iResults;
         if (iBytesRemaining > 0)
         {
            pCurSendByte += iResults;
         }
      }
      else
      {
         int nWSAErrorCode = WSAGetLastError();
         if (nWSAErrorCode != WSAEWOULDBLOCK)
         {
            Error = -1;
            break;
         }
      }
   }
}

ScotDolan wrote:

This all said, I thinking I might have to create two or three worker threads within this socket class I am developing.
One thread to recv packet and place in the safeque.
One Thread to send packet from safeque.
One Thread to check for FD_CLOSE and FD_CONNECTION events.

	<br />
	case LOOP_CLIENT:<br />
			WSAEnumNetworkEvents(client_socket, g_hClientEvent, &NetworkClientEvents);<br />
			if(  NetworkClientEvents.lNetworkEvents == FD_CLOSE)<br />
			{		<br />
				printf("Client Socket Closed Message: \n\r"); <br />
				WSACloseEvent(g_hClientEvent);<br />
				closesocket(client_socket);<br />
				WSACleanup();<br />
				state = CONNECT_CLIENT;<br />
			}<br />
<br />
			if(  NetworkClientEvents.lNetworkEvents == FD_CONNECT)<br />
			{<br />
				if (0 != NetworkClientEvents.iErrorCode[FD_CONNECT_BIT])   {<br />
					printf("Client Connection Failed: \n\r");  <br />
					state = CONNECT_CLIENT;<br />
				}else{ <br />
				   printf("Client Connected Message: \n\r");<br />
				    state = LOOP_CLIENT;<br />
				}<br />
			}<br />
<br />
<br />
<br />
			//  Transmitts Packets Across the Newtork<br />
			if( txbytesremaining == 0 )<br />
			{<br />
				if( TxQueue.Pop( &temp_txpacket) == true)<br />
				{  <br />
					temp_txbuffer = (char *)&temp_txpacket;   <br />
					int txbytesremaining = sizeof(temp_txbuffer); <br />
					iResults = send( client_socket, (char *)temp_txbuffer, txbytesremaining, NULL );   <br />
					if( iResults != SOCKET_ERROR )  <br />
					{    <br />
						txbytesremaining -= iResults;<br />
						if (txbytesremaining > 0)  <br />
							temp_txbuffer += iResults; //Increments the Byte Pointer     <br />
					}else{ <br />
						//ERROR <br />
						break; <br />
					}   <br />
				}<br />
			}else{<br />
				iResults = send( client_socket, (char *)temp_txbuffer, txbytesremaining, NULL );   <br />
				if( iResults != SOCKET_ERROR )  <br />
				{    <br />
					txbytesremaining -= iResults;<br />
					if (txbytesremaining > 0)<br />
						temp_txbuffer += iResults; //Increments the Byte Pointer      <br />
				}else{<br />
					break;//ERRROR<br />
				}<br />
			}<br />
<br />
<br />
<br />
			//  Receive Packets Across the Newtork<br />
			if( rxbytesremaining == 0 )<br />
				rxbytesremaining = sizeof(temp_rxbuffer);<br />
<br />
			iResults = recv( client_socket, (char *)temp_rxbuffer, rxbytesremaining, NULL );  <br />
			switch( iResults )<br />
  			{<br />
				case 0:<br />
					break;<br />
				case SOCKET_ERROR:<br />
					break;<br />
				default:<br />
					rxbytesremaining -= iResults;<br />
					temp_rxbuffer += iResults; <br />
					if(  rxbytesremaining == 0 )<br />
					{<br />
						temp_rxpacket = (INDEPENDENCER_PKT *)temp_rxbuffer;// Need a copy here<br />
						if( temp_rxpacket.verifyCRC() )<br />
						{<br />
							m_TcpClientRxPktCount++;<br />
							RxQueue.Push( temp_rxpacket );<br />
						}else{<br />
							m_TcpClientRxPktCrcErrCount++;<br />
						}<br />
					}<br />
					break;<br />
			}//switch<br />
<br />
			break;//LOOP_CLIENT

ScotDolan wrote:

You basicly wait for events Once you get a read event you start a thread to handle that event and read the fifo. But, before you start that thread you make sure the past current read thead has terminate.

// Socket I/O thread proc pseudocode
 
while (1)
{
   WaitMultipleObjects() on terminateevent, datatosendevent, socketevent(FD_READ/FD_CLOSE)
 
   if (terminateevent)
      break;
 
   if (socketevent)
   {
      if (FD_CLOSE event)
      {
         notify app that remote socket closed
         break;
      }
      else //must be FD_READ
      {
         loop calling recv() (queueing complete packets)
            until WSAWOULDBLOCK error
         Notify recv handler thread using an event object when received data available
      }
   }
 
   if (datatosendevent)
   {
      dequeue a send packet
      loop calling send() 
         until WSAWOULDBLOCK error or no more queued send data
      if WSAWOULDBLOCK and still data on send queue then set datatosendevent
   }
}
 
return (exit thread)

hamidreza_buddy wrote:

my program is in c#.

YUNAJAPAN wrote:

However the effect is not so good that you can see the right view flash because MFC modified the size of right view first then you alter it back to the original size in turn.