diff -r 000000000000 -r 3da2a79470a7 testtoolsconn/stat/desktop/source/common/transport/src/statsocket.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/testtoolsconn/stat/desktop/source/common/transport/src/statsocket.cpp	Mon Mar 08 15:04:18 2010 +0800
@@ -0,0 +1,280 @@
+/*
+* 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:  
+*
+*/
+
+
+
+
+#include "stdafx.h"
+#include "statsocket.h"
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+CSTATSocket::CSTATSocket()
+: m_pSocket((CClientSocket*)NULL),
+  m_pFile((CSocketFile*)NULL),
+  m_pArchiveIn((CArchive*)NULL),
+  m_pArchiveOut((CArchive*)NULL),
+  m_pListen((CClientSocket*)NULL),
+  IsRecvData(false),
+  ID(0), Length(0), pData(NULL)
+{
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+CSTATSocket::~CSTATSocket()
+{
+	Disconnect();
+	Release();
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+int CSTATSocket::Initialise(void)
+{
+	return ITS_OK;
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+int CSTATSocket::Connect(const char *pAddress)
+{
+	m_pSocket = new CClientSocket(this);
+
+	if (m_pSocket)
+	{
+		// if address supplied then we are attempting a connection
+		// else we are listening for a connection
+		if (pAddress && (*pAddress))
+		{
+			if (!m_pSocket->Create())
+			{
+				Disconnect();
+				return GENERAL_FAILURE;
+			}
+
+			char *p = strrchr(pAddress, ':');
+			int iPort = 700;
+			if (p)
+			{
+				(*p) = (char)0;
+
+				p++;
+				if (p && *p)
+					iPort = atoi(p);
+			}
+			int iRetry = 0;
+			while (!m_pSocket->Connect(pAddress, iPort))
+			{
+				iRetry++;
+				if (iRetry > 5)
+				{
+					Disconnect();
+					return E_TOOMANYERRORS;
+				}
+
+				Sleep(250);
+			}
+		}
+		else
+		{
+			if (!m_pListen->Accept(*m_pSocket))
+			{
+				Disconnect();
+				return E_CONNECTIONFAILED;
+			}
+
+			// don't need this object anymore
+			BYTE Buffer[50];
+			m_pListen->ShutDown();
+
+			while(m_pListen->Receive(Buffer,50) > 0);
+
+			delete m_pListen;
+			m_pListen = NULL;
+		}
+
+		m_pFile = new CSocketFile(m_pSocket);
+		m_pArchiveIn = new CArchive(m_pFile,CArchive::load);
+		m_pArchiveOut = new CArchive(m_pFile,CArchive::store);
+
+		// send acknowledgement message
+		Send('A', "Connected", 9);
+	}
+	else
+		return E_OUTOFMEM;
+
+	return ITS_OK;
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+int CSTATSocket::Listen(const char *pPort)
+{
+	m_pListen = new CClientSocket(this);
+
+	if (m_pListen)
+	{
+		if (!m_pListen->Create(atoi(pPort)))
+			return E_CONNECTIONFAILED;
+
+		if (!m_pListen->Listen())
+			return E_CONNECTIONFAILED;
+	}
+	else
+		return E_OUTOFMEM;
+
+	return ITS_OK;
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+int CSTATSocket::Send(const char cIdentifier, const char *pData, const unsigned long ulLength)
+{
+	if (m_pArchiveOut != NULL)
+	{
+		TRY
+		{
+			(*m_pArchiveOut) << cIdentifier;
+			(*m_pArchiveOut) << ulLength;
+
+			if (ulLength)
+				m_pArchiveOut->Write(pData, ulLength);
+
+			m_pArchiveOut->Flush();
+		}
+		CATCH(CFileException, e)
+		{
+			Disconnect();
+			return E_WRITEFAILED;
+		}
+		END_CATCH
+	}
+
+	return ITS_OK;
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// External: passed received data back to calling function
+int CSTATSocket::Receive(char *cIdentifier, char **ppData, unsigned long *pLength)
+{
+	int ret = NO_DATA_AT_PORT;
+
+	if (IsRecvData)
+	{
+		(*cIdentifier) = ID;
+		(*pLength) = Length;
+		(*ppData) = pData;
+
+		IsRecvData = false;
+		ret = ITS_OK;
+	}
+
+	return ret;
+}
+	
+	
+////////////////////////////////////////////////////////////////////////////////////////
+// Internal: Receives data from the socket
+int CSTATSocket::ReceiveData()
+{
+	if (!IsRecvData)
+	{
+		unsigned long ActualRead = 0;
+
+		(*m_pArchiveIn) >> ID;
+		(*m_pArchiveIn) >> Length;
+
+		if(pData)
+		{
+			delete [] pData;
+		}
+
+		if (Length)
+		{
+			pData = new char [Length + 1];
+			if (pData)
+			{
+				ActualRead = m_pArchiveIn->Read(pData, Length);
+				*(pData + Length) = (char)0;
+			}
+			else
+				Length = 0;
+		}
+
+		IsRecvData = true;
+		return true;
+	}
+
+	return false;
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+int CSTATSocket::Disconnect(void)
+{
+	if (m_pArchiveOut)
+	{
+		delete m_pArchiveOut;
+		m_pArchiveOut = NULL;
+	}
+
+	if (m_pArchiveIn)
+	{
+		delete m_pArchiveIn;
+		m_pArchiveIn = NULL;
+	}
+
+	if (m_pFile)
+	{
+		delete m_pFile;
+		m_pFile = NULL;
+	}
+
+	if (m_pSocket)
+	{
+		BYTE Buffer[50];
+		m_pSocket->ShutDown();
+
+		while(m_pSocket->Receive(Buffer,50) > 0);
+
+		delete m_pSocket;
+		m_pSocket = NULL;
+	}
+
+	return ITS_OK;
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+// 
+int CSTATSocket::Release(void)
+{
+	return ITS_OK;
+}
+
+
+////////////////////////////////////////////////////////////////////////////////////////
+//	PRIVATE FUNCTIONS
+////////////////////////////////////////////////////////////////////////////////////////