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

// RTP Pint Implementation

// 

//

/**

 @file

 @internalComponent

*/

#include <e32std.h>

#include <ecom/ecom.h>

#include <ecom/implementationproxy.h>

#include "rtppint.h"

#include "rtpflow.h"

#include "rtcpflow.h"

using namespace ESock;

class CRtpController;

// RTP Protocol-Interface

CRtpProtocolIntf::CRtpProtocolIntf(CProtocolIntfFactoryBase& aFactory,const Messages::TNodeId& aId)

: CProtocolIntfBase(aFactory,aId)

	{

	}

void CRtpProtocolIntf::DoFlowCreated(CSubConnectionFlowBase&  )

	{

	/* nothing to Do Here */

	return;

	}

void CRtpProtocolIntf::DoFlowBeingDeleted(CSubConnectionFlowBase& aFlow)

	{

	/* The flows shud be removed from the Hash Table */

	TInt sz = iFlowArray.Count();

	for(TInt i=0; i < sz; i++)

		{

		/* When RTP Flow is removed. We remove the entry from the hash table.

		 * When RTCP Flow is removed this entry is still maintained        */

		if(iFlowArray[i].GetRtpFlow() == &aFlow)

			{

			iFlowArray.Remove(i);

			return;

			}

		}

	return;

	}

void CRtpProtocolIntf::RegisterSubConnProvIDL(CRtpBaseFlow* aRtpBaseflow, const Messages::TNodeId& aScprId)

	{

	TRtpFlowHolder *pFlowHolder;

	/* Query if the flow Created was RTP or RTCP */

	/* Verify the flow Creation Order is Correct */

	/* Initialise RTP and RTCP flows with proper params */

	pFlowHolder = FindInFlowArray(aScprId);

	if(!pFlowHolder)

		{	

		/* This flow is an RTP Flow */

		TRtpFlowHolder flowHolder(aScprId);

		flowHolder.SetRtpFlow(static_cast<CRtpFlow*>(aRtpBaseflow));

		iFlowArray.AppendL(flowHolder);

		}

	else

		{

		/* This flow is RTCP. The fact that pHolder exists means

		 an RTP Socket was already opened */

		pFlowHolder->SetRtcpFlow(static_cast<CRtcpFlow*>(aRtpBaseflow));

		/* Here ask the RTP Flow to create an RTCP Sender.

		   Pass on the Parameters to RTCP Flow */

		CRtpFlow *pRtpFlow   = pFlowHolder->GetRtpFlow();	

		CRtcpFlow *pRtcpFlow = pFlowHolder->GetRtcpFlow();

		pRtcpFlow->SetRtpSession(pRtpFlow->GetRtpSession());

		}

	}

//Tries to find a FlowHolder belonging to the supplied SCPR. Will return a

//pointer to the flowholder or NULL if cannot be found 

TRtpFlowHolder* CRtpProtocolIntf::FindInFlowArray(const Messages::TNodeId& aScprId)

	{

	TInt sz = iFlowArray.Count();

	for(TInt i=0; i < sz; i++)

		{

		if(iFlowArray[i].ScprId() == aScprId)

			{

			return &iFlowArray[i];

			}

		}

    return 0;	

	}

CRtpProtocolIntf::~CRtpProtocolIntf()

	{

	iFlowArray.Close();

	}