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

// 

//

// EPOC includes

#include <e32base.h>

#include <in_sock.h>

// Test system includes

#include "EsockTestSection8.h"

// Test step 8.1

const TDesC& CEsockTest8_1::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test8.1");

	return ret;

	}

CEsockTest8_1::~CEsockTest8_1()

	{

	}

enum TVerdict CEsockTest8_1::easyTestStepPreambleL()

	{

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_8.1"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest8_1::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	// Urgent data test - 1 byte read out-of-band

	// for client enable KSoTcpNextSendUrgentData

	TESTL(iEsockSuite->GetSocketHandle(iSockIndex2).SetOpt(KSoTcpNextSendUrgentData, KSolInetTcp, 1)==KErrNone);

	// send a single byte from the client

	TRequestStatus stat;

	iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("7"), stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrNone, stat.Int());

	// wait for 1 second

	User::After(1000000);

	// check on server that urgent data is available

	TInt nRet;

	TInt ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(nRet == 1, nRet);

	// check the urgent data offset (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOUrgentDataOffset, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(nRet == 0, nRet);

	// check the number of bytes to read (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(nRet == 0, nRet);

	// get the last error - check it is KErrUrgentData (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOSelectLastError, KSOLSocket, nRet);

	TESTEL(KErrUrgentData == ret, ret);

	// peek for urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpPeekUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(nRet == '7', nRet);

	// peek again

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpPeekUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(nRet == '7', nRet);

	// read the urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(nRet == '7', nRet);

	// read again

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNotFound == ret, ret);

	return EPass;

	}

// Test step 8.2

const TDesC& CEsockTest8_2::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test8.2");

	return ret;

	}

CEsockTest8_2::~CEsockTest8_2()

	{

	}

enum TVerdict CEsockTest8_2::easyTestStepPreambleL()

	{

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_8.2"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest8_2::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	// Urgent data test - 2 bytes, 1 of urgent data read out-of-band

	// for client enable KSoTcpNextSendUrgentData

	TInt ret = iEsockSuite->GetSocketHandle(iSockIndex2).SetOpt(KSoTcpNextSendUrgentData, KSolInetTcp, 1);

	TESTEL(KErrNone == ret, ret);

	// send 2 bytes of data from the client

	TRequestStatus stat;

	iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("89"), stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrNone, stat.Int());

	// check on server that urgent data is not available

	TInt nRet;

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(0 == nRet, nRet);

	// wait for 1 second

	User::After(1000000);

	// check the urgent data offset (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOUrgentDataOffset, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(1 == nRet, nRet);

	// check the number of bytes to read (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(1 == nRet, nRet);

	// read the data - check only a single byte is read

	TBuf8<40> rbuf;

	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf, stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrUrgentData, stat.Int());

	TESTL(rbuf==_L8("8"));

	// check that urgent data is now available

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(1 == nRet, nRet);

	// check KSoTcpNextSendUrgentData option is disabled (client)

	ret = iEsockSuite->GetSocketHandle(iSockIndex2).GetOpt(KSoTcpNextSendUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(0 == nRet, nRet);

	// get the last error - check it is KErrUrgentData (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOSelectLastError, KSOLSocket, nRet);

	TESTEL(KErrUrgentData == ret, ret);

	// peek for urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpPeekUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTL(nRet=='9');

	// read the urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTL(nRet=='9');

	// read again

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNotFound == ret, ret);

	return EPass;

	}

// Test step 8.3

const TDesC& CEsockTest8_3::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test8.3");

	return ret;

	}

CEsockTest8_3::~CEsockTest8_3()

	{

	}

enum TVerdict CEsockTest8_3::easyTestStepPreambleL()

	{

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_8.3"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest8_3::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	// Urgent data test - 14 bytes (4th is urgent) read out-of-band

	// for client enable KSoTcpNextSendUrgentData

	TInt ret = iEsockSuite->GetSocketHandle(iSockIndex2).SetOpt(KSoTcpNextSendUrgentData, KSolInetTcp, 1);

	TESTEL(KErrNone == ret, ret);

	// send 4 bytes of data from the client

	TRequestStatus stat;

	iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("1234"), stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrNone, stat.Int());

	// send 10 more bytes of data from the client

	iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("abcdefghij"), stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrNone, stat.Int());

	// wait for 1 second

	User::After(1000000);

	// check on server that urgent data is not available

	TInt nRet;

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(0 == nRet, nRet);

	// check the urgent data offset (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOUrgentDataOffset, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(3 == nRet, nRet);

	// check the number of bytes to read before urgent data(server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(3 == nRet, nRet);

	// read the data - check only 3 bytes are read

	TBuf8<10> rbuf;

	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf, stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrUrgentData, stat.Int());

	TESTL(rbuf==_L8("123"));

	// check that urgent data is now available

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(1 == nRet, nRet);

	// check the number of bytes to read before urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(0 == nRet, nRet);

	// peek for urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpPeekUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTL(nRet=='4');

	// read the urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTL(nRet=='4');

	User::After(1000);

	// check the number of bytes to read is now updated since we read out urgent data

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(10 == nRet, nRet);

	// read the rest of the data

	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf, stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrNone, stat.Int());

	TESTL(rbuf==_L8("abcdefghij"));

	return EPass;

	}

// Test step 8.4

const TDesC& CEsockTest8_4::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test8.4");

	return ret;

	}

CEsockTest8_4::~CEsockTest8_4()

	{

	}

enum TVerdict CEsockTest8_4::easyTestStepPreambleL()

	{

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_8.4"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest8_4::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	// Urgent data test - 8000 bytes (7998th is urgent) read out-of-band

	// send data from client - 8000 bytes with 7998th marked urgent

	TBuf8<100> wbuf;

	TRequestStatus stat;

	for (TInt i=0 ; i<80 ; i++)

		{

		wbuf.SetMax();

		wbuf.Fill(TChar((TUint8)i)); // fill buffer with data

		if (i==79) // send 100 chars with 98th marked urgent

			{

			iEsockSuite->GetSocketHandle(iSockIndex2).Write(wbuf.Mid(0,97), stat);

			User::WaitForRequest(stat);

			TESTEL(stat==KErrNone, stat.Int());

			TESTL(iEsockSuite->GetSocketHandle(iSockIndex2).SetOpt(KSoTcpNextSendUrgentData, KSolInetTcp, 1)==KErrNone);

			iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("?"), stat);

			User::WaitForRequest(stat);

			TESTEL(stat==KErrNone, stat.Int());

			iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("yz"), stat);

			User::WaitForRequest(stat);

			TESTEL(stat==KErrNone, stat.Int());

			}

		else // send 100 chars

			{

			iEsockSuite->GetSocketHandle(iSockIndex2).Write(wbuf, stat);

			User::WaitForRequest(stat);

			TESTEL(stat==KErrNone, stat.Int());

			}

		}

	User::After(1000000);

	// check on server that urgent data is not available

	TInt nRet;

	TInt ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(0 == nRet, nRet);

	// check the urgent data offset (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOUrgentDataOffset, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(7997 == nRet, nRet);

	// check the number of bytes to read before urgent data(server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(7997 == nRet, nRet);

	// read the data - check all bytes are read

	TInt expectedRet = KErrNone;

	TBuf8<100> rbuf;

	TInt count;

	for (count = 0; count < 7997;)

		{

		iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf, stat);

		User::WaitForRequest(stat);

		TESTL(stat==expectedRet);

		count+=rbuf.Length();

		if (count == 7900)

			{

			expectedRet = KErrUrgentData;

			}

		}

	TESTEL(7997 == count, count);

	// check that urgent data is now available

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(1 == nRet, nRet);

	// check the number of bytes to read before urgent data(server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(0 == nRet, nRet);

	// read the urgent data (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpReadUrgentData, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTL(nRet=='?');

	User::After(1000);

	// check the number of bytes to read (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOReadBytesPending, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(2 == nRet, nRet);

	// read the rest of the data

	TBuf8<2> rbuf2;

	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf2, stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrNone, stat.Int());

	TESTL(rbuf2==_L8("yz"));

	return EPass;

	}

// Test step 8.5

const TDesC& CEsockTest8_5::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test8.5");

	return ret;

	}

CEsockTest8_5::~CEsockTest8_5()

	{

	}

enum TVerdict CEsockTest8_5::easyTestStepPreambleL()

	{

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_8.5"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest8_5::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	// Urgent data test - 1 byte of data read in-band

	// for server enable KSoTcpOobInline

	TInt ret = iEsockSuite->GetSocketHandle(iSockIndex3).SetOpt(KSoTcpOobInline, KSolInetTcp, 1);

	TESTEL(KErrNone == ret, ret);

	// for client enable KSoTcpNextSendUrgentData

	ret = iEsockSuite->GetSocketHandle(iSockIndex2).SetOpt(KSoTcpNextSendUrgentData, KSolInetTcp, 1);

	TESTEL(KErrNone == ret, ret);

	// send a single data byte from the client

	TRequestStatus stat;

	iEsockSuite->GetSocketHandle(iSockIndex2).Write(_L8("7"), stat);

	User::WaitForRequest(stat);

	TESTEL(stat==KErrNone, stat.Int());

	// delay for 1 second

	User::After(1000000);

	// check on server that urgent data is available

	TInt nRet;

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSoTcpRcvAtMark, KSolInetTcp, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(1 == nRet, nRet);

	// check the urgent data offset (server)

	ret = iEsockSuite->GetSocketHandle(iSockIndex3).GetOpt(KSOUrgentDataOffset, KSOLSocket, nRet);

	TESTEL(KErrNone == ret, ret);

	TESTEL(0 == nRet, nRet);