// 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:
// This contains ESock Test cases from section 10
//
//

// EPOC includes
#include <e32base.h>
#include <test/es_dummy.h>

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


// Test step 10.1
const TDesC& CSocketTest10_1::GetTestName()
	{
	_LIT(ret,"Test10.1");
	return ret;
	}

enum TVerdict CSocketTest10_1::InternalDoTestStepL( void )
	{
	TVerdict verdict = EPass;
	
	Logger().WriteFormat(_L("Test Purpose: Shutdown with EStopOutput"));
	
	// 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("Opening a socket on Dummy protocol 2"));
	RSocket sk;
	ret = sk.Open(ss, _L("Dummy Protocol 2"));
	Logger().WriteFormat(_L("Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	
	Logger().WriteFormat(_L("Shutting down socket with EStopOutput"));
	TRequestStatus shutStat;
	TRequestStatus rstat;
	sk.Shutdown(RSocket::EStopOutput, shutStat);
	TESTL(KRequestPending == shutStat.Int());
	
	// Check we can still receive
	Logger().WriteFormat(_L("Attempting to receive data"));
	TSockXfrLength len;
	TBuf8<6> buf;
	TBuf<6> buf16;
	sk.Recv(buf, 0, rstat, len);
	User::WaitForRequest(rstat);
	TESTL(KErrNone == rstat.Int());
	buf16.Copy(buf);
	Logger().WriteFormat(_L("Recv status %S, length %d, buf '%S'"), 
		&EpocErrorToText(rstat.Int()), len(), &buf16);
	TESTL(KErrNone == rstat.Int());
	TESTL(_L8("End of") == buf);
	TESTL(6 == len());
	
	// Check writing fails
	Logger().WriteFormat(_L("Attempting to Send data"));
	buf.SetLength(1);
	sk.Send(buf, 0, rstat);
	User::WaitForRequest(rstat);
	Logger().WriteFormat(_L("Send status %S"), &EpocErrorToText(rstat.Int()));
	TESTL(KErrNotReady == rstat.Int());
	
	Logger().WriteFormat(_L("Attempting to receive more data"));
	sk.Recv(buf, 0, rstat, len);
	User::WaitForRequest(rstat);
	buf16.Copy(buf);
	Logger().WriteFormat(_L("Recv status %S, length %d, buf '%S'"), 
		&EpocErrorToText(rstat.Int()), len(), &buf16);
	TESTL(KErrEof == rstat.Int());
	TESTL(_L8(" Data") == buf);
	TESTL(5 == len());
	
	Logger().WriteFormat(_L("Attempting to receive more data"));
	sk.Recv(buf, 0, rstat, len);
	User::WaitForRequest(rstat);
	buf16.Copy(buf);
	Logger().WriteFormat(_L("Recv status %S, length %d, buf '%S'"), 
		&EpocErrorToText(rstat.Int()), len(), &buf16);
	TESTL(KErrEof == rstat.Int());
	TESTL(0 == buf.Length());
	TESTL(0 == len());
	
	Logger().WriteFormat(_L("Closing socket"));
	sk.Close(); // Should cancel shutStat
	User::WaitForRequest(shutStat);
	Logger().WriteFormat(_L("Shutdown status %S"), &EpocErrorToText(shutStat.Int()));
	TESTL(KErrCancel == shutStat.Int());
	
	ss.Close();
	
	CleanupStack::Pop(&ss);
	
	SetTestStepResult(verdict);
	return verdict;
	}

// Test step 10.2
const TDesC& CSocketTest10_2::GetTestName()
	{
	_LIT(ret,"Test10.2");
	return ret;
	}

enum TVerdict CSocketTest10_2::InternalDoTestStepL( void )
	{
	TVerdict verdict = EPass;
	
	Logger().WriteFormat(_L("Test Purpose: Shutdown"));
	
	// 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("Opening a socket on Dummy protocol 2"));
	RSocket sk;
	ret = sk.Open(ss, _L("Dummy Protocol 2"));
	Logger().WriteFormat(_L("Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	
	Logger().WriteFormat(_L("Shutting down socket with EStopInput"));
	TRequestStatus shutStat;
	TRequestStatus rstat;
	sk.Shutdown(RSocket::EStopInput, shutStat);		// Dummy doesn't complete EStopInput
	
	// Check we can still send
	Logger().WriteFormat(_L("Attempting to Send data"));
	TBuf8<6> buf;
	buf.SetLength(1);
	sk.Send(buf, 0, rstat);
	sk.CancelSend();
	User::WaitForRequest(rstat);
	Logger().WriteFormat(_L("Send status %S"), &EpocErrorToText(rstat.Int()));
	TESTL(KErrNotReady == rstat.Int());
	
	// Check receiving fails
	Logger().WriteFormat(_L("Attempting to Receive data"));
	TSockXfrLength len;
	sk.Recv(buf, 0, rstat, len);
	User::WaitForRequest(rstat);
	Logger().WriteFormat(_L("Recv status %S, length %d"), &EpocErrorToText(rstat.Int()), len());
	TESTL(KErrEof == rstat.Int());
	TESTL(0 == len());
	
	Logger().WriteFormat(_L("Closing socket"));
	sk.Close(); // Should cancel shutStat
	User::WaitForRequest(shutStat);
	Logger().WriteFormat(_L("Shutdown status %S"), &EpocErrorToText(shutStat.Int()));
	TESTL(KErrCancel == shutStat.Int());
	
	CleanupStack::Pop(&ss);
	ss.Close();
	
	SetTestStepResult(verdict);
	return verdict;
	}
	
	// Test step 10.2
	const TDesC& CSocketTest10_3::GetTestName()
	{
	_LIT(ret,"Test10.3");
	return ret;
	}
	
	enum TVerdict CSocketTest10_3::InternalDoTestStepL( void )
	{
	TVerdict verdict = EPass;
	
	Logger().WriteFormat(_L("Testing close before completion of accept on new socket"));
	RSocketServ ss;
	TInt ret=OptimalConnect(ss);
	CleanupClosePushL(ss);
    TESTL(KErrNone == ret);	
    
	Logger().WriteFormat(_L("Opening main socket by name"));             
	RSocket sock, sock2;                                                    
	ret=sock.Open(ss,_L("Dummy Protocol 2")); 
	TESTL(KErrNone == ret);	
	
	Logger().WriteFormat(_L("Opening null socket"));  
	ret=sock2.Open(ss); // null socket to accept onto                         
	TESTL(KErrNone == ret);	
	
	TSockAddr addr;
	Logger().WriteFormat(_L("Binding main socket"));
	ret=sock.Bind(addr);
	TESTL(KErrNone == ret);	
	
	Logger().WriteFormat(_L("Performing Listen"));
	Logger().WriteFormat(_L("Listen"));             
	ret=sock.Listen(5);
	TESTL(KErrNone == ret);	
	
	Logger().WriteFormat(_L("Performing Accept"));             
	TRequestStatus rstat;
	sock.Accept(sock2, rstat);
	TESTL(rstat.Int() == KRequestPending);	
	
	User::After(2 * 1000 * 1000);	// make sure accept processing has proceeded before closing the socket, otherwise
									// we risk incurring a BadHandle panic from it (as seen on SMP testing)
	
	Logger().WriteFormat(_L("Closing new socket"));
	sock2.Close();             

	Logger().WriteFormat(_L("Attempting to simulate a connect and complete the accept"));             
	//emulate en connect complete event
	ret=sock.SetOpt(KDummyOptionSetConnectComplete,KIoctlDummyLevel,NULL);
	TESTL(KErrNone == ret);	
	User::WaitForRequest(rstat); //Just a wait to allow something to possibly go wrong
	TESTL(rstat.Int() == KErrCancel);
	
	Logger().WriteFormat(_L("Opening null socket"));  
	ret=sock2.Open(ss); // null socket to accept onto                         
	TESTL(KErrNone == ret);	
	
	Logger().WriteFormat(_L("Performing Accept again"));           
	sock.Accept(sock2, rstat);
	TESTL(rstat.Int() == KRequestPending);	
	
	Logger().WriteFormat(_L("Attempting to simulate a connect and complete the accept"));             
	//emulate en connect complete event
	ret=sock.SetOpt(KDummyOptionSetConnectComplete,KIoctlDummyLevel,NULL);
	TESTL(KErrNone == ret);	
	User::WaitForRequest(rstat); //Just a wait to allow something to possibly go wrong
	TESTL(rstat.Int() == KErrNone);		
	
	CleanupStack::Pop(&ss);
    ss.Close();
	
	SetTestStepResult(verdict);
	return verdict;
	}