diff -r 000000000000 -r f5a58ecadc66 servicediscoveryandcontrol/pnp/test/upnp/Server/Flow/inc/ctransaction.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/servicediscoveryandcontrol/pnp/test/upnp/Server/Flow/inc/ctransaction.h	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,170 @@
+// Copyright (c) 2008-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:
+// @file
+// @internalComponent
+// 
+//
+
+#ifndef __CTRANSACTION_H_
+#define __CTRANSACTION_H_
+
+// System Includes
+#include <http/framework/cheadercodec.h>
+#include <rmemchunk.h>
+
+// Local Includes
+#include "CRequest.h"
+#include "CResponse.h"
+
+ 	
+class CTransaction : public CBase
+	{
+public:
+	static CTransaction* NewL ( CHeaderCodec& aCodec, RStringPool& aStringPool );	
+	virtual ~CTransaction ( );
+	
+	CRequest* Request ( ) const;
+	CResponse* Response ( ) const;	
+	
+	inline void AddBodyPart ( RMBufChain& aData )
+		{
+		if ( !aData.IsEmpty () )
+			iBodyParts.Append ( aData );
+		}
+	
+	inline void AddBodyPart ( RMemChunk& aMemChunk )
+		{
+		if ( !aMemChunk.IsEmpty () )
+			iMemParts.Append ( aMemChunk );
+		}
+	
+	inline void FreeMemChunk ( )
+		{
+		if ( !iMemParts.IsEmpty () )
+			iMemParts.Free();
+		}
+
+	inline void RemoveAllBodyParts ( ) 
+		{
+		if ( iBodyParts.IsEmpty ( ) )
+			{
+			return;
+			}
+			
+		while ( iBodyParts.NumBufs ( ) > 0 )
+			{
+			iBodyParts.Remove ( );
+			if ( iBodyParts.IsEmpty ( ) )
+				{
+				break;
+				}
+			}		
+		}
+		
+	inline RMBufChain& BodyParts ( )
+		{
+		return iBodyParts;
+		}
+
+	inline RMemChunk& MemParts ( )
+		{
+		return iMemParts;
+		}
+
+	inline void RemoveBodyPart ()
+		{
+		RMBuf* mBuf = iBodyParts.Remove ();	 // Remove the first body part
+		__ASSERT_DEBUG ( mBuf, User::Invariant() );
+		if ( iDataLeft != KErrUnknown )
+			iDataLeft -= mBuf->Length ();
+		}
+	
+	inline void GetBodyPart ( TPtrC8& aData )
+		{
+		RMBuf* buf = iBodyParts.First ();
+		aData.Set ( buf->Ptr (), buf->Length () );		
+		}
+	
+	inline TBool IsLastBodyPart () const
+		{
+		if ( iDataLeft != KErrUnknown )
+			{
+			return ( ( iDataLeft - iBodyParts.First()->Length() ) == 0)	? ETrue : EFalse;			
+			}
+		return Complete();
+		}
+	
+	inline void SetDataLeft ( TInt aDataLeft )
+		{
+		iDataLeft = aDataLeft;			
+		}
+
+	inline void SetComplete ()
+		{
+		iComplete = ETrue;		
+		}
+	
+	inline TBool Complete() const
+		{
+		return iComplete;	
+		}
+	
+	inline TInt DataLeft () const
+		{
+		return iDataLeft;	
+		}
+		
+	inline void Reset ()
+		{
+		iDataLeft = KErrUnknown;
+		iRequest->Reset ();
+		iResponse->Reset ();
+		if ( !iBodyParts.IsEmpty () )
+			iBodyParts.Free ();
+		iComplete = EFalse;
+		}
+	
+	inline TBool CloseNeeded () const
+		{
+		if ( iDataLeft != KErrUnknown )
+			{
+			if ( iBodyParts.IsEmpty () )
+				{
+				return iDataLeft != 0 ? ETrue : EFalse;
+				}
+			else
+				{
+				return ( ( iDataLeft - iBodyParts.Length() ) != 0 ) ? ETrue : EFalse;
+				}
+			}
+				
+		return !Complete ();	
+		}
+	
+protected:
+	CTransaction ( );
+	void ConstructL ( CHeaderCodec& aCodec, RStringPool& aStringPool );
+	
+protected:
+	TInt		iDataLeft;
+	CRequest* 	iRequest;
+	CResponse*	iResponse;
+	RMBufChain	iBodyParts;
+	RMemChunk	iMemParts;
+	TBool		iComplete : 1;	
+	};
+
+
+#endif // CTRANSACTION_H
+