C / C++ / MFC

UINT SendProc( LPVOID pParam )<br />
{<br />
   CSerial* pSerial = (CSerial*)pParam;<br />
   pParam->SendFunc();<br />
}<br />
<br />
void CSerial::Start()<br />
{<br />
...<br />
...<br />
AfxBeginThread(SendProc,(LPVOID)this,....);<br />
}

class SERIAL<br />
{<br />
  ...<br />
protected:<br />
  // Declaration of the two Threadfunctions<br />
  static UINT SendQueueThread(LPVOID x);      // Send Thread<br />
  static UINT PortReadThread(LPVOID x);       // Receive Thread<br />
<br />
  // <br />
  CWinThread*	m_pPortReadThread;<br />
  CWinThread*	m_pSendQueueThread;<br />
<br />
public:<br />
  bool PortInitialize(...);  // Initialization function<br />
  HANDLE hComPort;   // Handle to the serial interface<br />
  int send(BYTE IDByte,unsigned char* pFirstByte,int len);<br />
<br />
  ...<br />
};

bool SERIAL::PortInitialize(...)<br />
{<br />
  ...<br />
  hComPort=CreateFile ( portName,        // e.g. "COM1:"<br />
                        GENERIC_READ | GENERIC_WRITE,	// read/write mode<br />
			0,				// share mode<br />
			NULL,	                	// security attribute<br />
			OPEN_EXISTING,			// How to open serial port<br />
		        0,				// Port attributes<br />
			NULL );				// to copy<br />
	<br />
<br />
  if(hComPort==INVALID_HANDLE_VALUE)<br />
  {<br />
     ...<br />
     return false;<br />
  }	<br />
<br />
  // now doing all the stuff to initialize the interface<br />
<br />
  GetCommState(hComPort,&PortDCB);<br />
  ...<br />
  SetCommState(hComPort,&PortDCB);<br />
<br />
  GetCommTimeouts(hComPort,&CommTimeouts);<br />
  ...<br />
  SetCommTimeouts(hComPort,&CommTimeouts);<br />
<br />
  EscapeCommFunction(hComPort,SETDTR); <br />
  EscapeCommFunction(hComPort,SETRTS); <br />
<br />
  // Createing the sendthread<br />
  m_pSendQueueThread = AfxBeginThread( SendQueueThread, this );<br />
  if( m_pSendQueueThread == (CWinThread*)0 )<br />
  {<br />
     displayWindowsError( "SERIAL::PortInitialize(...) Error starting SendQueueThread." );<br />
     return( false );<br />
  }<br />
  else<br />
  {	<br />
     m_pSendQueueThread->SetThreadPriority(THREAD_PRIORITY_ABOVE_NORMAL );<br />
  }<br />
<br />
  // the PortReadThread is started in the same way<br />
  ...<br />
}  // end bool SERIAL :: PortInitialize(...)

UINT SERIAL :: SendQueueThread(LPVOID lpvoid)<br />
{<br />
  ...<br />
  SERIAL *pSerial=(SERIAL*) lpvoid;<br />
  BYTE ClassID,CommandID;<br />
  int len;<br />
  unsigned char *data;<br />
  ...<br />
  // pSerial->m_pMessage contains the data to send<br />
  ClassID=pSerial->m_pMessage->GetClassID();<br />
  CommandID=pSerial->m_pMessage->GetCommandID();<br />
  len=pSerial->m_pMessage->GetMessageLen();<br />
  data=pSerial->m_pMessage->GetMessageString();<br />
  test=pSerial->send(CommandID,data,len);<br />
  <br />
  ...<br />
}

int SERIAL::send(BYTE IDByte,unsigned char*  pFirstByte, int len)<br />
{<br />
  ...<br />
<br />
  // only test code<br />
  DWORD dwNumBytesWritten;<br />
  char* buffer;<br />
  buffer = new char[100];<br />
  for( int i = 0; i < 99; i++ )<br />
	buffer[i] = i + 48;<br />
  buffer[99] = 0;<br />
<br />
  try<br />
  {<br />
     DWORD strLen = strlen(buffer);<br />
     WriteFile(hComPort,	//port handle<br />
		(void*)buffer,  //Pointer to the date to write<br />
		(DWORD)strlen( buffer ),	//Number of bytes to write<br />
		&dwNumBytesWritten,		//Number of written bytes<br />
		NULL);				//		<br />
  }<br />
  catch ( CException *e )<br />
  {<br />
     ...<br />
  }<br />
<br />
  delete [] buffer;<br />
<br />
  ...<br />
  }  // end int SERIAL::send(BYTE IDByte,unsigned char*  pFirstByte, int len)

*x = *x ^ *y ^ *x<br />
*y = *x ^ *y ^ *y

*x = *y<br />
*y = *x

void inplace_swap(int *x, int *y)<br />
{<br />
	 *x = *x ^ *y; /* x = x + y */<br />
	 *y = *x ^ *y; /* y = x - y */<br />
	 *x = *x ^ *y; /* x = x - y */<br />
}

void inplace_swap(int* pX, int *pY)
{
    // validate pointers here

    *x = *x + *y;
    *y = *x - *y;
}

void inplace_swap(int *x, int *y) {
    int tmp = *x;
    *x = *y;
    *y = tmp;
}