// Copyright (c) 1997-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 20
// 
//



#include <e32base.h>
#include "SocketTestSection20.h"
#include "ES_DUMMY.H"
#include <es_sock.h>
#include <es_mbuf.h>
#include <es_prot.h>
#include <e32test.h>
#include <comms-infras/nifif.h>
#include <es_mbuf.h>
#include <ss_pman.h>
#include <ss_glob.h>
#include <agenterrors.h>

enum options
	{
	KOOM = 0,
	KEndOOM = 1,
	};
	
enum level
	{
	KHigh = 0,
	KLow = 1,
	};

const TInt KDesBufSize = 50;


// Test step 20.1
const TDesC& CSocketTest20_1::GetTestName()
	{
	_LIT(ret,"Test20.1");
	return ret;
	}

enum TVerdict CSocketTest20_1::InternalDoTestStepL( void )
	{
	// Create socket, connect and then shutdown using 
	TVerdict verdict = EFail;
	Logger().WriteFormat(_L("Test Purpose: Connect Socket, then Shutdown.... KSIConnectData Protocol"));

	// Connect to esock
	Logger().WriteFormat(_L("Attempting to connect to socket server"));
    RSocketServ ss;
	TInt ret = ss.Connect();
	Logger().WriteFormat(_L("Connect returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	CleanupClosePushL(ss); 

	// Create and open socket on TCP protocol
	RSocket socket1;
	Logger().WriteFormat(_L("Opening Socket 1"));
	ret = socket1.Open(ss, KAfInet, KSockStream, KProtocolInetTcp);
	TESTL(KErrNone == ret);
	Logger().WriteFormat(_L("Socket 1 Open returned %S"), &EpocErrorToText(ret));	
	CleanupClosePushL(socket1); 

	// Create Ports for Socket and socket to connect to
 	const TInt KSocket2Port = 3881;
 	_LIT(KLoopback, "127.0.0.1");
 	_LIT(KLocal, "0.0.0.0");
 	
 	// Set the local address of Socket1
 	TInetAddr socket1Addr;
 	socket1Addr.SetPort(KSocket2Port);
	socket1Addr.Input(KLocal);
	ret = socket1.Bind(socket1Addr);
 	
 	// Set remote address for socket 
 	TInetAddr socket2Addr;
 	socket2Addr.SetPort(KSocket2Port);
	socket2Addr.Input(KLoopback);
 	
 	// Connect socket1 to remote address
 	TRequestStatus connectSocket1Status;
 	Logger().WriteFormat(_L("Connecting Socket1 "));
 	socket1.Connect(socket2Addr, connectSocket1Status);
 	User::WaitForRequest(connectSocket1Status);
 	Logger().WriteFormat(_L("Socket 1 connect returned %S"), &EpocErrorToText(connectSocket1Status.Int()));
	TESTL(connectSocket1Status == KErrNone);
	 
	// Shutdown the Socket
	Logger().WriteFormat(_L("Shutting down Connection on Socket1"));
	TRequestStatus shutdownStatus;
	_LIT8(desOut, "Some test stuff to send to protocol");
	TBuf8<KDesBufSize> desIn;
	socket1.Shutdown(RSocket::EImmediate,desOut,desIn, shutdownStatus);
	User::WaitForRequest(shutdownStatus);
	Logger().WriteFormat(_L("Socket 1 shutdown returned %S"), &EpocErrorToText(shutdownStatus.Int()));
	if(shutdownStatus == KErrNone)
	 	{
	 	verdict = EPass;
	 	}
	 	
	// Clean up the Server side objects
 	CleanupStack::PopAndDestroy(&socket1);
 	CleanupStack::PopAndDestroy(&ss);
 	SetTestStepResult(verdict);   
	return verdict;
	}
	

// Test step 20.2
const TDesC& CSocketTest20_2::GetTestName()
	{
	_LIT(ret,"Test20.2");
	return ret;
	}

enum TVerdict CSocketTest20_2::InternalDoTestStepL( void )
	{
	// Create socket, connect and then shutdown using 
	TVerdict verdict = EFail;
	Logger().WriteFormat(_L("Test Purpose: Connect Socket, then Shutdown... KSIConnectionless Protocol"));

	// Connect to esock
	Logger().WriteFormat(_L("Attempting to connect to socket server"));
    RSocketServ ss;
	TInt ret = ss.Connect();
	Logger().WriteFormat(_L("Connect returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	CleanupClosePushL(ss); 


	// Create and open socket on TCP protocol
	RSocket socket1;
	Logger().WriteFormat(_L("Opening Socket 1"));
	ret = socket1.Open(ss, KAfInet, KSockDatagram, KProtocolInetUdp);
	Logger().WriteFormat(_L("Socket 1 Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);	
	CleanupClosePushL(socket1); 

	// Create Ports for Socket and socket to connect to
 	const TInt KSocket2Port = 3881;
 	_LIT(KLoopback, "127.0.0.1");
 	_LIT(KLocal, "0.0.0.0");
 	
 	// Set the local address of Socket1
 	TInetAddr socket1Addr;
 	socket1Addr.SetPort(KSocket2Port);
	socket1Addr.Input(KLocal);
	ret = socket1.Bind(socket1Addr);
 	
 	// Set remote address for socket 
 	TInetAddr socket2Addr;
 	socket2Addr.SetPort(KSocket2Port);
	socket2Addr.Input(KLoopback);
 	
 	// Connect socket1 to remote address
 	TRequestStatus connectSocket1Status;
 	Logger().WriteFormat(_L("Connecting Socket1 "));
 	socket1.Connect(socket2Addr, connectSocket1Status);
 	User::WaitForRequest(connectSocket1Status);
 	Logger().WriteFormat(_L("Socket 1 connect returned %S"), &EpocErrorToText(connectSocket1Status.Int()));
	TESTL(connectSocket1Status == KErrNone);
	 
	// Shutdown the Socket
	Logger().WriteFormat(_L("Shutting down Connection on Socket1"));
	TRequestStatus shutdownStatus;
	_LIT8(desOut, "Some test data to send to protocol");
	TBuf8<KDesBufSize> desIn;
	socket1.Shutdown(RSocket::EImmediate,desOut,desIn, shutdownStatus);
	User::WaitForRequest(shutdownStatus);
	Logger().WriteFormat(_L("Socket 1 shutdown returned %S"), &EpocErrorToText(shutdownStatus.Int()));
	if(shutdownStatus == KErrNone)
	 	{
	 	verdict = EPass;
	 	}
	
	 	
	// Clean up the Server side objects
 	CleanupStack::PopAndDestroy(&socket1);
	CleanupStack::PopAndDestroy(&ss);
 	SetTestStepResult(verdict);   
	return verdict;
	}


// Test step 20.3
const TDesC& CSocketTest20_3::GetTestName()
	{
	_LIT(ret,"Test20.3");
	return ret;
	}

enum TVerdict CSocketTest20_3::InternalDoTestStepL( void )
	{
	// Create socket, shutdown socket then connect 
	TVerdict verdict = EFail;
	Logger().WriteFormat(_L("Test Purpose: Shutdown Socket, then attempt to connect"));

	// Connect to esock
	Logger().WriteFormat(_L("Attempting to connect to socket server"));
    RSocketServ ss;
	TInt ret = ss.Connect();
	Logger().WriteFormat(_L("Connect returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	CleanupClosePushL(ss); 


	// Create and open socket on TCP protocol
	RSocket socket1;
	Logger().WriteFormat(_L("Opening Socket 1"));
	ret = socket1.Open(ss, KAfInet, KSockStream, KProtocolInetTcp);
	Logger().WriteFormat(_L("Socket 1 Open returned %S"), &EpocErrorToText(ret));	
	TESTL(KErrNone == ret);
	CleanupClosePushL(socket1); 

	// Create Ports for Socket and socket to connect to
 	const TInt KSocket2Port = 3881;
 	_LIT(KLoopback, "127.0.0.1");
 	_LIT(KLocal, "0.0.0.0");
 	
 	// Set the local address of Socket1
 	TInetAddr socket1Addr;
 	socket1Addr.SetPort(KSocket2Port);
	socket1Addr.Input(KLocal);
	ret = socket1.Bind(socket1Addr);
 	
 	// Set remote address for socket 
 	TInetAddr socket2Addr;
 	socket2Addr.SetPort(KSocket2Port);
	socket2Addr.Input(KLoopback);
 	
  	 	
 	// Shutdown the Socket
	Logger().WriteFormat(_L("Shutting down Connection on Socket1"));
	TRequestStatus shutdownStatus;
	_LIT8(desOut, "Some test stuff to send to protocol");
	TBuf8<KDesBufSize> desIn;
	socket1.Shutdown(RSocket::EImmediate,desOut,desIn, shutdownStatus);
	User::WaitForRequest(shutdownStatus);
	Logger().WriteFormat(_L("Socket 1 shutdown returned %S"), &EpocErrorToText(shutdownStatus.Int()));
 	
 	// Connect socket1 to remote address
 	TRequestStatus connectSocket1Status;
 	Logger().WriteFormat(_L("Connecting Socket1 "));
 	socket1.Connect(socket2Addr, connectSocket1Status);
 	User::WaitForRequest(connectSocket1Status);
 	Logger().WriteFormat(_L("Socket 1 connect returned %S"), &EpocErrorToText(connectSocket1Status.Int()));
	if(connectSocket1Status == KErrBadHandle)
	 	{
	 	verdict = EPass;
	 	}
	 	
	// Clean up the Server side objects
 	CleanupStack::PopAndDestroy(&socket1);
 	CleanupStack::PopAndDestroy(&ss);
 	SetTestStepResult(verdict);   
	return verdict;
	}
	
	
	
// Test step 20.4
const TDesC& CSocketTest20_4::GetTestName()
	{
	_LIT(ret,"Test20.4");
	return ret;
	}

enum TVerdict CSocketTest20_4::InternalDoTestStepL( void )
	{
	// Create socket, connect and then shutdown using 
	TVerdict verdict = EFail;
	Logger().WriteFormat(_L("Test Purpose: Connect Socket, then Get DisconnectData.... KSIConnectionless Protocol"));

	// Connect to esock
	Logger().WriteFormat(_L("Attempting to connect to socket server"));
    RSocketServ ss;
	TInt ret = ss.Connect();
	Logger().WriteFormat(_L("Connect returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	CleanupClosePushL(ss); 

	// Create and open socket on UDP protocol
	RSocket socket1;
	Logger().WriteFormat(_L("Opening Socket 1"));
	ret = socket1.Open(ss, KAfInet, KSockDatagram, KProtocolInetUdp);
	Logger().WriteFormat(_L("Socket 1 Open returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	CleanupClosePushL(socket1); 

	// Create Ports for Socket and socket to connect to
 	const TInt KSocket2Port = 3881;
 	_LIT(KLoopback, "127.0.0.1");
 	_LIT(KLocal, "0.0.0.0");
 	
 	// Set the local address of Socket1
 	TInetAddr socket1Addr;
 	socket1Addr.SetPort(KSocket2Port);
	socket1Addr.Input(KLocal);
	ret = socket1.Bind(socket1Addr);
 	
 	// Set remote address for socket 
 	TInetAddr socket2Addr;
 	socket2Addr.SetPort(KSocket2Port);
	socket2Addr.Input(KLoopback);
 	
 	// Connect socket1 to remote address
 	TRequestStatus connectSocket1Status;
 	Logger().WriteFormat(_L("Connecting Socket1 "));
 	socket1.Connect(socket2Addr, connectSocket1Status);
 	User::WaitForRequest(connectSocket1Status);
 	Logger().WriteFormat(_L("Socket 1 connect returned %S"), &EpocErrorToText(connectSocket1Status.Int()));
	TESTL(KErrNone == connectSocket1Status.Int());
	 
	TBuf8<KDesBufSize> desIn;
	ret = socket1.GetDisconnectData(desIn);
	if(ret == KErrNotSupported)
		{
		verdict = EPass;
		}
	 	
	// Clean up the Server side objects
 	CleanupStack::PopAndDestroy(&socket1);
 	CleanupStack::PopAndDestroy(&ss);
 	SetTestStepResult(verdict);   
	return verdict;
	}
	

// Test step 20.5
const TDesC& CSocketTest20_5::GetTestName()
	{
	_LIT(ret,"Test20.5");
	return ret;
	}

enum TVerdict CSocketTest20_5::InternalDoTestStepL( void )
	{
	// Create socket, connect, disconnect and then GetDisconnectData 
	TVerdict verdict = EFail;
	Logger().WriteFormat(_L("Test Purpose: Connect Socket, then Get DisconnectData.... KSIConnectData Protocol"));

	// Connect to esock
	Logger().WriteFormat(_L("Attempting to connect to socket server"));
    RSocketServ ss;
	TInt ret = ss.Connect();
	Logger().WriteFormat(_L("Connect returned %S"), &EpocErrorToText(ret));
	TESTL(KErrNone == ret);
	CleanupClosePushL(ss); 
	
	// Create and open socket on Dummy protocol
	RSocket socket1;
	Logger().WriteFormat(_L("Opening Socket 1"));
	ret = socket1.Open(ss, KDummyAddrFamily, KSockSeqPacket, KDummyThree);
	Logger().WriteFormat(_L("Socket 1 Open returned %S"), &EpocErrorToText(ret));	
	TESTL(KErrNone == ret);
	CleanupClosePushL(socket1); 

	// Create Ports for Socket and socket to connect to
 	const TInt KSocket2Port = 3881;
 	_LIT(KLoopback, "127.0.0.1");
 	_LIT(KLocal, "0.0.0.0");
 	
 	// Set the local address of Socket1
 	TInetAddr socket1Addr;
 	socket1Addr.SetPort(KSocket2Port);
	socket1Addr.Input(KLocal);
	ret = socket1.Bind(socket1Addr);
 	
 	// Set remote address for socket 
 	TInetAddr socket2Addr;
 	socket2Addr.SetPort(KSocket2Port);
	socket2Addr.Input(KLoopback);
 	
 	// Connect socket1 to remote address
 	TRequestStatus connectSocket1Status;
 	Logger().WriteFormat(_L("Connecting Socket1 "));
 	socket1.Connect(socket2Addr, connectSocket1Status);
 	User::WaitForRequest(connectSocket1Status);
 	Logger().WriteFormat(_L("Socket 1 connect returned %S"), &EpocErrorToText(connectSocket1Status.Int()));
	if(connectSocket1Status != KErrNone)
	 	{
	 	return EFail;
	 	}
	 
	// Get disconnect data
	TBuf8<KDesBufSize> desIn;
	ret = socket1.GetDisconnectData(desIn);
	if(ret == KErrNotFound)
		{
		verdict = EPass;
		}
	
	// Clean up the Server side objects
 	CleanupStack::PopAndDestroy(&socket1);	
 	CleanupStack::PopAndDestroy(&ss);
 	SetTestStepResult(verdict);   
	return verdict;
	}