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

// Contains the implementation of the test cases that predominately use NT RAS

// as the default interface. These test the use of TCP sockets and host resolvers.

// 

//

/**

 @file

*/

#include "TE_RConnectionNtRasTestSteps.h"

#include <in_iface.h>

#include <nifman.h>

#include <simtsy.h>

#include <dns_qry.h>

// From networking/inhook6/inc/dnd_err.h

const TInt KErrDndNameNotFound = -5120;

TE_RConnectionTest101::~TE_RConnectionTest101()

{

}

// Implicitly create a single connection using Connect()

enum TVerdict TE_RConnectionTest101::doTestStepL(void)

{

	TInt err;

	RSocketServ ss;

	RSocket sock;

	err = OpenSocketServer(ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss);

	err = OpenTcpSocket(sock, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock);

	err = ConnectTcpSocket(sock, iEchoServerAddr); // this will use Connect()

	TESTEL(KErrNone == err, err);

	err = TestTcpDataPathL(sock);

	TESTEL(KErrNone == err, err);

	err = DestroyTcpSocket(sock);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	CloseSocketServer(ss);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest101

TE_RConnectionTest102::~TE_RConnectionTest102()

{

}

// Explicitly associate a TCP socket to an existing connection

enum TVerdict TE_RConnectionTest102::doTestStepL(void)

{

	TInt err;

	RSocketServ ss;

	RConnection conn;

	RSocket sock;

	err = OpenSocketServer(ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss);

	err = OpenConnection(conn, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn);

	err = StartConnection(conn);

	TESTEL(KErrNone == err, err);

	err = OpenTcpSocketExplicit(sock, ss, conn);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock);

	err = ConnectTcpSocket(sock, iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	err = TestTcpDataPathL(sock);

	TESTEL(KErrNone == err, err);

	err = DestroyTcpSocket(sock);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	CloseConnection(conn);

	CleanupStack::Pop();

	CloseSocketServer(ss);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest102

TE_RConnectionTest103::~TE_RConnectionTest103()

{

}

enum TVerdict TE_RConnectionTest103::doTestStepL(void)

/*

 * Ensure that initially chosen interface with implicit connection creation

 * matches that chosen for later reuses (using TCP sockets)

 */

{

	TInt err;

	RSocketServ ss;

	RConnection conn;

	RSocket sock;

	TUint numOfConnections;

	err = OpenSocketServer(ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss);

	err = OpenTcpSocket(sock, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock);

	err = ConnectTcpSocket(sock, iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	err = TestTcpDataPathL(sock);

	TESTEL(KErrNone == err, err);

	// temporarily create a connection to see how many interfaces there are

	numOfConnections = NumberOfInterfacesL(ss);

	TESTEL(1 == numOfConnections, numOfConnections);

	err = DestroyTcpSocket(sock);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	err = OpenTcpSocket(sock, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock);

	err = ConnectTcpSocket(sock, iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	numOfConnections = NumberOfInterfacesL(ss);

	TESTEL(1 == numOfConnections, numOfConnections);

	err = TestTcpDataPathL(sock);

	TESTEL(KErrNone == err, err);

	err = DestroyTcpSocket(sock);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	CloseSocketServer(ss);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest103

TE_RConnectionTest104::~TE_RConnectionTest104()

{

}

enum TVerdict TE_RConnectionTest104::doTestStepL(void)

/*

 * Create multiple TCP connections simultaneously without waiting for them to connect

 */

{

	TInt err;

	RSocketServ ss;

	RSocket socks[4];

	RConnection conn;

	TUint numOfConnections = 0;

	TInt i;

	/*

	 * Set up the basics we need before starting

	 */

	err = OpenSocketServer(ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss);

	/*

	 * Open the TCP sockets

	 */

	for (i=0;i<4;i++)

	{

		err = OpenTcpSocket(socks[i], ss);

		TESTEL(KErrNone == err, err);

		CleanupClosePushL(socks[i]);

	}

	/*

	 * Now connect them all at once using this all encompassing helper function

	 */

	err = ConnectFourTcpSockets(socks[0], socks[1], socks[2], socks[3], iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	/*

	 * Test the data paths

	 */

	for (i=0;i<4;i++)

	{

		err = TestTcpDataPathL(socks[i]);

		TESTEL(KErrNone == err, err);

	}

	err = OpenConnection(conn, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn);

	err = EnumerateConnections(conn, numOfConnections);

	TESTEL(KErrNone == err, err);

	TESTEL(1 == numOfConnections, numOfConnections);

	CloseConnection(conn);

	CleanupStack::Pop();

	/*

	 * Tidy up in reverse order

	 */

	for (i=3; i>=0; i--)

	{

		err = DestroyTcpSocket(socks[i]);

		TESTEL(KErrNone == err, err);

		CleanupStack::Pop();

	}

	CloseSocketServer(ss);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest104

TE_RConnectionTest105::~TE_RConnectionTest105()

{

}

enum TVerdict TE_RConnectionTest105::doTestStepL(void)

/*

 * Send data over a new connection oriented socket (not associated with any existing connection)

 * when an existing connection using non-default parameter values already exists within the same

 * socket server.

 * Even though this is a tcp test it should be run with the db which has the dummy nif as the 

 * default so that any use of the default if will fail to connect.

 */

{

	TInt err;

	RSocketServ ss;

	RConnection conn;

	RSocket sock;

	TUint numOfConnections = 0;

	err = OpenSocketServer(ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss);

	err = OpenConnection(conn, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn);

	err = StartConnectionWithOverrides(conn, iDefaultIap);

	TESTEL(KErrNone == err, err);

	err = OpenTcpSocket(sock, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock);

	err = ConnectTcpSocket(sock, iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	err = TestTcpDataPathL(sock);

	TESTEL(KErrNone == err, err);

	err = EnumerateConnections(conn, numOfConnections);

	TESTEL(KErrNone == err, err);

	TESTEL(1 == numOfConnections, numOfConnections);

	err = DestroyTcpSocket(sock);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	CloseConnection(conn);

	CleanupStack::Pop();

	CloseSocketServer(ss);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest105

TE_RConnectionTest106::~TE_RConnectionTest106()

{

}

enum TVerdict TE_RConnectionTest106::doTestStepL(void)

/*

 * Send data over a new connection oriented socket in a new server session when an existing connection exists in 

 * another server session

 */

{

	TInt err;

	RSocketServ ss1, ss2;

	RConnection conn1;

	RSocket sock2;

	err = OpenSocketServer(ss1);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss1);

	err = OpenConnection(conn1, ss1);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn1);

	// deliberately using a NIF which doesn't support TCP connections

	err = StartConnectionWithOverrides(conn1, iHungryNifIap);

	TESTEL(KErrNone == err, err);

	err = OpenSocketServer(ss2);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss2);

	err = OpenTcpSocket(sock2, ss2);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock2);

	err = ConnectTcpSocket(sock2, iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	err = TestTcpDataPathL(sock2);

	TESTEL(KErrNone == err, err);

	err = DestroyTcpSocket(sock2);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	CloseSocketServer(ss2);

	CleanupStack::Pop();	

	CloseConnection(conn1);

	CleanupStack::Pop();

	CloseSocketServer(ss1);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest106

TE_RConnectionTest107::~TE_RConnectionTest107()

{

}

enum TVerdict TE_RConnectionTest107::doTestStepL(void)

{

	TInt err;

	RSocketServ ss1, ss2;

	RConnection conn1, conn2;

	RSocket sock2;

	TUint numOfConnections;

	err = OpenSocketServer(ss1);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss1);

	err = OpenSocketServer(ss2);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss2);

	err = OpenConnection(conn1, ss1);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn1);

	err = StartConnection(conn1);

	TESTEL(KErrNone == err, err);

	err = OpenConnection(conn2, ss2);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn2);

	err = StartConnectionWithOverrides(conn2, iDefaultIap);

	TESTEL(KErrNone == err, err);

	err = EnumerateConnections(conn2, numOfConnections);

	TESTEL(KErrNone == err, err);

	TESTEL(1 == numOfConnections, numOfConnections);

	err = OpenTcpSocketExplicit(sock2, ss2, conn2);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock2);

	err = ConnectTcpSocket(sock2, iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	err = TestTcpDataPathL(sock2);

	TESTEL(KErrNone == err, err);

	err = DestroyTcpSocket(sock2);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	CloseConnection(conn2);

	CleanupStack::Pop();

	CloseConnection(conn1);

	CleanupStack::Pop();

	CloseSocketServer(ss2);

	CleanupStack::Pop();

	CloseSocketServer(ss1);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest107

TE_RConnectionTest108::~TE_RConnectionTest108()

{

}

enum TVerdict TE_RConnectionTest108::doTestStepL(void)

/*

 * Create two connections (non-default first) then Connect() a TCP socket implicitly associating 

 * to a connection

 */

{

	TInt err;

	RSocketServ ss;

	RConnection conn1, conn2;

	RSocket sock;

	err = OpenSocketServer(ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss);

	err = OpenConnection(conn1, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn1);

	// deliberately pick an IAP which doesn't support TCP

	err = StartConnectionWithOverrides(conn1, iHungryNifIap);

	TESTEL(KErrNone == err, err);

	err = OpenConnection(conn2, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn2);

	err = StartConnection(conn2);

	TESTEL(KErrNone == err, err);

	err = OpenTcpSocket(sock, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(sock);

	err = ConnectTcpSocket(sock, iEchoServerAddr);

	TESTEL(KErrNone == err, err);

	err = TestTcpDataPathL(sock);

	TESTEL(KErrNone == err, err);

	err = DestroyTcpSocket(sock);

	TESTEL(KErrNone == err, err);

	CleanupStack::Pop();

	CloseConnection(conn2);

	CleanupStack::Pop();

	CloseConnection(conn1);

	CleanupStack::Pop();

	CloseSocketServer(ss);

	CleanupStack::Pop();

	return TestStepResult();

} // TE_RConnectionTest108

TE_RConnectionTest109::~TE_RConnectionTest109()

{

}

enum TVerdict TE_RConnectionTest109::doTestStepL(void)

/*

 * Test failure of the interface to start

 */

{	

	TInt err;

	RSocketServ ss;

	RConnection conn;

	err = OpenSocketServer(ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(ss);

	err = OpenConnection(conn, ss);

	TESTEL(KErrNone == err, err);

	CleanupClosePushL(conn);

	err = StartConnectionWithOverrides(conn, iBadNtRasIap);

	TESTEL(KErrIfAuthenticationFailure == err, err); // should be an error here