// Copyright (c) 2004-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:

// SocketTestSection14.cpp

// This contains ESock Test cases from section 14

// 

//

// EPOC includes

#include <e32base.h>

#include <test/es_dummy.h>

// Test system includes

#include "SocketTestSection18.h"

// Test step 18.1

const TDesC& CSocketTest18_1::GetTestName()

	{

	_LIT(ret,"Test18.1");

	return ret;

	}

enum TVerdict CSocketTest18_1::InternalDoTestStepL( void )

	{

	TVerdict verdict = EPass;

	Logger().WriteFormat(_L("Testing cancellation of Accept"));

	RSocketServ ss;

	TInt ret=OptimalConnect(ss);

	CleanupClosePushL(ss);

    TESTL(KErrNone == ret);	

	Logger().WriteFormat(_L("Open by name"));             

	RSocket sock, sock2;                                                    

	ret=sock.Open(ss,_L("Dummy Protocol 2")); 

	TESTL(KErrNone == ret);	

	ret=sock2.Open(ss); // null socket to accept onto                         

	TESTL(KErrNone == ret);	

	TSockAddr addr;

	ret=sock.Bind(addr);

	TESTL(KErrNone == ret);	

	Logger().WriteFormat(_L("Listen"));             

	ret=sock.Listen(5);

	TESTL(KErrNone == ret);	

	Logger().WriteFormat(_L("Accepting"));             

	TRequestStatus rstat;

	sock.Accept(sock2, rstat);

	TESTL(rstat.Int() == KRequestPending);	

	Logger().WriteFormat(_L("Cancelling Accept"));	

	sock.CancelAccept();

	User::WaitForRequest(rstat);

	TESTL(rstat == KErrCancel);	

    Logger().WriteFormat(_L("Attempting to complete the accept"));             

	//emulate en connect complete event

	ret=sock.SetOpt(KDummyOptionSetConnectComplete,0,0);

	User::After(100000); //Just a wait to allow something to possibly go wrong

	TESTL(rstat.Int() == KErrCancel);	

	CleanupStack::Pop(&ss);

    ss.Close();

	SetTestStepResult(verdict);

	return verdict;

	}

// Test step 18.2

const TDesC& CSocketTest18_2::GetTestName()

	{

	_LIT(ret,"Test18.2");

	return ret;

	}

enum TVerdict CSocketTest18_2::InternalDoTestStepL( void )

	{

	TVerdict verdict = EPass;

	Logger().WriteFormat(_L("Testing cancellation of Connect"));

	RSocketServ ss;

	TInt ret=OptimalConnect(ss);

	CleanupClosePushL(ss);

    TESTL(KErrNone == ret);	

	Logger().WriteFormat(_L("Open by name"));             

	RSocket sock;                                                    

	ret=sock.Open(ss,_L("Dummy Protocol 2"));                      

	TESTL(KErrNone == ret);

	Logger().WriteFormat(_L("Setiing option to block connect"));             

	ret = sock.SetOpt(KDummyOptionSetBlockConnect,25,TRUE);

	TESTL(KErrNone == ret);	

	TSockAddr addr;

	TRequestStatus stat1;

	Logger().WriteFormat(_L("Performing Connect"));             

	sock.Connect(addr,stat1);

	User::After(100000);

	TESTL(stat1 == KRequestPending);

	Logger().WriteFormat(_L("Setiing option to unblock complete connect"));             

	ret = sock.SetOpt(KDummyOptionSetBlockConnect,25,FALSE);

	TESTL(KErrNone == ret);	

	User::WaitForRequest(stat1);

	TESTL(stat1 == KErrNone);

	Logger().WriteFormat(_L("Closing Socket"));             

	sock.Close();

	Logger().WriteFormat(_L("Open by name"));             

	ret=sock.Open(ss,_L("Dummy Protocol 2"));                      

	TESTL(KErrNone == ret);

	Logger().WriteFormat(_L("Setiing option to block connect"));             

	ret = sock.SetOpt(KDummyOptionSetBlockConnect,25,TRUE);

	TESTL(KErrNone == ret);	

	TRequestStatus stat;

	Logger().WriteFormat(_L("Performing Connect"));             

	sock.Connect(addr,stat);

	User::After(100000);

	TESTL(stat == KRequestPending);

	Logger().WriteFormat(_L("Cancelling Connect"));             

	sock.CancelConnect();

	User::WaitForRequest(stat);

	TESTL(stat.Int() == KErrCancel);	

	Logger().WriteFormat(_L("Setiing option to unblock complete connect"));             

	ret = sock.SetOpt(KDummyOptionSetBlockConnect,25,FALSE);

	TESTL(KErrNone == ret);	

	User::After(100000);

	TESTL(stat == KErrCancel);

	CleanupStack::Pop(&ss);

    ss.Close();

	SetTestStepResult(verdict);

	return verdict;

	}

	// Test step 18.3

const TDesC& CSocketTest18_3::GetTestName()

	{

	_LIT(ret,"Test18.3");

	return ret;

	}

enum TVerdict CSocketTest18_3::InternalDoTestStepL( void )

	{

	TVerdict verdict = EPass;

	Logger().WriteFormat(_L("Testing cancellation of Ioctl"));

	RSocketServ ss;

	TInt ret=OptimalConnect(ss);

	CleanupClosePushL(ss);

    TESTL(KErrNone == ret);	

	Logger().WriteFormat(_L("Open by name"));             

	RSocket sock;                                                    

	ret=sock.Open(ss,_L("Dummy Protocol 2"));                      

	TESTL(KErrNone == ret);

	TRequestStatus stat;

	Logger().WriteFormat(_L("Sending Ioclt that does not complete"));             

	sock.Ioctl(KDummyIocltNonCompleting,stat);

	TESTL(KErrNone == ret);

	User::After(100000);

	TESTL(stat == KRequestPending);

	Logger().WriteFormat(_L("Setiing option to complete Ioclt"));             

	ret = sock.SetOpt(KDummyOptionSetIocltComplete,25,0);

	TESTL(KErrNone == ret);	

	User::WaitForRequest(stat);

	TESTL(stat == KErrNone);

	Logger().WriteFormat(_L("Sending Ioclt that does not complete"));             

	sock.Ioctl(KDummyIocltNonCompleting,stat);

	TESTL(KErrNone == ret);

	User::After(100000);

	TESTL(stat == KRequestPending);

	Logger().WriteFormat(_L("Cancelling Ioclt"));             

	sock.CancelIoctl();

	User::WaitForRequest(stat);

	TESTL(stat.Int() == KErrCancel);	

	Logger().WriteFormat(_L("Setiing option to complete Ioclt"));             

	ret = sock.SetOpt(KDummyOptionSetIocltComplete,25,0);

	TESTL(KErrNone == ret);	

	User::After(100000);

	TESTL(stat == KErrCancel);

	CleanupStack::Pop(&ss);

    ss.Close();

	SetTestStepResult(verdict);

	return verdict;

	}