/*
* Copyright (c) 2005 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:  Definition of the S60 Audio Stream Source custom command msg cods.
*
*/


#ifndef __S60STREAMINGSOURCE_H__
#define __S60STREAMINGSOURCE_H__

// Standard EPOC32 includes required by this header file
#include <e32base.h>
#include <e32std.h>
// DevSound includes
//#include <d32snd.h>
#include <e32hal.h>
#include <e32svr.h>
#include <implementationproxy.h> // ECom

#include "S60StreamingSourceUIDs.hrh"

// Public Media Server includes
#include <mmfdatasink.h>
#include <mmfdatasource.h>
#include <mmfdatapath.h>
#include <mmfdatasourcesink.hrh>
#include <mmfaudioiointerfaceuids.hrh>

#include <mmffourcc.h>

// FORWARD DECLARATIONS
class CDataBufferQueueItem;
class CReadRequest;

// CLASS DECLARATION

class CS60StreamingSource : public MDataSource
	{
	public:
		IMPORT_C static CS60StreamingSource* NewL(TUid aType);
		IMPORT_C static CS60StreamingSource* NewLC(TUid aType);

		virtual void ConstructSourceL(  const TDesC8& /*aInitData */);

		virtual TUid DataSourceType() const;
		virtual TFourCC SourceDataTypeCode(TMediaId /*aMediaId*/);
		virtual TInt SetSourceDataTypeCode(TFourCC /*aSourceFourCC*/, TMediaId /*aMediaId*/);
		virtual void FillBufferL(CMMFBuffer* /*aBuffer*/, MDataSink* /*aConsumer*/,TMediaId /*aMediaId*/);
		virtual void BufferEmptiedL(CMMFBuffer* /*aBuffer*/); //called by MDataSink to pass back emptied buffer to the source
		virtual TBool CanCreateSourceBuffer();
		virtual CMMFBuffer* CreateSourceBufferL(TMediaId /*aMediaId*/, TBool &/*aReference*/);

		virtual CMMFBuffer* CreateSourceBufferL(TMediaId aMediaId, CMMFBuffer& /*aSinkBuffer*/, TBool &aReference);


		virtual void SourceStopL();

		virtual void SourceCustomCommand(TMMFMessage& aMessage);

		void HandleFillBuffer(CMMFBuffer* aBuffer, MDataSink* aConsumer);

		IMPORT_C TBool IsSeekingSupported();

		IMPORT_C TBool IsRandomSeekingSupported();

	private:
		CS60StreamingSource(TUid aType);
		~CS60StreamingSource(void);
		void ConstructL (void);

	private: // Data

        // Queue of data buffers to be processed
        TSglQue<CDataBufferQueueItem>* iDataBufferQueue;

        TSglQue<CReadRequest>* iReadRequestQueue;

		TBool iHandlingRequest;
        CReadRequest* iCurrentRequest;

        CDataBufferQueueItem* iSrcBuffer;
	};

#endif // __S60STREAMINGSOURCE_H__

//  End of File