--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnp/upnpstack/dlnawebserver/inc/upnphttpchunkfiletransferreader.h	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,183 @@
+/** @file
+* Copyright (c) 2005-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:  CUpnpHttpChunkFileTransferReader is a class responsible for 
+*                asynchronous TCP reading and controlling the encoded data
+*
+*/
+
+
+
+#ifndef C_CUPNPHTTPCHUNKFILETRANSFERREADER_H
+#define C_CUPNPHTTPCHUNKFILETRANSFERREADER_H
+
+
+#include <e32base.h>
+#include <in_sock.h>
+#include <f32file.h>
+
+
+class CUpnpTcpSession;
+class CUpnpHttpFileTransferBuffer;
+class CUpnpHttpFileAccess;
+class CUpnpHttpFileTransferReader;
+class CUpnpHttpChunkParser;
+
+/**
+ *  CUpnpHttpChunkFileTransferReader is responsible for asynchronous reading.
+ *  It reads chunked-encoded data and process it  
+ *  @lib DLNAWebServer.lib
+ *  @since Series60 3.2
+ */
+NONSHARABLE_CLASS (CUpnpHttpChunkFileTransferReader) : public CUpnpHttpFileTransferReader
+    {
+
+public: // Constructors and destructors
+    
+    /**
+    * CUpnpHttpChunkFileTransferReader factory method.
+    * @since Series60 3.2
+    * @param aSession session that runs and supervises reader.
+    * @param aSocket socket from which data will be read.
+    * @param aPriority priority with which the reader will be working.
+    * @param aReadPortion - size of the buffer to read from the socket
+    * @param aBufferSize - the buffer size
+    * @return new CUpnpHttpChunkFileTransferReader object's instance.
+    */
+    static CUpnpHttpChunkFileTransferReader* NewL( CUpnpTcpSession& aSession,
+                                        RSocket& aSocket,
+                                        TThreadPriority aPriority,                                        
+                                        TInt aReadPortion,
+                                        TInt aBufferSize);
+    
+    /**
+    * Virtual destructor.
+    * @since Series60 3.2
+    */                             
+    virtual ~CUpnpHttpChunkFileTransferReader();             
+     
+
+private: // Constructors and destructors
+
+    /**
+    * CUpnpHttpChunkFileTransferReader constructor.
+    * @since Series60 3.2
+    * @param aSession session that runs and supervises reader.
+    * @param aSocket socket from which data will be read.
+    * @param aPriority priority with which the reader will be working.
+    * @param aHandle handle for logging for this thread.
+    * @param aPriority priority with which the reader will be working.
+    * @param aReadPortion - size of the buffer to read from the socket
+    * @param aBufferSize - the buffer size
+    */
+    CUpnpHttpChunkFileTransferReader( CUpnpTcpSession& aSession,
+                           RSocket& aSocket,
+                           TThreadPriority aPriority,
+                           TInt aReadPortion,
+                           TInt aBufferSize);
+    /**
+    * By default Symbian 2nd phase constructor is private.
+    * @since Series60 3.2
+    */
+    void ConstructL();
+    
+    /**
+    * Remaing number of bytes to read.
+    * @since Series60 3.2    
+    * @return TInt
+    */
+    TInt RemainingBytes();
+    
+    /**
+    * Starts reading in asynchronous mode.
+    * @since Series60 3.2
+    */
+    void StartL();   
+
+private:
+
+    /**
+    * Issues reading in asynchronous mode.
+    * @since Series60 3.2
+    */
+    void RunL();
+    
+    /**
+    * Invoked when RunL leaves.
+    */
+    TInt RunError( TInt aErr );
+    
+    /**
+     * Parse - decodes chunked-encoding     
+     * @since S60 3.2
+     * @param buffer
+     * @param position in the buffer
+     * @return error code
+     */
+    TInt Parse( TDes8& aBuffer, TInt& aPos );
+   
+protected:
+
+	/**
+    * Bytes to be read from the socket
+    * @since Series60 3.2    
+    * @return TInt
+    */
+    TInt ReadBufferSize();   
+    
+    /**
+    * Handle buffer of data
+    * @since Series60 3.2    
+    * @return TBool if all data handled
+    */
+    TBool HandleL();   
+    
+    /**
+    * Finish the session
+    * @since Series60 3.2
+    */
+    void Finish();  
+    
+    
+    /**
+    * Reads from socket
+    * @since Series60 3.2    
+    */
+    void ReadFromSocket();
+    
+    /**
+    * Resets the reader
+    * @since Series60 3.2    
+    */
+    void Reset();
+
+    /**
+    * Handles read data - trims the buffer and save data to file
+    * @since Series60 5.0
+    * @return TInt 
+    */
+    TInt HandleReadDataL( TInt aPieceToRead );
+                      
+private: 
+
+	//parser for chunked-encoding
+    CUpnpHttpChunkParser* iParser;
+
+    //decoded data
+    TInt iDecoded;    
+    };
+
+
+#endif // C_CUPNPHTTPCHUNKFILETRANSFERREADER_H
+
+// End Of File