--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/codhandler/codeng/inc/CodBuffStorage.h	Mon Mar 30 12:54:55 2009 +0300
@@ -0,0 +1,165 @@
+/*
+* 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 double buffering storage functionality for OMA downloads
+*
+*/
+
+
+
+#ifndef COD_BUFFSTORAGE_H
+#define COD_BUFFSTORAGE_H
+
+//  INCLUDES
+#include <e32base.h>
+
+
+// FORWARD DECLARATIONS
+class CFileSaver;
+
+
+// CLASS DECLARATION
+
+/**
+*  ?one_line_short_description.
+*  ?other_description_lines
+*
+*  @lib ?library
+*  @since Series 60 v2.8
+*/
+
+
+NONSHARABLE_CLASS( CCodBuffStorage ) : public CActive
+    {
+    public:  // Constructors and destructor
+    
+            
+    /**
+     * Two-phased constructor.
+     */
+    static CCodBuffStorage* NewL( CFileSaver* aStorage );
+    
+   /**
+    * Destructor.
+    */
+    ~CCodBuffStorage();
+    
+    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.
+     */
+    CCodBuffStorage(CFileSaver*);
+    
+    /**
+     * By default Symbian 2nd phase constructor is private.
+     */
+    void ConstructL();
+
+    public:     // Data
+
+
+    protected:  // Data
+
+
+    private:
+    
+    // Double-buffering
+    HBufC8* iBuff1, *iBuff2;
+    HBufC8* iClientBuffer;
+    TPtr8 *iWritePtr;
+    TInt iBufferSize;
+    
+    // For stalling condition handling
+    TInt iLastWriteErrorCode;
+    CActiveSchedulerWait iWait;
+    
+    // References to CFileSaver data
+    RFile* iFile;
+    TInt& iDownloadedSize; // How much data actually written to finally
+    TInt32& iBufferedSize;   // How much data received over the air (but not necessarily all in file yet)
+    
+    TInt32& iHttpStorageBufferSize; //Storage buffer size 128kb(Non-progressive)/16kb(Progressive)
+    TInt32& iHttpStorageLength;     //Content Length
+    TBool& iProgressiveDownload;    //Flag to indicate Progressive play
+    };
+    
+#endif      // COD_BUFFSTORAGE_H   
+            
+// End of File