--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/browserutilities/downloadmgr/DownloadMgrServEng/Inc/BuffStorage.h	Mon Mar 30 12:54:55 2009 +0300
@@ -0,0 +1,180 @@
+/*
+* 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 CActive
+    {
+    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
+
+    /**
+    * Cancels the timer.
+    * @param 
+    * @return
+    */
+    void DoCancel();
+    
+    /**
+    * Handles an active object’s request completion event.
+    * @param 
+    * @return
+    */
+    void RunL();
+    
+    /**
+    * Persist received chunk
+    * @since Series 60 v2.8
+    * @param aBuf new chunk to be added
+    * @return EFalse if content-length had to be updated.
+    */
+    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;
+    CActiveSchedulerWait iWait;
+    
+    // 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