/*

* Copyright (c) 2006 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 DATABUFFERDATASOURCE_H

#define DATABUFFERDATASOURCE_H

#include <e32base.h>

#include <DRMConfigTypes.h>

// Public Media Server includes

//#include <mmfdatasink.h>

#include <mmfdatasource.h>

//#include <mmfdatapath.h>

#include <mmfdatasourcesink.hrh>

#include <mmfaudioiointerfaceuids.hrh>

#include <mmffourcc.h>

#include <MultimediaDataSource.h>

#include <DataBufferSource.h>

#include "DataCopyEngineObserver.h"

#include "ParentChildIntfc.h"

// FORWARD DECLARATIONS

class CSourceQueueItem;

class CSinkQueueItem;

class CDataCopyEngineAO;

using multimedia::TBufferingConfig;

class CDataBufferMultimediaSource;

// CLASS DECLARATION

class CDataBufferSource : public MDataSource

    {

    public:

        static CDataBufferSource* NewL( TUid aType );

        ~CDataBufferSource(void);

        // From MDataSource begins

        TUid DataSourceType() const;

        TFourCC SourceDataTypeCode( TMediaId aMediaId );

        TInt SetSourceDataTypeCode( TFourCC aSourceFourCC, TMediaId aMediaId );

        void FillBufferL( CMMFBuffer* aBuffer, MDataSink* aConsumer, TMediaId aMediaId );

        void BufferEmptiedL( CMMFBuffer* aBuffer );

        TBool CanCreateSourceBuffer();

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

        TInt SourceThreadLogon(MAsyncEventHandler& aEventHandler);

        void SourceThreadLogoff();

        void SourcePrimeL();

        void SourcePlayL();

        void SourceStopL();

        void SourceCustomCommand(TMMFMessage& aMessage);

        void ConstructSourceL(  const TDesC8& aInitData );

        // From MDataSource ends

        void SetMultimediaSource(CDataBufferMultimediaSource& aMultimediaSource);

    private:

        CDataBufferSource(TUid aType);

        void ConstructL (void);

    private:

        //Data

        CDataBufferMultimediaSource* iMultiMediaSource;        

    };

class CDataBufferMultimediaSource : public CMultimediaDataSource,

                                    public MDataCopyEngineObserver,

                                    public CParentIntfc

    {

    public:

        IMPORT_C static CDataBufferMultimediaSource* NewL(MDataSource& aDataSource);

        // From CMultimediaDataSource begins

        TInt SetObserver( MMultimediaDataSourceObserver& aObserver );

        TInt GetObserver( MMultimediaDataSourceObserver*& aObserver );

        void Event( TUid aEvent );

        TInt SetDataTypeCode(TFourCC aSourceFourCC );

        TInt GetDataTypeCode(TFourCC& aSourceFourCC );

        TInt GetSize( TUint& aSize );

        TInt Open();

        TInt Close();

        TInt Prime();

        TInt Play();

        TInt Stop();

        TInt FillBuffer( CMMFBuffer* aBuffer);

        TInt GetInterface(

                TUid aInterfaceId,

                TVersion& aVer,

                TAny*& aInterfaceImpl );

        TInt EvaluateIntent( ContentAccess::TIntent aIntent );

        TInt ExecuteIntent( ContentAccess::TIntent aIntent );

        // From CMultimediaDataSource ends

        // From MCustomInterface

        TAny* CustomInterface( TUid aInterfaceUid );

        // From MDataCopyEngineObserver begins

        // Called by iDataCopyEngineAO when item on source queue is processed

        void SourceQueueItemProcessed();

        // Called by iDataCopyEngineAO when item on sink queue is processed

        void SinkQueueItemProcessed();

        // From MDataCopyEngineObserver ends

        void SourceCustomCommand(TMMFMessage& aMessage);

        // A common function that implements FillBuffer requests

        TInt ServiceFillBuffer( CMMFBuffer* aBuffer,

            MMultimediaDataSourceObserver* aObserver,

            MDataSink* aConsumer );

        // To be called by DRMConfig Interface begins

        TInt GetDRMType( TDRMType& aDRMType );

        TInt GetAllowedOutputDeviceCount( TInt& aCount );

        TInt GetAllowedOutputDevice(

                        TInt aIndex,

                        TDRMAllowedOutputDevice& aOutputDevice );

        // To be called by DRMConfig Interface ends

    private:

        CDataBufferMultimediaSource(MDataSource& aDataSource);

        ~CDataBufferMultimediaSource(void);

        void ConstructL (void);

         // A common function that implements FillBuffer requests

        TInt AppendBufferToSinkQueue( CMMFBuffer* aBuffer,

            MMultimediaDataSourceObserver* aObserver,

            MDataSink* aConsumer );

        // Reset queues

        TInt EmptySourceQueue();

        TInt EmptySinkQueue();

        // Calculate BufferedDataSize

        void CalculateBufferdDataSize();

        // Handles SetDRMConfig custom command

        TInt HandleSetDRMConfig(  TMMFMessage& aMessage );

        // Implements SetDRMConfig custom command

        void DoSetDRMConfigL( TMMFMessage& aMessage );

        TInt DoHandleCancel( TMMFMessage& aMessage );

    private: // Data

        // Queue of data buffers from client

        TSglQue<CSourceQueueItem>* iSourceQueue;

        // Queue of buffers from controller

        TSglQue<CSinkQueueItem>* iSinkQueue;

        // Pointer to DataCopyEngineAO owned by this

        CDataCopyEngineAO* iDataCopyEngineAO;

        // Source item Counter

        TInt iSrcItemsCount;

        // Sink item Counter

        TInt iSnkItemsCount;

        // Number of bytes received from client so far

        TUint iSrcBytes;

        // Number of bytes copied to controller so far

        TUint iSnkBytes;

        // Size of source (Set by the application)

        TUint iSizeBytes;

       // FourCC

        TFourCC iSourceFourCC;

       // Reference to MMultimedia data source

        MMultimediaDataSourceObserver* iObserver;

        // Observer bit rate in bps

        TUint   iObserverBitRate;

        // Transfer bit rate in bps

        TUint   iTransferRate;

        // Buffering size in bytes

        TUint   iBufferedDataSize;

        // Holds true if last buffer is received or not

        TBool   iLastBufferReceived;

        TBufferingConfig iBufferingConfig;

        TMMFMessage* iMessage;

        /* Attributes to hold DRM Info */

        // Holds DRM Type set by client

        TDRMType iDRMType;

        // Holds list of allowed output devices set by client

        RArray<TDRMAllowedOutputDevice> iAllowedOutputDeviceList;

        // Parent MDataSource

        MDataSource* iParentDataSource;

    };

#endif // DATABUFFERDATASOURCE_H

    //  End of File