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

// class for the rtp unit test cases

// 

//

/**

 @file

 @internalComponent

*/

#include "trtpstep.h"

#include <test/testexecutelog.h>

#include "rtp.h"

#include <in_sock.h>

#include <commdbconnpref.h>

#include <cs_subconparams.h>

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

_LIT8(KRtpSessionCNAME, "Hello There!");

#include "rtp_subconparams.h"

#endif

TVerdict CTrtpStep::doTestStepL()

	{

	iServer->iCurrentStep = this;

	iServer->iStopping = EFalse;

	iServer->iStopCount = 1;

#if defined EKA2

		User::SetCritical(User::ESystemCritical);

#endif

	if (!iServer->iOom)

		return trtpDoTestStepL();

	else

		{

		TVerdict verdict = EFail;

		for (TInt oomCount = 0; ; oomCount++)

			{

			__UHEAP_RESET;

			__UHEAP_SETFAIL(RHeap::EDeterministic, oomCount);

			TInt countBefore = User::CountAllocCells();

			INFO_PRINTF2(_L("countbefore at %d"), countBefore);

			iServer->iStopping = EFalse;

			iServer->iStopCount = 1;

			iIgnoreIncrease = EFalse;

			iError = KErrNone;

			TRAPD(error, verdict = trtpDoTestStepL());

			TInt countAfter = User::CountAllocCells();

			INFO_PRINTF2(_L("countAfter at %d"), countAfter);

			__UHEAP_RESET;

			if (error != KErrNoMemory && iError != KErrNoMemory)

				{

				break;

				}

			else

				{

				if (countBefore != countAfter && !iIgnoreIncrease)

					{

					INFO_PRINTF2(_L("OOM Failed at %d"), oomCount);

					verdict = EFail;

					break;

					}

				}

			}

		SetTestStepResult(verdict);

		return verdict;

		}

	}

void CTrtpStep::GotEvent(TRtpEventType aType)

	{

	switch(aType)

		{

		case ERtpSDES:

			iGotSdes = ETrue;

			break;

		case ERtpAPP: 

			iGotApp = ETrue;

			break;

		case ERtpSR:

			iGotSr = ETrue;

			break;

		case ERtpRR:

			iGotRR = ETrue;

			break;

		case ERtpBYE:

			iGotBye = ETrue;

			break;

		default:

			break;

		}

	}

void CTrtpStep::ResetEvents()

	{

	iGotSdes = EFalse;	

	iGotApp = EFalse;

	iGotSr = EFalse;

	iGotRR = EFalse;

	iGotBye = EFalse;

	}

TVerdict CMakePacket::trtpDoTestStepL()

/**

 * @return - TVerdict code

 * Override of base class pure virtual

 * Demonstrates reading configuration parameters fom an ini file section

 */

	{

	TInt bufSize;

	GetIntFromConfig(ConfigSection(),_L("BufferSize"),bufSize);

	INFO_PRINTF2(_L("Creating buffer of size %d"), bufSize);

	SetTestStepResult(EPass);

	// Check that RRtpSendPacket objects are created closed

	if (iServer->iSendPacket.IsOpen())

		SetTestStepResult(EFail);

	TPtrC config(0,0);

	TBool extension;

	TInt type = 0;

	TInt len = KRtpNoExtension;

	extension = GetStringFromConfig(ConfigSection(), _L("HeaderExtension"),config);

	TLex lex(config);

	if (extension)

		{		

		lex.Val(type);

		if (!lex.Eos() && lex.Peek() == ',')

			lex.Get();

		lex.Val(len);

		if (!lex.Eos() && lex.Peek() == ',')

			lex.Get();

		}

	iServer->iSendPacket = iServer->iSendSource.NewSendPacketL(bufSize, len);

	iServer->iPacket = &iServer->iSendPacket;

	if (extension)

		{

		// Just create the extension now; its existence is checked in

		// CExtension

		RRtpHeaderExtension extension = iServer->iSendPacket.Extension();

		extension.SetType((TUint16)type);

		TInt* array = const_cast<TInt*>(reinterpret_cast<const TInt*>(

											extension.Data().Ptr()));

		TInt i = 0;

		while (!lex.Eos() && i < len)

			{

			TInt val;

			lex.Val(val);

			array[i] = val;

			if (!lex.Eos() && lex.Peek() == ',')

				lex.Get();

			i++;

			}

		}

	if (!iServer->iPacket->IsOpen())

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CClosePacket::trtpDoTestStepL()

/**

 * @return - TVerdict code

 * Override of base class pure virtual

 * Demonstrates reading configuration parameters fom an ini file section

 */

	{

	SetTestStepResult(EPass);

	iIgnoreIncrease = 1;

	iServer->iSendPacket.Close();

	if (iServer->iSendPacket.IsOpen())

	{

		SetTestStepResult(EFail);

	}

	iServer->iPacket = NULL;

	return TestStepResult();

	}

TVerdict CSetPayloadType::trtpDoTestStepL()

/**

 * @return - TVerdict code

 * Override of base class pure virtual

 * Demonstrates reading configuration parameters fom an ini file section

 */

	{

	SetTestStepResult(EPass);

	TInt payloadType;

	GetIntFromConfig(ConfigSection(),_L("PayloadType"),payloadType);

	INFO_PRINTF2(_L("Setting payload type to %d"), payloadType);

	iServer->iSendPacket.SetPayloadType(payloadType);

	return TestStepResult();

	}

TVerdict CPayloadType::trtpDoTestStepL()

/**

 * @return - TVerdict code

 * Override of base class pure virtual

 * Demonstrates reading configuration parameters fom an ini file section

 */

	{

	SetTestStepResult(EPass);

	TInt payloadType;

	GetIntFromConfig(ConfigSection(),_L("PayloadType"),payloadType);

	TInt gotPayloadType = iServer->iPacket->PayloadType();

	INFO_PRINTF3(_L("Payload type is %d should be %d"), gotPayloadType, payloadType);

	if (gotPayloadType != payloadType)

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CSetMarker::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt marker;

	GetIntFromConfig(ConfigSection(),_L("Marker"),marker);

	INFO_PRINTF2(_L("Setting marker to %d"), marker);

	iServer->iSendPacket.SetMarker(marker);

	return TestStepResult();

	}

TVerdict CMarker::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt marker;

	GetIntFromConfig(ConfigSection(),_L("Marker"),marker);

	TInt gotMarker = iServer->iPacket->Marker();

	INFO_PRINTF3(_L("Marker is %d should be %d"), gotMarker, marker);

	if (gotMarker != marker)

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CExtension::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt extension;

	GetIntFromConfig(ConfigSection(),_L("Extension"),extension);

	TInt gotExtension = iServer->iPacket->ExtensionPresent();

	INFO_PRINTF3(_L("Extension is %d should be %d"), gotExtension, extension);

	if (gotExtension != extension)

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CFlags::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt rawFlags; // big-endian from packet

	GetIntFromConfig(ConfigSection(),_L("Flags"),rawFlags);

	TUint32 flags = CTrtpServer::Swap32(static_cast<TUint32>(rawFlags));

	TUint32 gotFlags = iServer->iPacket->Flags();

	INFO_PRINTF3(_L("Flags is %d should be %d"), gotFlags, flags);

	if (gotFlags != flags)

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CSetFlags::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt rawFlags;

	GetIntFromConfig(ConfigSection(),_L("Flags"),rawFlags);

	TUint32 flags = CTrtpServer::Swap32(static_cast<TUint32>(rawFlags));

	INFO_PRINTF2(_L("Setting flags to %d"), flags);

	iServer->iSendPacket.SetFlags(flags);

	return TestStepResult();

	}

TVerdict CSequenceNumber::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt sequenceNumber;

	GetIntFromConfig(ConfigSection(),_L("SequenceNumber"),sequenceNumber);

	TInt gotSequenceNumber = iServer->iPacket->SequenceNumber();

	INFO_PRINTF3(_L("SequenceNumber is %d should be %d"), gotSequenceNumber, sequenceNumber);

	if (gotSequenceNumber != sequenceNumber)

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CTimestamp::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt timestamp;

	GetIntFromConfig(ConfigSection(),_L("Timestamp"),timestamp);

	TInt gotTimestamp = iServer->iPacket->Timestamp();

	INFO_PRINTF3(_L("Timestamp is %d should be %d"), gotTimestamp, timestamp);

	if (gotTimestamp != timestamp)

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CSSRC::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt SSRC;

	GetIntFromConfig(ConfigSection(),_L("SSRC"),SSRC);

	TInt gotSSRC = iServer->iPacket->SSRC();

	INFO_PRINTF3(_L("SSRC is %d should be %d"), gotSSRC, SSRC);

	if (gotSSRC != SSRC)

		SetTestStepResult(EFail);

	return TestStepResult();

	}

TVerdict CSetTimestamp::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	TInt timestamp;

	GetIntFromConfig(ConfigSection(),_L("Timestamp"),timestamp);

	INFO_PRINTF2(_L("Setting timestamp to %d"), timestamp);

	iServer->iSendPacket.SetTimestamp(timestamp);

	return TestStepResult();

	}

TVerdict COpenSession::doTestStepPreambleL()

	{

	SetTestStepResult(EPass);

	User::LeaveIfError(iServer->iFs.Connect());

	User::LeaveIfError(iServer->iSocketServer.Connect());

	iServer->iScheduler = new (ELeave) CActiveScheduler;

	CActiveScheduler::Install(iServer->iScheduler);

	return TestStepResult();

	}

TVerdict COpenSession::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	iIgnoreIncrease = 1;

	TInetAddr localAddress(KInetAddrLoop, 9000);

	TInetAddr remoteAddress(KInetAddrLoop, 9002);

	if (!iServer->iConnected)

		{

		iServer->iSession.OpenL(iServer->iSocketServer, localAddress, remoteAddress, 

								KDefaultMaxPcktSize);

		}

	else

		{

		TRequestStatus status;

		User::LeaveIfError(iServer->iRtpSocket.Open(iServer->iSocketServer, 

									   localAddress.Family(),

									   KSockDatagram, KProtocolInetUdp));

		User::LeaveIfError(iServer->iRtpSocket.Bind(localAddress));

		iServer->iRtpSocket.Connect(remoteAddress, status);

		User::WaitForRequest(status);

		iServer->iSession.OpenL(iServer->iRtpSocket, KDefaultMaxPcktSize);

		}

	CleanupClosePushL(iServer->iSession);

	// Check that send sources can be opened and closed

	iServer->iSendSource = iServer->iSession.NewSendSourceL();

	iServer->iSendSource.Close();

	iServer->iSendSource = iServer->iSession.NewSendSourceL();

	iServer->iSendSource.SetDefaultPayloadSize(KDefaultMaxPcktSize);

	CleanupStack::Pop();

	return TestStepResult();

	}

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

TVerdict COpenSession2::doTestStepPreambleL()

	{

	SetTestStepResult(EPass);

	User::LeaveIfError(iServer->iFs.Connect());

	User::LeaveIfError(iServer->iSocketServer.Connect());

	iServer->iScheduler = new (ELeave) CActiveScheduler;

	CActiveScheduler::Install(iServer->iScheduler);

	return TestStepResult();

	}

TVerdict COpenSession2::trtpDoTestStepL()

	{

	SetTestStepResult(EPass);

	iIgnoreIncrease = 1;

	TInetAddr localAddress(KInetAddrLoop, 9000);

	TInetAddr remoteAddress(KInetAddrLoop, 9002);

	//RConnection iConnection;

	TRequestStatus status;

	User::LeaveIfError(iServer->iConnect.Open(iServer->iSocketServer));

	iServer->iConnect.Start(status);

	User::WaitForRequest(status);

	if(status.Int() != KErrNone)

	{

		SetTestStepResult(EFail);

		return TestStepResult();

	}

	// Create the container for all sub connection parameters

	RSubConParameterBundle subconParams;

	CleanupClosePushL(subconParams);

 	// Create a container for RTP sub connection parameters (Param bundle takes ownership)

	CSubConParameterFamily* subConFamily = CSubConParameterFamily::NewL(subconParams, KProtocolExtensionFamily);

 	// Create the requested generic parameter set for RTP (RTP family takes ownership)

	CSubConRTPGenericParamSet* reqGenericParams = CSubConRTPGenericParamSet::NewL(*subConFamily, CSubConParameterFamily::ERequested);

	TUid idRTP = TUid::Uid(KRtpFlowImplementationUid);

	// Set the requested Generic Parameters

	reqGenericParams->SetProtocolUIDRtp(idRTP);

	reqGenericParams->SetBandWidth(1234);

	reqGenericParams->SetRtptimeConversion(100);

	reqGenericParams->SetRtpAutoSend(EFalse);

	reqGenericParams->SetRtpTimeNow(0);

	reqGenericParams->SetMaxDropOut(3000);

	reqGenericParams->SetMinSequencial(3);

	reqGenericParams->SetMaxMisorder(100);

	reqGenericParams->SetServiceProtocolID(KProtocolInetUdp);

	reqGenericParams->SetLowerSubConnType(RSubConnection::EAttachToDefault);

	reqGenericParams->SetCNAMEL(KRtpSessionCNAME());

	TUid idTier = TUid::Uid(2048);

	reqGenericParams->SetTierID(idTier);

	User::LeaveIfError(iServer->iSubConnect.Open(iServer->iSocketServer,RSubConnection::ECreateNew,iServer->iConnect));

	// Set Properties of the sub-connection

	User::LeaveIfError(iServer->iSubConnect.SetParameters(subconParams));

	// Destroy parameters

	CleanupStack::PopAndDestroy();         // subconParams

	if (!iServer->iConnected)

		{

		iServer->iSession.OpenL(iServer->iSocketServer, localAddress, remoteAddress,

									KDefaultMaxPcktSize, iServer->iSubConnect,

									EPriorityNormal, KNullDesC8);

		}

/*	else

		{

		TRequestStatus status;

		User::LeaveIfError(iServer->iRtpSocket.Open(iServer->iSocketServer, 

									   localAddress.Family(),

									   KSockDatagram, KProtocolInetUdp));

		User::LeaveIfError(iServer->iRtpSocket.Bind(localAddress));

		iServer->iRtpSocket.Connect(remoteAddress, status);

		User::WaitForRequest(status);

		iServer->iSession.OpenL(iServer->iSubConnect,iServer->iRtpSocket, KDefaultMaxPcktSize);

		}*/

	CleanupClosePushL(iServer->iSession);

	// Check that send sources can be opened and closed

	iServer->iSendSource = iServer->iSession.NewSendSourceL();

	iServer->iSendSource.Close();

	iServer->iSendSource = iServer->iSession.NewSendSourceL();

	iServer->iSendSource.SetDefaultPayloadSize(KDefaultMaxPcktSize);

	CleanupStack::Pop();