// 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 4

// 

//

// EPOC includes

#include <e32base.h>

#include <in_sock.h>

// Test system includes

#include "EsockTestSection4.h"

// Test step 4.1

const TDesC& CEsockTest4_1::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test4.1");

	return ret;

	}

CEsockTest4_1::~CEsockTest4_1()

	{

	}

enum TVerdict CEsockTest4_1::easyTestStepPreambleL()

	{

	if (iEsockSuite->GetSocketListCount() > 1)

		{

		CloseSockets();

		}

	if (iEsockSuite->GetSocketListCount() < 1)

		{

		const TPtrC &sectName = SectionName(_L("Test_4.1"));

		// get size of listening queue

		if (!GetIntFromConfig(sectName, _L("qSize"), iSize))

			{

			return EFail;

			}

		// get local ip address

		TInetAddr addrLocal;

		if (!GetIpAddressFromConfig(sectName, _L("ipAddressLocal"), addrLocal))

			{

			return EFail;

			}

		// get remote ip address

		if (!GetIpAddressFromConfig(sectName, _L("ipAddressRemote"), iAddrRemote))

			{

			return EFail;

			}

		// get port number

		if (!GetIntFromConfig(sectName, _L("port"), iPort))

			{

			return EFail;

			}

		// set port number

		iAddrRemote.SetPort(iPort);

		// open socket and listen for connect requests

		TInt nRet = OpenListeningSocketL(addrLocal, iSockIndex, iPort, iSize);

		if (KErrNone != nRet)

			{

			if (KErrServerTerminated == nRet)

				{

				User::Leave(EFail);

				}

			return EFail;

			}

		}

	return EPass;

	}

enum TVerdict CEsockTest4_1::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	// open <nSize> active sockets

	TInt sockIndexIgnore;  // socket index - returned value we can ignore

	for (TInt n = 0; n < iSize; n++)

		{

		TESTL(KErrNone == OpenActiveSocketL(iAddrRemote, sockIndexIgnore, iPort));

		}

	// open another active socket

	RSocket sock1;

	CleanupClosePushL(sock1);

	TInt nRet = sock1.Open(iEsockSuite->iSocketServer, KAfInet,KSockStream, KProtocolInetTcp);

	TESTEL(KErrNone == nRet, nRet);

	// add socket to list

	sockIndexIgnore=iEsockSuite->AddSocketToListL(sock1);

	CleanupStack::Pop();

	// make connect request

	TRequestStatus stat;

	sock1.Connect(iAddrRemote, stat);

	User::WaitForRequest(stat);

	nRet = stat.Int();

	TESTEL(KErrTimedOut == nRet, nRet);

	// accept one of the outstanding requests

	TESTL(KErrNone == AcceptConnectionL(sockIndexIgnore, iSockIndex));

	// make another connect request

	TESTL(KErrNone == OpenActiveSocketL(iAddrRemote, sockIndexIgnore, iPort));

	// accept one of the outstanding requests

	TESTL(KErrNone == AcceptConnectionL(sockIndexIgnore, iSockIndex));

	return EPass;

	}

// Test step 4.2

const TDesC& CEsockTest4_2::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test4.2");

	return ret;

	}

CEsockTest4_2::~CEsockTest4_2()

	{

	}

enum TVerdict CEsockTest4_2::easyTestStepPreambleL()

	{

	if (iEsockSuite->GetSocketListCount() < 1)

		{

		const TPtrC &sectName = SectionName(_L("Test_4.2"));

		// get local ip address

		TInetAddr addrLocal, addrRemote;

		if (!GetIpAddressFromConfig(sectName, _L("ipAddressLocal"), addrLocal))

			{

			return EFail;

			}

		// get ip address to connect to (usually loopback)

		if (!GetIpAddressFromConfig(sectName, _L("ipAddressRemote"), addrRemote))

			{

			return EFail;

			}

		// get port number

		TInt port;

		if (!GetIntFromConfig(sectName, _L("port"), port))

			{

			return EFail;

			}

		// open socket and listen for connect requests

		TInt nRet = OpenListeningSocketL(addrLocal, iSockIndex, port);

		if (KErrNone != nRet)

			{

			if (KErrServerTerminated == nRet)

				{

				User::Leave(EFail);

				}

			return EFail;

			}

		}

	return EPass;

	}

enum TVerdict CEsockTest4_2::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	// open active socket and make connect request

	// by not doing this allow time for the CancelAccept() after the Accept() below

	// TESTL(OpenActiveSocketL(addrRemote, sockIndexIgnore, port));

	// open a blank socket

	RSocket sock;

	CleanupClosePushL(sock);

	TInt nRet = sock.Open(iEsockSuite->iSocketServer);

	TESTEL(KErrNone == nRet, nRet);

	// accept a connection on the listening socket

	TRequestStatus stat;

	iEsockSuite->GetSocketHandle(iSockIndex).Accept(sock, stat);

	// cancel the accept before completion

	iEsockSuite->GetSocketHandle(iSockIndex).CancelAccept();

	User::WaitForRequest(stat);

	nRet = stat.Int();

	TESTEL(KErrCancel == nRet, nRet);

	CleanupStack::PopAndDestroy();

	return EPass;

	}