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

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

// Test system includes
#include "SocketTestSection21.h"
#include <test/es_dummy.h>

// Test step 21.1
const TDesC& CSocketTest21_1::GetTestName()
	{
	_LIT(ret,"Test21.1");
	return ret;
	}

enum TVerdict CSocketTest21_1::InternalDoTestStepL( void )
	{
	TVerdict verdict = EPass;
	
	Logger().WriteFormat(_L("Test Purpose: Ioctl call with data"));
	
	// connect to esock
	Logger().WriteFormat(_L("Attempting to connect to socket server"));
    RSocketServ ss;
    TInt ret = OptimalConnect(ss);
	CleanupClosePushL(ss);
	Logger().WriteFormat(_L("Connect returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	
	Logger().WriteFormat(_L("Open a socket on Dummy Protocol 1"));
	RSocket sock;
	CleanupClosePushL (sock);
	ret = sock.Open(ss,_L("Dummy Protocol 1"));
	Logger().WriteFormat(_L("Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);

	Logger().WriteFormat(_L("Issue an Ioctl by passing valid data"));	
	TBuf8<64> ioctlData;
	TRequestStatus status;
	sock.Ioctl (KDummyIoctlCompleteWithData, status, &ioctlData);
	User::WaitForRequest(status);
	TESTL(KErrNone == status.Int());
	TESTL(ioctlData.Compare(KIoctlData()) == 0);
	CleanupStack::PopAndDestroy(); // sock	


	Logger().WriteFormat(_L("Open a socket again on Dummy Protocol 1"));
	RSocket sock2;
	CleanupClosePushL (sock2);
	ret = sock2.Open(ss,_L("Dummy Protocol 1"));
	Logger().WriteFormat(_L("Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	Logger().WriteFormat(_L("Issue an Ioctl by passing NULL data"));
	TRequestStatus status2;
	sock2.Ioctl (KDummyIoctlCompleteWithData, status2, NULL);
	User::WaitForRequest(status2);
	TESTL(KErrNone == status2.Int());
	CleanupStack::PopAndDestroy(); // sock2		
	
	CleanupStack::PopAndDestroy(); // ss

	return verdict;
	}

// Test step 21.2
const TDesC& CSocketTest21_2::GetTestName()
	{
	_LIT(ret,"Test21.2");
	return ret;
	}

enum TVerdict CSocketTest21_2::InternalDoTestStepL( void )
	{
	TVerdict verdict = EPass;
	
	Logger().WriteFormat(_L("Test Purpose: Connect complete with data"));
	
	// connect to esock
	Logger().WriteFormat(_L("Attempting to connect to socket server"));
    RSocketServ ss;
    TInt ret = OptimalConnect(ss);
	CleanupClosePushL(ss);
	Logger().WriteFormat(_L("Connect returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	
	Logger().WriteFormat(_L("Open a socket on Dummy Protocol 3"));
	RSocket sock;
	CleanupClosePushL (sock);
	ret = sock.Open(ss, KDummyThreeName);
	Logger().WriteFormat(_L("Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);

	Logger().WriteFormat(_L("Setting sockopt not to complete connect"));	
	ret = sock.SetOpt(KDummyOptionSetBlockConnectData,28,TRUE); //Block connect
	TESTL(KErrNone == ret);
	
	Logger().WriteFormat(_L("Perform connect"));
	TRequestStatus status;
	TSockAddr addr;
	TBuf8<64> connectedData;
	sock.Connect (addr, KNullDesC8(), connectedData, status);
	Logger().WriteFormat(_L("<i>Setting sockopt to now complete the connect with data</i>"));
	ret = sock.SetOpt(KDummyOptionSetBlockConnectData,28,FALSE); //Unblock Connect
	TESTL(KErrNone == ret);
	User::WaitForRequest(status);
	TESTL(KErrNone == status.Int());
	TESTL(connectedData.Compare(KConnectCompleteData()) == 0);

	CleanupStack::PopAndDestroy(); // sock
	
	Logger().WriteFormat(_L("Open a socket again on Dummy Protocol 3"));
	RSocket sock2;
	CleanupClosePushL (sock2);
	ret = sock2.Open(ss, KDummyThreeName);
	Logger().WriteFormat(_L("Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);

	Logger().WriteFormat(_L("Setting sockopt not to complete connect"));	
	ret = sock2.SetOpt(KDummyOptionSetBlockConnectData,28,TRUE); //Block connect
	TESTL(KErrNone == ret);
	
	Logger().WriteFormat(_L("Perform connect"));
	TRequestStatus status2;
	TSockAddr addr2;
	sock2.Connect (addr2, status2);
	Logger().WriteFormat(_L("<i>Setting sockopt to now complete the connect with data</i>"));
	ret = sock2.SetOpt(KDummyOptionSetBlockConnectData,28,FALSE); //Unblock Connect
	TESTL(KErrNone == ret);
	User::WaitForRequest(status2);
	TESTL(KErrNone == status2.Int());

	CleanupStack::PopAndDestroy(2); // sock, ss

	return verdict;
	}