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

//

#ifndef __RTPSTREAMER_H__

#define __RTPSTREAMER_H__

#include <e32base.h>

#include <es_sock.h> //RSocketServer, RSocket

#include <rtp.h>

const TUint KRTPHeaderSize = 12;

const TUint KSendBucketSize = 4;//sets number of internally buffered audio frames	

class CMMFCodec; //fwd ref

class CAudioBufferArray;

class TSBCFrameParameters;

class CA2dpCodecUtilities;

/**

Callback class implemented by CA2dpBTHeadsetAudioInterface to get error events

back from CActiveRTPStreamer

*/

class MRTPStreamerObserver

	{

public:

/**

Callback when the CRtpSendPackets detects an error condition

event

@internalComponent

@param aError standard SymbianOS error

*/

	void virtual RTPStreamerEvent(TInt aError) = 0;

	};

/**

RTP Streamer used by the CA2dpBTHeadsetAudioInterface.

This class is used by the CA2dpBTHeadsetAudioInterface in order to stream

buffers of audio to the headset.  The CActiveRTPStreamer can buffer a number

of buffers internally set by the KSendBucketSize.

@internalComponent

*/

NONSHARABLE_CLASS(CActiveRTPStreamer) : public CTimer

	{

public:

	static CActiveRTPStreamer*	NewL(RSocket& aSock, MRTPStreamerObserver& aRTPStreamerObserver);

	~CActiveRTPStreamer();

	//callbacks from RTP	

	static void RTPCallback(CActiveRTPStreamer* aStreamer, const TRtpEvent& aEvent);

	static void RTPSendSourceCallback(CActiveRTPStreamer* aStreamer, const TRtpEvent& aEvent);

	void SetCodec(CMMFCodec& aCodec);

	void SetAudioConfiguration(const CA2dpAudioCodecConfiguration& aAudioCodecConfiguration);

	void Send(const TDesC8& aData, TRequestStatus& aStatus);

	void Pause();

	void Resume();

	void CancelLastSendBuffer();

	void FlushPendingSendBuffers();

	TUint BytesSent() const;

	void ResetBytesSent();

private:

	CActiveRTPStreamer(MRTPStreamerObserver& aRTPStreamerObserver);

	void ConstructL(RSocket& aSock);	

	void InitializeForSendL(const TDesC8& aData);

	TUint CodecProcessPayloadL(const TDesC8& aData, TDes8& aPayload);

	void PacketSent(TRtpEventType aEvent);

	void RTPSessionEvent(const TRtpEvent& aEvent);

	void CompleteSendRequestStatus(TInt aError);

	//CActive

	void RunL();

	void DoCancel();

private:	

	MRTPStreamerObserver& iRTPStreamerObserver;

	CAudioBufferArray*	iAudioBufferArray; //this class is owned

	TTimeIntervalMicroSeconds32	iRTPPacketDuration;

	RRtpSession			iRTPSession;

	RRtpSendSource		iRTPSendSource;

	TRtpEventType		iRTPEventType;

	TBool				iRtpCanSend;

	TRequestStatus*		iSendStatus;

	TUint iMaxMTULength;

	TUint iFrameLength;

	TUint iBufferLength;

	TUint iNumberOfInputBytesToMakeRTPPacket;

	TUint8 iPayloadType;

	TUint iTimeStampIncrement;

	TUint iTimeStamp;

	TBuf8<4> iMediaPayloadHeader;

	TUint iBitRate;

	TUint iBytesSent;

	TBool iBufferParamsInitialized;

	TBool iPaused;

	TInt iUnrecoverableError;

	TUint iSendBufferSize;

	//these classes aren't owned

	CMMFCodec* iCodec;

	CA2dpAudioCodecConfiguration* iA2dpAudioCodecConfiguration;	

	};

#endif