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


#include "ts_testincomming.h"



CTS_TestIncomming::CTS_TestIncomming()
	{
	iTestStepName = KTestIncomming;
	}

CTS_TestIncomming::~CTS_TestIncomming()
	{
	}

enum TVerdict CTS_TestIncomming::doTestStepPreambleL(void)
/**
 * Implements OOM testing in each test
 */
	{
	if (!(GetBoolFromConfig(KTestIncomming,KOomTest,iIsOOMTest)))
		iIsOOMTest=EFalse;
	return EPass;
	}


enum TVerdict CTS_TestIncomming::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(KTestIncomming, KNumOfSocks, numOfSockets);


	if ((!err) || (numOfSockets < 1))
		{
		return EInconclusive;
		}

	RArray<CSplitEchoSocket*> sockArray;
	RArray<TBool> expectSocketsToSucceedArray;
	TConnDetails *theConn;

	TInt i;
	for (i = 0; i < numOfSockets; i++)
		{
		// Get some configuration data...
		TInetAddr dest;
		TInetAddr src;

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

		CSplitEchoSocket* newSocket = CSplitEchoSocket::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;
	}