diff -r 000000000000 -r dfb7c4ff071f datacommsserver/esockserver/test/TE_IPCTest/Test01IPCStreamConnection.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/test/TE_IPCTest/Test01IPCStreamConnection.cpp	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,137 @@
+// 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 01
+// 
+//
+
+// EPOC includes
+#include <e32base.h>
+
+// Test system includes
+
+#include "Test01IPCStreamConnection.h"
+
+const TDesC& CTest01IPCStreamConnection::GetTestName()
+	{
+	_LIT(ret,"IPCTest01");
+	return ret;
+	}
+
+enum TVerdict CTest01IPCStreamConnection::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 Open server socket, set port  & listen:");
+	Logger().Write(aLog01);
+	RSocket aServerSock;
+	CleanupClosePushL(aServerSock);
+	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);
+		}
+	
+	//-------------------substep 02-----------------------------	
+	_LIT(aLog02,"02 Create blank socket and marry it (with accept) to the server socket:");
+	Logger().Write(aLog02);
+	RSocket aNewConn;
+	CleanupClosePushL(aNewConn);
+	if ( (err=aNewConn.Open(ss)) != KErrNone)
+		{
+		_LIT(aLog,"Error:Could not open blank socket. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+
+	TRequestStatus aAcceptStat;
+	aServerSock.Accept(aNewConn, aAcceptStat);
+	
+	//-------------------substep 03-----------------------------	
+	_LIT(aLog03,"03 Create client socket and connect it to the server");
+	Logger().Write(aLog03);
+	RSocket aClientSock;
+	CleanupClosePushL(aClientSock);
+	if ( (err=aClientSock.Open(ss, iProt)) != KErrNone)
+		{
+		_LIT(aLog,"Error:Could not open client socket. err = %d");
+		Logger().WriteFormat(aLog, err);
+		User::Leave(EFail);
+		}
+
+	TSockAddr aAddr;
+	aAddr.SetPort(1);
+	TRequestStatus aConnectStat;
+	aClientSock.Connect(aAddr, aConnectStat);
+	
+	//-------------------substep 04-----------------------------	
+	_LIT(aLog04,"04 Check the status of the connection at the both ends:");
+	Logger().Write(aLog04);
+	User::WaitForRequest(aConnectStat);
+	User::WaitForRequest(aAcceptStat);
+	TVerdict verdict = EPass;
+
+	err = aConnectStat.Int();
+    if (err != KErrNone)
+		{
+		_LIT(aLog,"Error:Client socket not connected. err = %d");
+		Logger().WriteFormat(aLog, err);
+		verdict = EFail;
+		}
+    
+    err = aAcceptStat.Int();
+    if (err != KErrNone)
+		{
+		_LIT(aLog,"Error:Connection not accepted on server side. err = %d");
+		Logger().WriteFormat(aLog, err);
+		verdict = EFail;
+		}
+    
+    if (verdict == EFail)
+    	User::Leave(EFail);
+	
+	//-------------------substep 05-----------------------------	
+	_LIT(aLog05,"05 Close all sockets.  Close socket server:"); Logger().WriteFormat(aLog05);
+	CleanupStack::PopAndDestroy(4, &ss);
+	return verdict;
+	}
+	
+