diff -r 000000000000 -r dfb7c4ff071f datacommsserver/esockserver/test/TE_ESock/EsockTestSection9.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/test/TE_ESock/EsockTestSection9.cpp	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,504 @@
+// Copyright (c) 2001-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:
+// This contains ESock Test cases from section 9
+// 
+//
+
+// EPOC includes
+#include <e32base.h>
+#include <in_sock.h>
+
+// Test system includes
+#include "EsockTestSection9.h"
+
+
+// Test step 9.1
+const TDesC& CEsockTest9_1::GetTestName()
+	{
+	// store the name of this test case
+	_LIT(ret,"Test9.1");
+	
+	return ret;
+	}
+
+CEsockTest9_1::~CEsockTest9_1()
+	{
+	}
+
+enum TVerdict CEsockTest9_1::easyTestStepPreambleL()
+	{
+	if (KErrNone != OpenMinSockets(_L("Test_9.1"),KAfInet, KSockStream, KProtocolInetTcp))
+		{
+		return EFail;
+		}
+	
+	return EPass;
+	}
+
+enum TVerdict CEsockTest9_1::easyTestStepL()
+	{
+	Logger().WriteFormat(_L("TE_ESock: Test 9.1"));
+	
+	// List Route(s)
+	ListRoutes();
+	
+	return EPass;
+	}
+
+
+// Test step 9.2
+const TDesC& CEsockTest9_2::GetTestName()
+	{
+	// store the name of this test case
+	_LIT(ret,"Test9.2");
+	
+	return ret;
+	}
+
+CEsockTest9_2::~CEsockTest9_2()
+	{
+	}
+
+enum TVerdict CEsockTest9_2::easyTestStepPreambleL()
+	{
+	if (KErrNone != OpenMinSockets(_L("Test_9.2"),KAfInet, KSockStream, KProtocolInetTcp))
+		{
+		return EFail;
+		}
+	
+	return EPass;
+	}
+
+enum TVerdict CEsockTest9_2::easyTestStepL()
+	{
+	Logger().WriteFormat(_L("TE_ESock: test 9.2"));
+	TESTL(EPass == TestStepResult());
+	
+	// ipv4
+	// List Route(s)
+	ListRoutes();
+
+	TInt ret = SetRoute(KSoInetAddRoute, IPADDR(10,158,7,52),IPADDR(255,0,0,0),IPADDR(10,158,7,73), IPADDR(127,0,0,1), 0);
+	TESTEL(KErrNone == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	// Delete Route
+	ret = SetRoute(KSoInetDeleteRoute, IPADDR(10,158,7,52),IPADDR(255,0,0,0),IPADDR(10,158,7,73), IPADDR(127,0,0,1), 0);
+	TESTEL(KErrNone == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	return EPass;
+	}
+
+// Test step 9.3
+const TDesC& CEsockTest9_3::GetTestName()
+	{
+	// store the name of this test case
+	_LIT(ret,"Test9.3");
+	
+	return ret;
+	}
+
+CEsockTest9_3::~CEsockTest9_3()
+	{
+	}
+
+enum TVerdict CEsockTest9_3::easyTestStepPreambleL()
+	{
+	if (KErrNone != OpenMinSockets(_L("Test_9.3"),KAfInet, KSockStream, KProtocolInetTcp))
+		{
+		return EFail;
+		}
+	
+	return EPass;
+	}
+
+enum TVerdict CEsockTest9_3::easyTestStepL()
+	{
+	Logger().WriteFormat(_L("TE_ESock: test 9.3"));
+	TESTL(EPass == TestStepResult());
+	
+	// ipv6
+	// List Route(s)
+	ListRoutes();
+	
+	TPckgBuf<TSoInetRouteInfo> opt;
+	opt().iType = ERtUser;
+	opt().iState = ERtReady;
+	opt().iIfAddr.SetFamily(KAFUnspec);
+	opt().iMetric = 1;
+	(TInetAddr::Cast(opt().iIfAddr)).Input(_L("::1"));
+	(TInetAddr::Cast(opt().iGateway)).Input(_L("fe80::dead:beef"));
+	(TInetAddr::Cast(opt().iDstAddr)).Input(_L("2001:618:400:61::dead:fee"));
+	(TInetAddr::Cast(opt().iNetMask)).Input(_L("ffff:ffff:ffff:ffff:ffff:ffff:ffff:ffff"));
+	// Add Route
+	TInt ret = iEsockSuite->GetSocketHandle(1).SetOpt(KSoInetAddRoute, KSolInetRtCtrl, opt);
+	TESTEL(KErrNone == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	// Delete Route
+	ret = iEsockSuite->GetSocketHandle(1).SetOpt(KSoInetDeleteRoute, KSolInetRtCtrl, opt);
+	TESTEL(KErrNone == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	return EPass;
+	}
+
+// Test step 9.4
+const TDesC& CEsockTest9_4::GetTestName()
+	{
+	// store the name of this test case
+	_LIT(ret,"Test9.4");
+	
+	return ret;
+	}
+
+CEsockTest9_4::~CEsockTest9_4()
+	{
+	}
+
+enum TVerdict CEsockTest9_4::easyTestStepPreambleL()
+	{
+	if (KErrNone != OpenMinSockets(_L("Test_9.4"),KAfInet, KSockStream, KProtocolInetTcp))
+		{
+		return EFail;
+		}
+	
+	return EPass;
+	}
+
+enum TVerdict CEsockTest9_4::easyTestStepL()
+	{
+	Logger().WriteFormat(_L("TE_ESock: test 9.4"));
+	TESTL(EPass == TestStepResult());
+	
+	// ipv4
+	// List Route(s)
+	ListRoutes();
+	
+	// Add Route
+	TInt ret = SetRoute(KSoInetAddRoute, IPADDR(10,158,7,52),IPADDR(255,0,0,0),IPADDR(10,158,7,73), IPADDR(127,0,0,1), 0);
+	TESTEL(KErrNone == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	// Change Route
+	ret = SetRoute(KSoInetChangeRoute, IPADDR(10,158,7,52),IPADDR(255,0,0,0),IPADDR(10,158,7,70), IPADDR(127,0,0,1), 0);
+	TESTEL(KErrNotFound == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	return EPass;
+	}
+
+// Test step 9.5
+const TDesC& CEsockTest9_5::GetTestName()
+	{
+	// store the name of this test case
+	_LIT(ret,"Test9.5");
+	
+	return ret;
+	}
+
+CEsockTest9_5::~CEsockTest9_5()
+	{
+	}
+
+enum TVerdict CEsockTest9_5::easyTestStepPreambleL()
+	{
+	if (KErrNone != OpenMinSockets(_L("Test_9.5"),KAfInet, KSockStream, KProtocolInetTcp))
+		{
+		return EFail;
+		}
+	
+	return EPass;
+	}
+
+enum TVerdict CEsockTest9_5::easyTestStepL()
+	{
+	Logger().WriteFormat(_L("TE_ESock: test 9.5"));
+	TESTL(EPass == TestStepResult());
+	
+	// ipv6
+	// List Route(s)
+	ListRoutes();
+	
+	TPckgBuf<TSoInetRouteInfo> opt;
+	opt().iType = ERtUser;
+	opt().iState = ERtReady;
+	opt().iIfAddr.SetFamily(KAFUnspec);
+	opt().iMetric = 1;
+	(TInetAddr::Cast(opt().iIfAddr)).Input(_L("::1"));
+	(TInetAddr::Cast(opt().iGateway)).Input(_L("fe80::dead:beef"));
+	(TInetAddr::Cast(opt().iDstAddr)).Input(_L("2001:618:400:61::dead:fee"));
+	(TInetAddr::Cast(opt().iNetMask)).Input(_L("ffff:ffff:ffff:ffff:ffff:ffff:ffff:ffff"));
+	// Add Route
+	TInt ret = iEsockSuite->GetSocketHandle(1).SetOpt(KSoInetAddRoute, KSolInetRtCtrl, opt);
+	TESTEL(KErrNone == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	(TInetAddr::Cast(opt().iIfAddr)).Input(_L("::1"));
+	(TInetAddr::Cast(opt().iGateway)).Input(_L("ffff::new:beef"));
+	// Change Route
+	ret = iEsockSuite->GetSocketHandle(1).SetOpt(KSoInetChangeRoute, KSolInetRtCtrl, opt);
+	TESTEL(KErrNotFound == ret, ret);
+	
+	// List Route(s)
+	ListRoutes();
+	
+	return EPass;
+	}
+
+
+const TInt KTimerPeriod = 10 * 1000000; // Guard timer period, in microseconds.
+
+CEsockTest9_6::CEsockTest9_6()
+	{
+	iGuardTimer.CreateLocal();	// Set up the timer
+	}
+
+// Test step 9.5
+const TDesC& CEsockTest9_6::GetTestName()
+	{
+	// store the name of this test case
+	_LIT(ret,"Test9.6");
+	
+	return ret;
+	}
+
+CEsockTest9_6::~CEsockTest9_6()
+	{
+	iGuardTimer.Close();		// Cleanup the timer
+	}
+
+/**
+   Create a UDP socket. Perform a zero-length SendTo, then attempt to receive the zero-length datagram.
+
+   @return EPass on success, EFail on failure
+*/
+TVerdict CEsockTest9_6::easyTestStepL()
+	{
+	Logger().WriteFormat(_L("TE_ESock: test 9.6"));
+	
+	TInt cleanupCount = 0;		// Number of items we've put on Cleanup Stack - remember to increment this after every Push operation.
+	
+	RSocket sendSocket;
+
+	CleanupClosePushL( sendSocket );
+	++cleanupCount;
+
+	TSockAddr sendSocketAddress;
+	Logger().WriteFormat(_L("Creating Send Socket"));
+	if( !CreateUdpSocket( sendSocket, sendSocketAddress ) )
+		{
+		CleanupStack::PopAndDestroy( cleanupCount );
+		return EFail;
+		}
+
+
+	RSocket recvSocket;
+
+	CleanupClosePushL( recvSocket );
+	++cleanupCount;
+
+	TSockAddr recvSocketAddress;
+	Logger().WriteFormat(_L("Creating Receive Socket"));
+	if( !CreateUdpSocket( recvSocket, recvSocketAddress ) )
+		{
+		CleanupStack::PopAndDestroy( cleanupCount );
+		return EFail;
+		}
+
+
+
+	HBufC8 *udpWriteBuffer = HBufC8::NewLC( 0 ); // Empty buffer for zero-length write
+	++cleanupCount;
+
+	HBufC8 *udpReadBuffer  = HBufC8::NewMaxLC( 32 ); // Non-Empty buffer for reads - 32 is an unimportant magic number
+	++cleanupCount;
+
+	TPtrC8  ptrWritebuf( udpWriteBuffer->Des() );
+	TPtr8   ptrReadbuf( udpReadBuffer->Des() );
+	TSockAddr toAddress( recvSocketAddress );
+
+	TBool isOk = PerformSend( sendSocket, ptrWritebuf, toAddress );
+	if( isOk )
+		{
+		TSockAddr fromAddress;
+		isOk = PerformRecv( recvSocket, ptrReadbuf, fromAddress );
+		if( isOk )
+			{
+			Logger().WriteFormat(_L("Receieved %d bytes"), udpReadBuffer->Length());
+			if( udpReadBuffer->Length() != 0 )
+				{
+				isOk = EFalse;
+				}
+			}
+		}
+	
+	CleanupStack::PopAndDestroy( cleanupCount );
+
+	return isOk ? EPass : EFail;
+	}
+
+// Work around for timer oddness....
+/**
+   Wait until either a request completes, or the specified period has elapsed
+
+   @param aRequestStatus  Request to wait on
+   @param aPeriod        Timeout in microseconds
+*/
+void CEsockTest9_6::WaitFor( TRequestStatus& aRequestStatus, TInt aPeriod )
+	{
+	// Set up the timer
+	TRequestStatus timerStatus;
+	iGuardTimer.After( timerStatus, aPeriod );
+	// Wait for either the supplied event, or the timer, to complete
+	User::WaitForRequest( aRequestStatus, timerStatus );
+	if( timerStatus == KRequestPending )
+		{
+		// This is lifted from SockBench to solve some apparently
+		// strange behaviour with the timer.
+		
+		// Since we are still waiting for this timer, cancel it and
+		// wait for the request to be flagged.  I believe this is
+		// needed since the kernel may have setup a semaphore on the
+		// 'TimerStatus' Request Status.  The Cancel() will flag the
+		// status change (or maybe the timer will expire anyway) and
+		// if we don't clear it, we may crash later when we return
+		// to the Active Scheduler (since the TRequestStatus and
+		// RTimer won't exist).
+		//
+		iGuardTimer.Cancel();
+		User::WaitForRequest( timerStatus );
+		}
+	iGuardTimer.Cancel();
+	}
+
+
+/**
+   Send data on a socket via SendTo
+
+   @param aSocket  The socket to send the data on
+   @param aDesc    The data to send
+   @param anAddress The address to send to
+   @return ETrue on success, EFalse on failure
+*/
+TBool CEsockTest9_6::PerformSend( RSocket& aSocket, const TDesC8& aDesc, TSockAddr& anAddress )
+	{
+	TRequestStatus socketStatus;
+
+	aSocket.SendTo( aDesc, anAddress, 0, socketStatus );
+	WaitFor( socketStatus, KTimerPeriod );
+
+	Logger().WriteFormat(_L("UDP Send returns %d"), socketStatus.Int() );
+
+	if( socketStatus == KRequestPending )
+		{
+		aSocket.CancelSend();
+		Logger().WriteFormat(_L("Timeout on UDP Send"));
+		User::WaitForRequest( socketStatus );
+		return EFalse;
+		}
+
+	if( socketStatus != KErrNone )
+		{
+		Logger().WriteFormat(_L("UDP Send failed with error %d"), socketStatus.Int() );
+		return EFalse;
+		}
+
+	return ETrue;
+	}
+
+/**
+   Receive data on a socket via RecvFrom
+
+   @param aSocket The socket to recevie data from
+   @param aDesc Descriptor to receive the data into
+   @param anAddress On success, contains the address from which data was received
+   @return ETrue on success, EFalse on failure
+*/
+TBool CEsockTest9_6::PerformRecv( RSocket& aSocket, TDes8& aDesc, TSockAddr& anAddress )
+	{
+	TRequestStatus socketStatus;
+
+	aSocket.RecvFrom( aDesc, anAddress, 0, socketStatus );
+	WaitFor( socketStatus, KTimerPeriod );
+
+	Logger().WriteFormat(_L("UDP Recv returns %d"), socketStatus.Int() );
+
+	if( socketStatus == KRequestPending )
+		{
+		aSocket.CancelRecv();
+		Logger().WriteFormat(_L("Timeout on UDP Recv"));
+		User::WaitForRequest( socketStatus );
+		return EFalse;
+		}
+
+	if( socketStatus != KErrNone )
+		{
+		Logger().WriteFormat(_L("UDP Recv failed with error %d"), socketStatus.Int() );
+		return EFalse;
+		}
+
+	return ETrue;
+	}
+
+/**
+   Create a UDP Socket and bind it to an arbitrary address
+
+   @param aSocket The socket
+   @param aAddress On return, contains the local socket name
+   @return ETrue on success, EFalse otherwise
+*/
+TBool CEsockTest9_6::CreateUdpSocket( RSocket& aSocket, TSockAddr& aAddress )
+	{
+	// Open the socket
+	TInt nRet = aSocket.Open( iEsockSuite->iSocketServer, KAfInet, KSockDatagram, KProtocolInetUdp );
+	if( KErrNone != nRet )
+		{
+		Logger().WriteFormat(_L("Failed to open socket: return value = <%d>"), nRet );
+		return EFalse;
+		}
+
+	// Bind to any address.
+	//TInetAddr myAddress( KInetAddrAny, KInetPortAny );
+	TInetAddr myAddress( KInetAddrLoop, KInetPortAny );
+	nRet = aSocket.Bind( myAddress );
+	if( KErrNone != nRet )
+		{
+		Logger().WriteFormat(_L("Failed to bind socket: return value = <%d>"), nRet );
+		return EFalse;
+		}
+
+	// Retrieve the bound address
+	aSocket.LocalName( aAddress );
+
+	// Happy shiny
+	return ETrue;
+	}
+
+