// 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:

// This contains TS_TestConnection echo data primitive.

// stores this connection in C

// 

//

/**

 @file

*/

#include "TS_TestConnection.h"

/* 

 * xxx

 * Open a default / named connection

 */

CTS_TestConnection::CTS_TestConnection()

	{

	iTestStepName = KTestConnection;

	}

CTS_TestConnection::~CTS_TestConnection()

	{	

	}

enum TVerdict CTS_TestConnection::doTestStepPreambleL(void)

/**

 * Implements OOM testing in each test

 */

	{

	if (!(GetBoolFromConfig(KTestConnection,KOomTest,iIsOOMTest)))

		iIsOOMTest=EFalse;

	return EPass;

	}

enum TVerdict CTS_TestConnection::doTestStepL(void)

/**

 * Creates and starts one or more Explicit Connection(s)

 * and appends it/them to the array of

 * connections in the MultiHoming Suite 

 * @return The test step outcome.

 * 

 */

{

	TInt err = KErrNone;

	TInt numOfSockets = 0;

	err = GetIntFromConfig(KTestConnection, KNumOfSocks, numOfSockets);

	if ((!err) || (numOfSockets < 1))

		{

		return EInconclusive;

		}

	RArray<CEchoSocket*> sockArray;

	RArray<TBool> expectSocketsToSucceedArray;

	TConnDetails *theConn;

	TInt i;

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

		{

		// Get some configuration data...

		TInetAddr dest;

		TInetAddr src;

		//RSocketServ theSS;

		TInt protocol = KProtocolInetUdp;

		TInt packSize = PACKET_SIZE;

		TInt packCount = NUM_OF_PACKETS;

		TInt aTol = UDP_TOLERANCE;

		TBool expectSuccess = ETrue;

		TBool isListener = EFalse;

		err = GetSockConfig(i,protocol,packSize,packCount, aTol, dest, src, 

						expectSuccess, isListener, &theConn);

		expectSocketsToSucceedArray.Append(expectSuccess);

		if (err!=KErrNone)

			{

			LogExtra((TText8*)__FILE__, __LINE__, ESevrErr, KEConfigFile);

			}

		CEchoSocket* newSocket = CEchoSocket::NewL();

		err = newSocket->Echo(dest, src, packSize,packCount,protocol,aTol, theConn, i, isListener, this);

		if (err == KErrNone)

			{

			err = sockArray.Append(newSocket);

			if (err != KErrNone)

				{

				newSocket->DoCancel();

				delete newSocket;

				newSocket = NULL;

				}

			}

		else

			{

			TPtrC Errortxt = EpocErrorToText(err);

			Log(KELogger, &Errortxt);

			delete newSocket;

			}

		}	// for (i<numOfSockets)

	if(sockArray.Count() > 0)

		CEnhancedScheduler::Start();	// And start them off...

	// Wait for all to finish / time out.

	for (i = 0; i < sockArray.Count(); i++)

		{

		TInt err = KErrNone;

		TBool boolResult = EFalse;

		TInt percent = 0;

		TInt numSent = -1;

		err = sockArray[i]->LogReport(boolResult, numSent, percent);

		if (expectSocketsToSucceedArray[i] &&

			(KErrNone == err) && boolResult

			||

			// Failure means there was a socket error or no packets received

			!expectSocketsToSucceedArray[i] && (KErrNone != err || !boolResult))

			{

			Log(KSockPassed, i, numSent, percent);

			}

		else

			{

			TPtrC errorText = EpocErrorToText(err);

			Log(KSockFailed, i, &errorText, numSent, percent);

			iTestStepResult = EFail;

			}

		delete sockArray[i];

		}

	expectSocketsToSucceedArray.Close();

	sockArray.Close();

	return iTestStepResult;

	}