// 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;
	}