C / C++ / MFC

BuckBrown wrote:

Let me say that I am NOT a Windows programmer

BuckBrown wrote:

Everthing I do in Windows needs some information that I dont have access to!

Obliterator wrote:

You would have thought the developers of Bluetooth could have sat at a table and agreed some basic common API for the software side of things like they did with the hardware side, but apparently not!

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)