diff -r 000000000000 -r dfb7c4ff071f datacommsserver/esockserver/test/TE_IPCTest/Test02IPCSimpleDataTransfer.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/test/TE_IPCTest/Test02IPCSimpleDataTransfer.cpp	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,249 @@
+// Copyright (c) 2004-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:
+// Contains IPC Test 02
+// 
+//
+
+// EPOC includes
+#include <e32base.h>
+
+// Test system includes
+#include "Test02IPCSimpleDataTransfer.h"
+
+
+const TDesC& CTest02IPCSimpleDataTransfer::GetTestName()
+	{
+	_LIT(ret,"IPCTest02");
+	return ret;
+	}
+
+enum TVerdict CTest02IPCSimpleDataTransfer::InternalDoTestStepL(void)
+	{
+	
+	//-------------------substep 00-----------------------------	
+	_LIT(aLog00,"00 Open socket server:");Logger().Write(aLog00);
+	
+	TInt err;
+	RSocketServ ss;
+	CleanupClosePushL(ss);
+	if ( (err = OptimalConnect(ss)) != KErrNone )
+		{
+		Logger().WriteFormat(_L("Connecting to socket server failed with %d"), err);
+		User::Leave(EFail);
+		}
+	
+	//-------------------substep 01-----------------------------	
+	_LIT(aLog01,"01 Create a single client/server connection:");
+	Logger().Write(aLog01);
+
+	RSocket aClientSock, aNewConn, aServerSock;
+	CleanupClosePushL(aNewConn);
+	CleanupClosePushL(aClientSock);
+	CleanupClosePushL(aServerSock);
+	
+	TRequestStatus aAcceptStat, aConnectStat;
+	TSockAddr aAddr;
+	
+	if ( (err=aServerSock.Open(ss, iProt)) != KErrNone)
+		{
+		_LIT(aLog,"Error:Could not open server socket. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	if ( (err=aServerSock.SetLocalPort(1)) != KErrNone)
+		{
+		_LIT(aLog,"Error:Could not set port. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	if ( (err=aServerSock.Listen(1)) != KErrNone)
+		{
+		_LIT(aLog,"Error:Could not set up socket to listen. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	
+	if ( (err=aNewConn.Open(ss)) != KErrNone)
+		{
+		_LIT(aLog,"Error:Could not open blank socket. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	aServerSock.Accept(aNewConn, aAcceptStat);
+	
+	if ( (err=aClientSock.Open(ss, iProt)) != KErrNone)
+		{
+		_LIT(aLog,"Error:Could not open client socket. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	
+	aAddr.SetPort(1);
+	aClientSock.Connect(aAddr, aConnectStat);
+	
+	User::WaitForRequest(aConnectStat);
+	User::WaitForRequest(aAcceptStat);
+	TVerdict verdict = EPass;
+
+	err = aConnectStat.Int();
+    if (aConnectStat != KErrNone)
+		{
+		_LIT(aLog,"Error:Client socket not connected. err = %d");
+		Logger().WriteFormat(aLog, err);
+		verdict = EFail;
+		}
+    
+    err = aAcceptStat.Int();
+    if (aAcceptStat != KErrNone)
+		{
+		_LIT(aLog,"Error:Connection not accepted on server side. err = %d");
+		Logger().WriteFormat(aLog, err);
+		verdict = EFail;
+		}
+    
+    if (verdict == EFail)
+    	User::Leave(EFail);
+	
+    CleanupStack::PopAndDestroy(&aServerSock);
+	
+	//-------------------substep 02-----------------------------	
+	_LIT(aLog02,"02 Send 0x100 bytes to the client. Check the content on arrival:");
+	Logger().Write(aLog02);
+	
+	TBuf8<0x100>* aOut, *aIn;
+	CleanupStack::PushL( aOut = new (ELeave) TBuf8<0x100>);
+	CleanupStack::PushL( aIn  = new (ELeave) TBuf8<0x100>);
+	aOut->SetMax();
+	aOut->Fill('a');
+	aIn->SetMax();
+	aIn->Fill('b');
+	
+	TRequestStatus aWriteStat, aReadStat;
+	aClientSock.Read(*aIn, aReadStat);
+	aNewConn.Write(*aOut, aWriteStat);
+	
+	User::WaitForRequest(aWriteStat);
+	err = aWriteStat.Int();
+    if (err != KErrNone)
+		{
+		_LIT(aLog,"Error:Failed to write. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+
+    User::WaitForRequest(aReadStat);
+    err = aReadStat.Int();
+    if (err != KErrNone)
+		{
+		_LIT(aLog,"Error:Failed to read. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+    
+	if (aIn->Compare(*aOut))
+		{
+		_LIT(aLog,"Error:Data received on clent side corrupted. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	
+	//-------------------substep 03-----------------------------	
+	_LIT(aLog03_1,"03 Send 0x100 bytes to the client partially (a byte after byte). Then ...");
+	Logger().Write(aLog03_1);
+	_LIT(aLog03_2,"   ...receive them on client side and check the content.");
+	Logger().Write(aLog03_2);
+
+	TInt i;
+	aIn->Fill('b');
+	aClientSock.Read(*aIn, aReadStat);
+	
+	aOut->SetLength(1);
+	for (i=0;i<0x100;i++)
+		{
+		aNewConn.Write(*aOut, aWriteStat);
+		User::WaitForRequest(aWriteStat);
+		err = aWriteStat.Int();
+		if (err != KErrNone)
+			{
+			_LIT(aLog,"Error:Failed to write. err = %d");
+			Logger().WriteFormat(aLog, err);
+			User::Leave(EFail);
+			}
+		}
+	
+	User::WaitForRequest(aReadStat);
+	err = aReadStat.Int();
+    if (err != KErrNone)
+		{
+		_LIT(aLog,"Error:Failed to read. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	
+	aOut->SetMax();
+	if (aIn->Compare(*aOut))
+		{
+		_LIT(aLog,"Error:Data received on clent side corrupted. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	
+	//-------------------substep 04-----------------------------	
+	_LIT(aLog04_1,"04 Send 0x100 bytes to the server. Then...");
+	Logger().Write(aLog04_1);
+	_LIT(aLog04_2,"   ...receive them partially(byte after byte) on the server side and check the content.");
+	Logger().Write(aLog04_2);
+	
+	aIn->Fill('b');
+	aClientSock.Write(*aOut, aWriteStat);
+	
+	User::WaitForRequest(aWriteStat);
+	err = aWriteStat.Int();
+	if (err != KErrNone)
+		{
+		_LIT(aLog,"Error:Failed to write. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	
+	TBuf8<0x01> aInSmall;
+	for (i=0;i<0x100;i++)
+		{
+		aNewConn.Read(aInSmall, aReadStat);
+		User::WaitForRequest(aReadStat);
+		err = aReadStat.Int();
+		if (err != KErrNone)
+			{
+			_LIT(aLog,"Error:Failed to read. err = %d");
+			Logger().WriteFormat(aLog, err);
+			User::Leave(EFail);
+			}
+		(*aIn)[i] = aInSmall[0];
+		}
+	
+	if (aIn->Compare(*aOut))
+		{
+		_LIT(aLog,"Error:Data received on clent side corrupted. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+	
+	//-------------------substep 05-----------------------------	
+	_LIT(aLog05,"05 Cleanup stack. Close all sockets.  Close socket server");
+	Logger().Write(aLog05);
+    CleanupStack::PopAndDestroy(5, &ss);
+	return EPass;
+	}
+	
+