--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/testexecmgmt/ucc/Source/SerialTcpRelay/CSerialPort.cpp	Mon Mar 08 15:04:18 2010 +0800
@@ -0,0 +1,237 @@
+/*
+* Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description:  
+* CSerialPort -- encapsulates the details of using the serial port as 
+* a communications channel
+* System Includes
+*
+*/
+
+
+
+#include <stdio.h>
+#include <assert.h>
+
+/*********************************************************************
+ *
+ * Local Includes
+ *
+ ********************************************************************/
+#include "CSerialPort.h"
+
+
+/*********************************************************************
+ *
+ * Definitions
+ *
+ ********************************************************************/
+#define READ_TIMEOUT	(1000)
+
+
+/*********************************************************************
+ *
+ * Construction
+ *
+ ********************************************************************/
+CSerialPort::CSerialPort()
+{
+	iComPort = INVALID_HANDLE_VALUE;
+	iMutex =  CreateMutex( NULL, false, NULL );
+	assert (iMutex != NULL);
+}
+
+
+CSerialPort::~CSerialPort()
+{
+	assert( iComPort == INVALID_HANDLE_VALUE );
+	CloseHandle( iMutex );
+	iMutex = NULL;
+}
+
+
+/*********************************************************************
+ *
+ * OpenComPort() -- open a com port, set the timeouts, set the config
+ *
+ ********************************************************************/
+int CSerialPort::OpenPort( char *aComPort )
+{
+	int err;
+
+	// Open the COM Port
+	iComPort = CreateFile( aComPort, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_FLAG_WRITE_THROUGH, NULL );
+	if( iComPort == INVALID_HANDLE_VALUE ) {
+		err = GetLastError();
+		return err;
+	}
+
+	// Set the timeouts (see msdn for the meaning of these carefully chosen values)
+	COMMTIMEOUTS CommTimeOuts;
+	CommTimeOuts.ReadIntervalTimeout = MAXDWORD;
+	CommTimeOuts.ReadTotalTimeoutMultiplier = MAXDWORD;
+    CommTimeOuts.ReadTotalTimeoutConstant = READ_TIMEOUT;
+	CommTimeOuts.WriteTotalTimeoutMultiplier = 0;
+	CommTimeOuts.WriteTotalTimeoutConstant = 0;
+	err = SetCommTimeouts( iComPort, &CommTimeOuts );
+	if( err == 0 ) {
+		err = GetLastError();
+		CloseHandle( iComPort );
+		iComPort = INVALID_HANDLE_VALUE;
+		return err;
+	}
+
+	// Configure the COM port - NO FLOW CONTROL
+	DCB dcb;
+	GetCommState(iComPort, &dcb);
+	dcb.DCBlength			= sizeof(dcb); 
+	dcb.BaudRate			= CBR_115200;
+//	dcb.fBinary				= TRUE;
+	dcb.fBinary				= FALSE;
+	dcb.fParity				= NOPARITY;
+	dcb.fOutxCtsFlow		= TRUE;
+	dcb.fOutxDsrFlow		= FALSE;
+	dcb.fDtrControl			= DTR_CONTROL_ENABLE;	
+	dcb.fDsrSensitivity		= FALSE;
+	dcb.fTXContinueOnXoff	= TRUE;
+	dcb.fOutX				= FALSE;
+	dcb.fInX				= FALSE;
+	dcb.fErrorChar			= FALSE;
+	dcb.fNull				= FALSE;
+//	dcb.fRtsControl			= RTS_CONTROL_HANDSHAKE;
+	dcb.fRtsControl			= RTS_CONTROL_ENABLE;
+	dcb.fAbortOnError		= TRUE;
+	dcb.XonLim				= 100;
+	dcb.XoffLim				= 100;
+	dcb.ByteSize			= 8;
+	dcb.Parity				= NOPARITY;
+	dcb.StopBits			= ONESTOPBIT;
+	dcb.XonChar				= 17;
+	dcb.XoffChar			= 19;
+	err = SetCommState( iComPort, &dcb );	
+	if( err == 0 ) {
+		err = GetLastError();
+		CloseHandle( iComPort );
+		iComPort = INVALID_HANDLE_VALUE;
+		return err;
+	}
+
+	// raise RTS and DTR so the other end won't block (it can use whatever hw flow control it wants)
+	err = EscapeCommFunction( iComPort, SETDTR );
+	assert( err != 0 );
+	err = EscapeCommFunction( iComPort, SETRTS );
+	assert( err != 0 );
+
+	// Success
+	return 0;
+}
+
+
+/*********************************************************************
+ *
+ * CloseComPort() -- close an open com port.
+ *
+ ********************************************************************/
+void CSerialPort::ClosePort()
+{
+	// if the port isn't open then just return
+	if( iComPort == INVALID_HANDLE_VALUE ) 
+		return;
+	
+	// close the port
+	CloseHandle( iComPort );
+	iComPort = INVALID_HANDLE_VALUE;
+}
+
+
+/*********************************************************************
+ *
+ *  ReceiveBytes() -- read specified number of bytes from the comport
+ *
+ ********************************************************************/
+int CSerialPort::ReceiveBytes( char* aBuff, int *aSize )
+{
+	int err, mutex_err;
+	int original_size;
+	unsigned long iBytesRead;
+
+	// check the state and the params
+	assert( iComPort != INVALID_HANDLE_VALUE );
+	assert( aBuff != NULL );
+	assert( aSize != NULL );
+
+	// acquire the port mutex
+	mutex_err = WaitForSingleObject( iMutex, INFINITE );
+	assert( mutex_err == WAIT_OBJECT_0 );
+
+	// receive bytes
+	original_size = *aSize;
+	err = ReadFile( iComPort, aBuff, *aSize, &iBytesRead, NULL );
+
+	// give the mutex back 
+	mutex_err = ReleaseMutex( iMutex );
+	assert( mutex_err != 0 );
+
+	// set aSize to the number actually read
+	*aSize = iBytesRead;
+
+	// check for errors
+	if( err == 0 )  {
+		err = GetLastError();
+		return err;
+	}
+
+	// done
+	return 0;
+}
+
+
+/*********************************************************************
+ *
+ *  SendBytes() -- write the specified number of bytes to the COMport
+ *
+ ********************************************************************/
+int CSerialPort::SendBytes( char *aBuff, int *aSize )
+{
+	int err, mutex_err;
+	DWORD dwModemStatus, dwBytes = 0;
+
+	// check state and params
+	assert( iComPort != INVALID_HANDLE_VALUE );
+	assert( aBuff != NULL );
+	assert( aSize != NULL );
+
+	// acquire the port mutex
+	mutex_err = WaitForSingleObject(iMutex, INFINITE);
+	assert( mutex_err == WAIT_OBJECT_0 );
+
+	// write bytes to the port
+	err = GetCommModemStatus( iComPort, &dwModemStatus );
+	err = WriteFile( iComPort, (LPVOID)aBuff, *aSize, &dwBytes, NULL );
+
+	// give the mutex back 
+	mutex_err = ReleaseMutex( iMutex );
+	assert( mutex_err != 0 );
+
+	// set aSize to the number actually written
+	*aSize = dwBytes;
+
+	// check for errors
+	if( err == 0 ) {
+		err = GetLastError();
+		return err;
+	}
+	
+	// done	
+	return 0;	
+}