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

// Basic Test cases for RTP Flows and SCPR

// @file

// @internalAll

// 

//

#include "cfrtp_basictests.h"

#include "te_cfrtpsuitedefs.h"

#include <rtp_proto_id.h>

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <in_sock_internal.h>

#endif

CSubConStep::~CSubConStep()

/**

 * Destructor

 */

	{

	}

CSubConStep::CSubConStep()

/**

 * Constructor

 */

	{

	SetTestStepName(KSubConTestStep);

	}

TVerdict CSubConStep::doTestStepPreambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	SetTestStepResult(CTe_CfrtpSuiteStepBase::doTestStepPreambleL());

	return TestStepResult();

	}

TVerdict CSubConStep::doTestStepL()

/**

 * Try opening a SubConnection and Set RTP Params on it.

 * @return - TVerdict code

 *

 */

	{

    SetTestStepResult(EFail);

    /* Open a RSubCon and Set rtp params on it */

    RSubConnection subConnection;

	// 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(iBandWidth);

	reqGenericParams->SetRtptimeConversion(iRtpTimeConv);

	reqGenericParams->SetRtpAutoSend(iAutoSend);

	reqGenericParams->SetRtpTimeNow(iRtpTimeNow);

	reqGenericParams->SetServiceProtocolID(KProtocolInetUdp);

	reqGenericParams->SetLowerSubConnType(RSubConnection::EAttachToDefault);

	reqGenericParams->SetCNAMEL(iCName);

	iIpAddrDest1.SetPort(iDestPort1); //For RTCP ?

	reqGenericParams->SetDefDestinationAddr(iIpAddrDest1);

	TUid idTier = TUid::Uid(iTierId);

	reqGenericParams->SetTierID(idTier);

	TInt err;

	err = subConnection.Open(iSocketServ,RSubConnection::ECreateNew,iCon);

	if(KErrNone != err)

		{

		SetTestStepResult(EFail);

		}

	else

		{

		// Set Properties of the sub-connection

		TInt res = subConnection.SetParameters(subconParams);

		if(res == KErrNone)

			{

			SetTestStepResult(EPass);

			}

		}

	// Destroy parameters

	CleanupStack::PopAndDestroy();         // subconParams

	subConnection.Close();

	return TestStepResult();

	}

TVerdict CSubConStep::doTestStepPostambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	return TestStepResult();

	}

//

CRtpSockTest::~CRtpSockTest()

/**

 * Destructor

 */

	{

	}

CRtpSockTest::CRtpSockTest()

/**

 * Constructor

 */

	{

	SetTestStepName(KRtpSockTestStep);

	}

TVerdict CRtpSockTest::doTestStepPreambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	SetTestStepResult(CTe_CfrtpSuiteStepBase::doTestStepPreambleL());

	return TestStepResult();

	}

TVerdict CRtpSockTest::doTestStepL()

/**

 * @return - TVerdict code

 * Try opening a Socket on an RTP SCPR.

 */

	{

    SetTestStepResult(EFail);

    TInt err;

    if(KErrNone == CTe_CfrtpSuiteStepBase::InitSubConL())

    	{	

    	err = iRtpSocket.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolRtp, iSubCon);

    	if(KErrNone == err)

    		{

    		SetTestStepResult(EPass);

    		}

    	}

    return TestStepResult();

	}

TVerdict CRtpSockTest::doTestStepPostambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	return TestStepResult();

	}

//

CRtcpSockTest::~CRtcpSockTest()

/**

 * Destructor

 */

	{

	}

CRtcpSockTest::CRtcpSockTest()

/**

 * Constructor

 */

	{

	SetTestStepName(KRtcpSockTestStep);

	}

TVerdict CRtcpSockTest::doTestStepPreambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	SetTestStepResult(CTe_CfrtpSuiteStepBase::doTestStepPreambleL());

	return TestStepResult();

	}

TVerdict CRtcpSockTest::doTestStepL()

/**

 * @return - TVerdict code

 * Try opening both RTP and RTCP Sockets.

 */

	{

    SetTestStepResult(EFail);

    TInt err;

    if(KErrNone == CTe_CfrtpSuiteStepBase::InitSubConL())

    	{	

    	err = iRtpSocket.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolRtp, iSubCon);

    	if(KErrNone == err)

    		{

    		err = iRtcpSocket.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolRtcp, iSubCon);

    		if(KErrNone == err)

    			{

    			SetTestStepResult(EPass);

    			}

    		}

    	}

    return TestStepResult();

	}

TVerdict CRtcpSockTest::doTestStepPostambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	return TestStepResult();

	}

//

CRtpSendRecv::~CRtpSendRecv()

/**

 * Destructor

 */

	{

	}

CRtpSendRecv::CRtpSendRecv()

/**

 * Constructor

 */

	{

	SetTestStepName(KRtpSendRecvStep);

	}

TVerdict CRtpSendRecv::doTestStepPreambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	SetTestStepResult(CTe_CfrtpSuiteStepBase::doTestStepPreambleL());

	return TestStepResult();

	}

TVerdict CRtpSendRecv::doTestStepL()

/**

 * @return - TVerdict code

 */

	{

    SetTestStepResult(EFail);

    if(KErrNone == InitSocketsL())

    	{

		iIpAddrDest1.SetPort(iDestPort1);

		TBuf8<3000> sendBuf((TUint8*)"Hello World");

		TRequestStatus status;

		iRtpSocket.SendTo(sendBuf, iIpAddrDest1, NULL, status);

		User::WaitForRequest(status);

		if(status.Int() == KErrNone)

			{

			/* Now do a Receive */

			sendBuf.FillZ();

			iRtpSocket.RecvFrom(sendBuf,iIpAddrDest1,NULL,status);

			User::WaitForRequest(status);

			if(status.Int() == KErrNone)

				{

				sendBuf.SetLength(2500);

				TRequestStatus status;

				iRtpSocket.SendTo(sendBuf, iIpAddrDest1, NULL, status);

				User::WaitForRequest(status);

				if(status.Int() == KErrNone)

					{

					SetTestStepResult(EPass);	

					}

				}

			}

    	}

    return TestStepResult();

	}

TVerdict CRtpSendRecv::doTestStepPostambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	return TestStepResult();

	}

//

CRtcpSendRecv::~CRtcpSendRecv()

/**

 * Destructor

 */

	{

	}

CRtcpSendRecv::CRtcpSendRecv()

/**

 * Constructor

 */

	{

	SetTestStepName(KRtcpSendRecvTestStep);

	}

TVerdict CRtcpSendRecv::doTestStepPreambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	SetTestStepResult(CTe_CfrtpSuiteStepBase::doTestStepPreambleL());

	return TestStepResult();

	}

TVerdict CRtcpSendRecv::doTestStepL()

/**

 * @return - TVerdict code

 */

	{

    SetTestStepResult(EFail);

    if(KErrNone == InitSocketsL())

    	{

		iIpAddrDest1.SetPort(iDestPort1+1);

		TBuf8<3000> sendBuf((TUint8*)"Hello World");

		TRequestStatus status;

		iRtcpSocket.SendTo(sendBuf, iIpAddrDest1, NULL, status);

		User::WaitForRequest(status);

		if(status.Int() == KErrNone)

			{

			/* Now do a Receive */

			sendBuf.FillZ();

			iRtcpSocket.RecvFrom(sendBuf,iIpAddrDest1,NULL,status);

			User::WaitForRequest(status);

			if(status.Int() == KErrNone)

				{

				sendBuf.SetLength(2500);

				TRequestStatus status;

				iRtcpSocket.SendTo(sendBuf, iIpAddrDest1, NULL, status);

				User::WaitForRequest(status);

				if(status.Int() == KErrNone)

					{

					SetTestStepResult(EPass);	

					}

				}

			}

    	}

    return TestStepResult();

	}

TVerdict CRtcpSendRecv::doTestStepPostambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	//SetTestStepResult(EFail);  

	return TestStepResult();

	}

//

CRtpConnect::~CRtpConnect()

/**

 * Destructor

 */

	{

	}

CRtpConnect::CRtpConnect()

/**

 * Constructor

 */

	{

	SetTestStepName(KRtpConnectTestStep);

	}

TVerdict CRtpConnect::doTestStepPreambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	SetTestStepResult(CTe_CfrtpSuiteStepBase::doTestStepPreambleL());

	return TestStepResult();

	}

TVerdict CRtpConnect::doTestStepL()

/**

 * @return - TVerdict code

 */

	{

    SetTestStepResult(EFail);

    if(KErrNone == InitSocketsL())

    	{

		iIpAddrDest1.SetPort(iDestPort1);

		TRequestStatus status;

		iRtpSocket.Connect(iIpAddrDest1,status);

		User::WaitForRequest(status);

		if(status.Int() == KErrNone)

			{

			TInetAddr rem;

			iRtpSocket.RemoteName(rem);

			if(rem == iIpAddrDest1)

				{

				TBuf8<1024> sendBuf((TUint8*)"Hello World");

				iRtpSocket.Send(sendBuf, NULL, status);

				User::WaitForRequest(status);

				if(status.Int() == KErrNone)

					{

					/* Now do a Receive */

					sendBuf.FillZ();

					iRtpSocket.Recv(sendBuf,NULL,status);

					User::WaitForRequest(status);

					if(status.Int() == KErrNone)

						{

						/* Next time Connect shud fail */

						iIpAddrDest1.SetPort(iDestPort1+2);

						iRtpSocket.Connect(iIpAddrDest1,status);

						User::WaitForRequest(status);

						if(status.Int() != KErrNone)

							{

							SetTestStepResult(EPass);

							}

						}

					}	

				}

			}

    	}

    return TestStepResult();

	}

TVerdict CRtpConnect::doTestStepPostambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	return TestStepResult();

	}

//

CRtcpConnect::~CRtcpConnect()

/**

 * Destructor

 */

	{

	}

CRtcpConnect::CRtcpConnect()

/**

 * Constructor

 */

	{

	SetTestStepName(KRtpConnectTestStep);

	}

TVerdict CRtcpConnect::doTestStepPreambleL()

/**

 * @return - TVerdict code

 * Override of base class virtual

 */

	{

	SetTestStepResult(CTe_CfrtpSuiteStepBase::doTestStepPreambleL());

	return TestStepResult();

	}

TVerdict CRtcpConnect::doTestStepL()

/**

 * @return - TVerdict code

 */

	{

    SetTestStepResult(EFail);

    if(KErrNone == InitSocketsL())

    	{

		iIpAddrDest1.SetPort(iDestPort1+1);

		TRequestStatus status;

		iRtcpSocket.Connect(iIpAddrDest1,status);

		User::WaitForRequest(status);

		if(status.Int() == KErrNone)

			{

			TInetAddr rem;

			iRtcpSocket.RemoteName(rem);

			if(rem == iIpAddrDest1)

				{

				TBuf8<1024> sendBuf((TUint8*)"Hello World");

				iRtcpSocket.Send(sendBuf, NULL, status);