--- /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;
+ }
+
+