/*

* 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 CACHESOURCE_H

#define CACHESOURCE_H

#include <e32base.h>

#include <DataSourceConfigIntfc.h>

#include <MultimediaDataSource.h>

// FORWARD DECLARATIONS

class MDataSource;

class CSinkQueueItem;

class CReadWriteRequestAO;

class CDataSourceConfigIntfc;

class CMMFDataBuffer;

// CLASS DECLARATION

class CMDataSourceObserver : public MMultimediaDataSourceObserver

    {

    public:

      static CMDataSourceObserver* NewL(

            CMultimediaDataSource* aDataSource

            ,CMultimediaDataSource* aParent );

        virtual ~CMDataSourceObserver();

    private:

        CMDataSourceObserver(CMultimediaDataSource* aDataSource ,CMultimediaDataSource* aParent);

        void ConstructL();

        void BufferFilled( CMMFBuffer* aBuffer );

        // KStreamControlEventSeekingSupportChanged

        // KStreamControlEventRandomSeekingSupportChanged

        // KMultimediaDataSourceObserverEventSourceSizeChanged

        void Event( TUid aEvent );

        // Returns BITRATE. This is used for calculation how much of data need to be

        // buffered by the source before filling observer buffers.

        TInt GetBitRate( TUint& aBitRate );

        CMultimediaDataSource* iDataSource;

        CMultimediaDataSource* iParent;

    };

class CCacheSource : public CMultimediaDataSource

                            //,public MCacheCopyEngineObserver

    {

    public:

        IMPORT_C static CCacheSource* NewL( CMultimediaDataSource* aDataSource, CDataSourceConfigIntfc* aDataSourceConfig );

        // 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);

        // From MCustomInterface

        TAny* CustomInterface( TUid aInterfaceUid );

       /* Seeking Interface */

        // Returns true if byte position can be reset to zero.

        // Valid in all states

        TInt GetSeekingSupport( TBool& aSeekSupport );

        // Returns true if byte position can be set anywhere between zero and

        // GetSize().

        // Valid in all states

        TInt GetRandomSeekingSupport( TBool& aSeekSupport );

        // Moves read position pointer to byte location requested by the observer

        // between zero and GetSize(). If the size specified is out of range, this

        // function returns KErrArgument.

        TInt Seek( TUint aPosInBytes );

        // From CMultimediaDataSource ends

        TInt ServiceBufferFilled( CMMFBuffer* aBuffer );

        void ReadRequestComplete(CReadWriteRequestAO* aRequest,TRequestStatus& aStatus);

        ~CCacheSource();

    private:

        CCacheSource(CMultimediaDataSource* aDataSource, CDataSourceConfigIntfc* aDataSourceConfig);

        void ConstructL (void);

        TInt EmptySinkQueue();

        TInt AppendBufferToSinkQueue( CMMFBuffer* aBuffer );

        TInt ServiceFillBuffer();

    private: // Data

        // Queue of data buffers from client

        TSglQue<CSinkQueueItem>* iSinkQueue;

        // Reference to MMultimedia data source

        MMultimediaDataSourceObserver* iObserver;

        CMDataSourceObserver* iDataSourceObserver;

        // Parent DataSource to Talk to

        CMultimediaDataSource* iDataSource;

        // Sink item Counter

        TInt iSnkItemsCount;

        //Temp File to Store Data

        RFile iFile;

        //Session to File server.

        RFs iFs;

        //File Name and Path for the Temp file

        TFileName iFileName;

        //Last Buffer Flag

        TBool iLastBufferWritten;

        //Size of the Temp File

        TInt iFileSize;

        // Number of bytes copied to controller so far

        TUint iSnkBytes;

        CMMFDataBuffer* iTransferBuffer;

        CDataSourceConfigIntfc* iDataSourceConfig;

        CReadWriteRequestAO* iReadRequest;

        CReadWriteRequestAO* iWriteRequest;

        CDataSourceConfigIntfc::TCacheType iCacheType;

        CMMFDataBuffer* iDataBuffer;

        HBufC*          iCacheLocation;

        TInt            iAbsBufferStart;

        TInt            iAbsBufferEnd;

        TInt            iBufferReadPos;

        TInt            iSeekStart;

        TInt            iSeekEnd;

        TInt            iAbsBufferReadPos;

    };

#endif // CACHESOURCE_H

    //  End of File