/*
* 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 the License "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:  Implements storage functionality in the DownloadManager
*
*/



#ifndef BUFFSTORAGE_H
#define BUFFSTORAGE_H

//  INCLUDES
#include <e32base.h>


// FORWARD DECLARATIONS
class CHttpDownload;
class CHttpStorage;
class RFotaEngineSession;
class RWriteStream;
class CDocumentHandler;
class CBuffStorage;

// CLASS DECLARATION

/**
*  ?one_line_short_description.
*  ?other_description_lines
*
*  @lib ?library
*  @since Series 60 v2.8
*/


NONSHARABLE_CLASS( CBuffStorage ) : public CBase
    {
    public:  // Constructors and destructor
    
            
    /**
     * Two-phased constructor.
     */
    static CBuffStorage* NewL( CHttpStorage* aStorage );
    
   /**
    * Destructor.
    */
    ~CBuffStorage();
    
    public: // Interface
    
    /**
    * Delets the storage buffers.
    * @param 
    * @return
    */
    void ResetBuffers();
    
	/**
    * Persist received chunk
    * @since Series 60 v2.8
    * @param aBuf new chunk to be added
    * @return EFalse if content-length had to be updated.
    */
    TBool WriteOutNextBodyDataL( const TDesC8& aBuf );
    
    /**
    * If buffering enabled, flush data to disk
    */
    void FlushBuffersL();
    
    /**
    * Returns buffer size
    * @since Series 60 v2.8
    * @param 
    * @return  Buffer size.
    */
    const TInt& CurrentBufferSize() { return iBufferSize; }
    
    /**
    * Clear the error encountered during writing to file
    * @since Series 60 v2.8
    * @param 
    * @return  Buffer size.
    */
    void ClearErrors() { iLastWriteErrorCode = KErrNone; }
        

    protected:  // Functions from base classes

    
    private: // From CActive

    void DoBufferingWriteL(const TDesC8& aBuf);
    void DoNonbufferingWriteL(const TDesC8& aBuf);
    
    private:              
    /**
     * C++ default constructor.
     */
    CBuffStorage(CHttpStorage*);
    
    /**
     * By default Symbian 2nd phase constructor is private.
     */
    void ConstructL();
	
	public:     // Data
	
	friend class CBuffStorage;
    
    
    protected:  // Data


    private:
    
    // Double-buffering
    HBufC8* iBuff1, *iBuff2;
    HBufC8* iClientBuffer;
    TPtr8 *iWritePtr;
    TInt iBufferSize;
    
    // For stalling condition handling
    TInt iLastWriteErrorCode;
    
    // References to CHttpStorage data
    RFile*& iFile;
    TInt32& iDownloadedSize; // How much data actually written to finally
    TInt32& iBufferedSize;   // How much data received over the air (but not necessarily all in file yet)
    
    TInt& iHttpStorageBufferSize;
    TInt32& iHttpStorageLength;
    TBool& iBufferingEnabled;
    TBool& iProgressiveDownload;
    
#ifdef __SYNCML_DM_FOTA
    RWriteStream*& iFotaStream;
#endif // __SYNCML_DM_FOTA

    };
    


    
#endif      // BUFFSTORAGE_H   
            
// End of File