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

// EPOC includes
#include <e32base.h>
#include <in_sock.h>

// Test system includes
#include "EsockTestSection10.h"


// Test step 10.1
const TDesC& CEsockTest10_1::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test10.1");
	
	return ret;
	}

CEsockTest10_1::~CEsockTest10_1()
	{
	}

enum TVerdict CEsockTest10_1::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_10.1"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest10_1::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	TPckgBuf<TUint> flags;
	
	// get select state of server socket
	TRequestStatus stat;
	flags() = KSockSelectRead | KSockSelectWrite | KSockSelectExcept;
	iEsockSuite->GetSocketHandle(iSockIndex3).Ioctl(KIOctlSelect, stat, &flags, KSOLSocket);
	User::WaitForRequest(stat);
	TESTL(stat==KErrNone);
	TESTL(flags()==KSockSelectWrite);
	
	// send data from client to server (2 bytes, 1 urgent)
	TInt ret = iEsockSuite->GetSocketHandle(iSockIndex2).SetOpt(KSoTcpNextSendUrgentData, KSolInetTcp, 1);
	TESTEL(KErrNone == ret, ret);
	iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("12"), stat);
	User::WaitForRequest(stat);
	TESTEL(stat==KErrNone, stat.Int());
	
	// delay for 1 second
	User::After(1000000);
	
	// get select state of the server socket
	flags() = KSockSelectRead | KSockSelectWrite | KSockSelectExcept;
	iEsockSuite->GetSocketHandle(iSockIndex3).Ioctl(KIOctlSelect, stat, &flags, KSOLSocket);
	User::WaitForRequest(stat);
	TESTL(stat==KErrNone);
	TESTL(flags()==(KSockSelectRead | KSockSelectWrite | KSockSelectExcept));
	
	// read data (server)
	TBuf8<20> rbuf2;
	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf2, stat);
	User::WaitForRequest(stat);
	TESTEL(stat==KErrUrgentData, stat.Int());
	
	// get select state of the server socket
	flags() = KSockSelectRead | KSockSelectWrite | KSockSelectExcept;
	iEsockSuite->GetSocketHandle(iSockIndex3).Ioctl(KIOctlSelect, stat, &flags, KSOLSocket);
	User::WaitForRequest(stat);
	TESTL(stat==KErrNone);
	
	TESTL(flags()==(KSockSelectWrite | KSockSelectExcept));
	
	// read the urgent data byte
	TInt nRet;
	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);
	TESTEL(KErrNone == ret, ret);
	TESTL(nRet=='2');
	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);
	TESTEL(KErrNotFound == ret, ret);
	
	// get select state of the server socket
	flags() = KSockSelectRead | KSockSelectWrite | KSockSelectExcept;
	iEsockSuite->GetSocketHandle(iSockIndex3).Ioctl(KIOctlSelect, stat, &flags, KSOLSocket);
	User::WaitForRequest(stat);
	TESTL(stat==KErrNone);
	TESTL(flags()==KSockSelectWrite);
	
	return EPass;
	}


// Test step 10.2
const TDesC& CEsockTest10_2::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test10.2");
	
	return ret;
	}

CEsockTest10_2::~CEsockTest10_2()
	{
	}

enum TVerdict CEsockTest10_2::easyTestStepL()
	{
	
	// Ioctl on an unconnected socket
	
	// open a TCP socket
	RSocket sock;
	CleanupClosePushL(sock);
	TInt nRet = sock.Open(iEsockSuite->iSocketServer, KAfInet, KSockStream, KProtocolInetTcp);
	TESTEL(KErrNone == nRet, nRet);
	
	// get select state of the socket
	sock.GetOpt (KSOSelectPoll, KSOLSocket, (nRet = 0));
	
	// socket is blocked for writing, has no data for reading
	// and has no exception condition
	TESTEL(0 == nRet, nRet);
	
	// close the socket
	CleanupStack::PopAndDestroy();
	
	return EPass;
	}


// Test step 10.3
const TDesC& CEsockTest10_3::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test10.3");
	
	return ret;
	}

CEsockTest10_3::~CEsockTest10_3()
	{
	}

enum TVerdict CEsockTest10_3::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_10.3"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest10_3::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	// cancel an Ioctl operation
	
	TPckgBuf<TUint> flags;
	flags() = KSockSelectExcept;
	
	// get select state of the server socket
	// do not wait for operation to complete
	TRequestStatus stat;
	iEsockSuite->GetSocketHandle(iSockIndex3).Ioctl(KIOctlSelect, stat, &flags, KSOLSocket);
	TESTEL(KRequestPending == stat.Int(), stat.Int());
	
	// cancel the Ioctl operation
	iEsockSuite->GetSocketHandle(iSockIndex3).CancelIoctl();
	
	// wait for operation to complete
	User::WaitForRequest(stat);
	
	// completion status will be KErrNone or KErrCancel
	TESTEL(KErrCancel == stat.Int(), stat.Int());
	
	// get select state of the server socket
	flags() = KSockSelectRead | KSockSelectWrite | KSockSelectExcept;
	iEsockSuite->GetSocketHandle(iSockIndex3).Ioctl(KIOctlSelect, stat, &flags, KSOLSocket);
	
	User::WaitForRequest(stat);
	TESTEL(KErrNone == stat.Int(), stat.Int());
	
	// socket is not blocked for writing
	TESTL(flags()==KSockSelectWrite);
	
	return EPass;
	}