// 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 Flow definitions.

// 

//

/**

 @file

 @internalComponent

*/

#ifndef CRTPFLOW_H

#define CRTPFLOW_H

#include "rtpprovisioninfo.h"

#include "rtpbaseflow.h"

#include "rtpcontroller.h"

const TInt KRtpDefBufSz = 1500;

NONSHARABLE_CLASS(CRtpFlow) : public CRtpBaseFlow 

	{

	/** CRtpFlow implements the RTP Flow.

	@internalComponent 

	**/				    

	friend class CRtpFlowFactory;	

	public:

	static CRtpFlow* NewL(CSubConnectionFlowFactoryBase& aFactory, 

	                       const Messages::TNodeId& aSubConn,  

	                       CProtocolIntfBase* aProtocolIntf);

	public:

	//CSubConnectionFlowBase

	virtual void ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage);

	virtual TInt  Write(RMBufChain& aData, TUint aOptions, TSockAddr* anAddr = NULL );

	virtual TInt GetData(RMBufChain& aData, TUint aLength,TUint aOptions,TSockAddr* anAddr=NULL);

	/*MRtpDataSender*/

	void SendData(TDes8& aBuffer, TSockAddr &aAddr, TInt aFlags, TRequestStatus  &aStatus);

	public:

	virtual void NewData(TUint aCount);

	virtual void CanSend();

	virtual void DoCanClose(MSessionControlNotify::TDelete aDelete);

	virtual void DoUpdateLocalAddress(const TSockAddr& anAddr);

	virtual TInt DoSetOption(TUint level, TUint name, const TDesC8 &anOption);

	virtual TInt DoGetOption(TUint level, TUint name, TDes8 &anOption) const;

	/* When an RTCP flow is created call this function to enable RTCP in

	   RtpSession. The function will return a Pointer to RTPSession which

	   can be passed on to RTCP Flow */

	CRtpController* GetRtpSession() const;

	void SetNonRtpSendData(TInt aNonRtpData);

 	TInt NonRtpSendData();

	virtual ~CRtpFlow(); 

	protected:

	CRtpFlow(ESock::CSubConnectionFlowFactoryBase& aFactory, const Messages::TNodeId& aSubConnId, ESock::CProtocolIntfBase* aProtocolIntf);

	/* RTP Session Pointer */

	CRtpController *iRtpSession;

	void ConstructL();

	/* Worker for Provision */

	void DoProvisionL(const CRtpProvisionConfig *apRtpProv);

	/* This buffer is used to pass data to rtp Stack.*/

	RBuf8 iRtpBuffer;

	// Non Rtp Data sending flag

	TInt iNonRtpSendData;

	/* Handlet For RTP Flow */

	CCFRtpHandler *iRtpHandler;	

};

#endif // CRTPFLOW_H