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

// 

//

// EPOC includes

#include <e32base.h>

#include <in_sock.h>

#include <es_mbuf.h>

#include <ss_pman.h>

// Test system includes

#include "EsockTestSection6.h"

// Test step 6.1

const TDesC& CEsockTest6_1::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.1");

	return ret;

	}

CEsockTest6_1::~CEsockTest6_1()

	{

	}

enum TVerdict CEsockTest6_1::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

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

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest6_1::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	TRequestStatus stat;

	// shutdown server socket - Normal mode

	iEsockSuite->GetSocketHandle(iSockIndex3).Shutdown(RSocket::ENormal, stat);

	User::WaitForRequest(stat);

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

	TBuf8<40> rbuf;

	// read from server socket

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

	User::WaitForRequest(stat);

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

	// write on server socket

	iEsockSuite->GetSocketHandle(iSockIndex3).Write(_L8("some data"), stat);

	User::WaitForRequest(stat);

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

	// read fronm client socket

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

	User::WaitForRequest(stat);

	TESTEL(stat==KErrEof, stat.Int()); // nothing to read

	// write on client socket

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

	User::WaitForRequest(stat);

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

	return EPass;

	}

// Test step 6.2

const TDesC& CEsockTest6_2::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.2");

	return ret;

	}

CEsockTest6_2::~CEsockTest6_2()

	{

	}

enum TVerdict CEsockTest6_2::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

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

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest6_2::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	TRequestStatus stat;

	// shutdown server socket - StopOutput mode

	iEsockSuite->GetSocketHandle(iSockIndex3).Shutdown(RSocket::EStopOutput, stat);

	User::WaitForRequest(stat);

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

	// write on server socket

	iEsockSuite->GetSocketHandle(iSockIndex3).Write(_L8("some data"), stat);

	User::WaitForRequest(stat);

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

	// read on client

	TBuf8<40> rbuf, wbuf;

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

	User::WaitForRequest(stat);

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

	// write on client

	wbuf.SetMax();

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

	User::WaitForRequest(stat);

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

	// read on server

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

	User::WaitForRequest(stat);

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

	TESTL(rbuf==wbuf);

	return EPass;

	}

// Test step 6.3

const TDesC& CEsockTest6_3::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.3");

	return ret;

	}

CEsockTest6_3::~CEsockTest6_3()

	{

	}

enum TVerdict CEsockTest6_3::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

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

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest6_3::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	TRequestStatus stat;

	// shutdown server socket - StopInput mode

	iEsockSuite->GetSocketHandle(iSockIndex3).Shutdown(RSocket::EStopInput, stat);

	User::WaitForRequest(stat);

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

	TBuf8<4> rbuf, wbuf;

	// write on server

	wbuf.SetMax();

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

	User::WaitForRequest(stat);

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

	// read on client

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

	User::WaitForRequest(stat);

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

	TESTL(rbuf==wbuf);

	// write on client socket

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

	User::WaitForRequest(stat);

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

	// read on server

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

	User::WaitForRequest(stat);

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

	return EPass;

	}

// Test step 6.4

const TDesC& CEsockTest6_4::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.4");

	return ret;

	}

CEsockTest6_4::~CEsockTest6_4()

	{

	}

enum TVerdict CEsockTest6_4::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

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

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest6_4::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	TRequestStatus stat;

	// shutdown server socket - Immediate mode

	iEsockSuite->GetSocketHandle(iSockIndex3).Shutdown(RSocket::EImmediate, stat);

	User::WaitForRequest(stat);

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

	TBuf8<40> rbuf;

	// read on server socket

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

	User::WaitForRequest(stat);

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

	// write on server

	iEsockSuite->GetSocketHandle(iSockIndex3).Write(_L8("some data"), stat);

	User::WaitForRequest(stat);

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

	// read on client

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

	User::WaitForRequest(stat);

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

	// write on client

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

	User::WaitForRequest(stat);

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

	return EPass;

	}

// Test step 6.5

const TDesC& CEsockTest6_5::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.5");

	return ret;

	}

CEsockTest6_5::~CEsockTest6_5()

	{

	}

enum TVerdict CEsockTest6_5::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

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

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest6_5::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	TRequestStatus stat;

	// shutdown client socket - Normal mode

	iEsockSuite->GetSocketHandle(iSockIndex2).Shutdown(RSocket::ENormal, stat);

	User::WaitForRequest(stat);

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

	TBuf8<40> rbuf;

	// read on client socket

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

	User::WaitForRequest(stat);

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

	// write on client

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

	User::WaitForRequest(stat);

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

	// read on server

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

	User::WaitForRequest(stat);

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

	// write on server

	iEsockSuite->GetSocketHandle(iSockIndex3).Write(_L8("more data"), stat);

	User::WaitForRequest(stat);

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

	return EPass;

	}

// Test step 6.6

const TDesC& CEsockTest6_6::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.6");

	return ret;

	}

CEsockTest6_6::~CEsockTest6_6()

	{

	}

enum TVerdict CEsockTest6_6::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_6.6"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest6_6::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	TRequestStatus stat;

	// shutdown client socket - StopOutput mode

	iEsockSuite->GetSocketHandle(iSockIndex2).Shutdown(RSocket::EStopOutput, stat);

	User::WaitForRequest(stat);

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

	// write on client socket

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

	User::WaitForRequest(stat);

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

	TBuf8<40> rbuf, wbuf;

	// read on server

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

	User::WaitForRequest(stat);

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

	// write on server

	wbuf.SetMax();

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

	User::WaitForRequest(stat);

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

	// read on client

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

	User::WaitForRequest(stat);

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

	TESTL(rbuf==wbuf);

	return EPass;

	}

// Test step 6.7

const TDesC& CEsockTest6_7::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.7");

	return ret;

	}

CEsockTest6_7::~CEsockTest6_7()

	{

	}

enum TVerdict CEsockTest6_7::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_6.7"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)

		{

		return EFail;

		}

	return EPass;

	}

enum TVerdict CEsockTest6_7::easyTestStepL()

	{

	TESTL(EPass == TestStepResult());

	TRequestStatus stat;

	// shutdown client socket - StopInput mode

	iEsockSuite->GetSocketHandle(iSockIndex2).Shutdown(RSocket::EStopInput, stat);

	User::WaitForRequest(stat);

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

	// For testing - try a short delay 

	User::After(1000000); 

	TBuf8<40> rbuf, wbuf;

	// write on client

	wbuf.SetMax();

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

	User::WaitForRequest(stat);

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

	// read on server

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

	User::WaitForRequest(stat);

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

	// write on server socket

	iEsockSuite->GetSocketHandle(iSockIndex3).Write(_L8("some data"), stat);

	User::WaitForRequest(stat);

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

	// read on client

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

	User::WaitForRequest(stat);

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

	// For testing - try a short delay 

	User::After(1000000); 

	return EPass;

	}

// Test step 6.8

const TDesC& CEsockTest6_8::GetTestName()

	{

	// store the name of this test case

	_LIT(ret,"Test6.8");

	return ret;

	}

CEsockTest6_8::~CEsockTest6_8()

	{

	}

enum TVerdict CEsockTest6_8::easyTestStepPreambleL()

	{

	CloseSockets();

	TInt connections;

	TRAPD(ret, connections = OpenConnectionsL(_L("Test_6.8"), iSockIndex2, iSockIndex3));

	if (KErrNone != ret)

		{

		return EFail;

		}

	if (0 >= connections)