// Copyright (c) 2006-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 __METADATAFILEWRITER_H

#define __METADATAFILEWRITER_H

//  INCLUDES

#include <e32base.h>

#include <3gplibrary/mp4lib.h>

#include "mp4atom.h"

// FORWARD DECLARATIONS

class RFile64;

#define NUM_MDF      10     /* Number of temporary metadata files */

// CLASS DECLARATION

NONSHARABLE_CLASS(CMetaDataWriterBuffer) : public CBase

    {

    public:  // Constructors and destructor

        inline CMetaDataWriterBuffer() : iData( NULL ), iOutputFileNum( -1 ) {}

        inline CMetaDataWriterBuffer( HBufC8& aBuffer, 

                            const TInt aOutputFileNum) 

                            : iData(&aBuffer), iOutputFileNum(aOutputFileNum) {}

        /**

        * Destructor.

        */

        ~CMetaDataWriterBuffer();

    public:

        HBufC8* iData;

        TInt iOutputFileNum;

    };

/**

*  Async buffering file writer.

*/

NONSHARABLE_CLASS(CMetaDataFileWriter) : public CActive

    {

    public: // Constructors and destructor

        /**

        * Two-phased constructor.

        */

        static CMetaDataFileWriter* NewL( );

        /**

        * Destructor.

        */

        ~CMetaDataFileWriter();

    public: // New functions

        /**

        * Writes incoming buffer data to internal buffers for writing to disk.

        * @since 2.6

        * @param aFileNumber Index of file the data is to be written

        * @param aBuf Data to be written

        * @return Error code, KErrNone if no errors, otherwise one of the system wide error codes.

        */

        TInt Write( RFile64& aFile, const TInt aFileNumber, const TDesC8& aBuf );

        /**

        * Flush internal buffers to disk.

        * @since 2.6

        * @return Error code, KErrNone if no errors, otherwise one of the system wide error codes.

        */

        TInt Flush();

        /**

        * Reads data from internal buffers that have not yet been written to disk.

        * @since 5.0

        * @param aFileNumber Index of file

        * @param aBuf Data to be written

        * @param bytestoread Number of bytes to readData

        * @return number of bytes read

        */

        TInt ReadBuffer( const TInt aFileNumber, TDes8& aBuf, TInt bytestoread );

    protected: // Functions from base classes

        /**

        * From CActive Cancels async request.

        */

        void DoCancel();

        /**

        * From CActive Called when async request completes.

        */

	    void RunL();

	    /**

	    * Called when errors in RunL force Leave. 

	    */

	    TInt RunError(TInt aError);

private:

        /**

        * C++ default constructor.

        */

        CMetaDataFileWriter();

        /**

        * By default Symbian 2nd phase constructor is private.

        */

        void ConstructL( );

        /**

        * Writes incoming data to internal buffers and buffer queues..

        * @since 2.6

        * @param aFileNumber Index of file the data is to be written

        * @param aBuf Data to be added to buffers..

        * @return Error code, KErrNone if no errors, otherwise one of the system wide error codes.

        */

        TInt AddDataToBuffer(const TInt aFileNumber, const TDesC8& aBuf );

private:

		// Write error code.

	    TInt iError;

        // Whether we are flushing after async write.

    	TBool iFlush;

        // Whether the flushing is done.

    	TBool iFlushDone;

        // Array to keep file status information

        TBool iAsyncWritingOngoing;

        // Outputfiles

        RPointerArray<RFile64> iOutputFile;

        // Array of output buffers.

        RPointerArray<CMetaDataWriterBuffer> iOutputBufferQueue;

        // Array of input buffers.

        RPointerArray<CMetaDataWriterBuffer> iInputBufferArray;

        // Queue of empty write buffers.

        RPointerArray<CMetaDataWriterBuffer> iEmptyBufferQueue;

        // Array to count delivered bytes from iInputBufferArray

        TInt iInputBufferArrayDelivered[NUM_MDF];

};

#endif  //__METADATAFILEWRITER_H

// End of File