--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mmfenh/enhancedmediaclient/Plugins/DataBufferSource/inc/DataBufferDataSource.h	Tue Feb 02 01:08:46 2010 +0200
@@ -0,0 +1,200 @@
+/*
+* 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