diff -r 000000000000 -r bde4ae8d615e os/mm/devsound/sounddevbt/src/A2dpBlueTooth/headsetaudioif/RTPStreamer.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/os/mm/devsound/sounddevbt/src/A2dpBlueTooth/headsetaudioif/RTPStreamer.h	Fri Jun 15 03:10:57 2012 +0200
@@ -0,0 +1,118 @@
+// 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
+