diff -r 000000000000 -r 307788aac0a8 realtimenetprots/rtp/cfrtp/src/rtppint.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/realtimenetprots/rtp/cfrtp/src/rtppint.cpp	Tue Feb 02 01:03:15 2010 +0200
@@ -0,0 +1,113 @@
+// 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();
+	}
+