--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/applayerpluginsandutils/httpprotocolplugins/httpclient/chttprequestbatcher.h	Tue Feb 02 01:09:52 2010 +0200
@@ -0,0 +1,122 @@
+// Copyright (c) 2003-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:
+//
+
+#ifndef __CHTTPREQUESTBATCHER_H__
+#define __CHTTPREQUESTBATCHER_H__
+
+#include <e32base.h>
+#include <http/framework/logging.h>
+
+#include "moutputstream.h"
+#include "moutputstreamobserver.h"
+
+class CX509Certificate;
+
+
+class CHttpRequestBatcher : public CActive,
+							public MOutputStream,
+							public MOutputStreamObserver
+	{
+public:		// methods
+	static CHttpRequestBatcher* NewL(MOutputStream& aOutputStream, const TInt aBufferSize);
+
+	virtual ~CHttpRequestBatcher();
+
+	virtual void Bind(MOutputStreamObserver& aObserver);
+
+
+private:	// methods from MOutputStream
+	virtual void SendDataReqL(const TDesC8& aBuffer);
+
+	virtual void ShutdownReq();
+
+	virtual void SecureClientReq(const TDesC8& aHostName);
+
+	virtual void Close();
+
+	virtual const CX509Certificate* ServerCert();
+	
+	virtual TInt CipherSuite(TDes8& aCipherSuite);
+
+	virtual void MOutputStream_Reserved();
+
+	virtual void Reset ();
+	
+	virtual void SetTCPCorking(TBool aValue);
+private:	// methods from MOutputStreamObserver
+	virtual void SendDataCnfL();
+
+	virtual void SecureClientCnf();
+
+	virtual void OutputStreamCloseInd(TInt aError);
+
+	virtual void MOutputStreamObserver_Reserved();
+	
+	virtual void OnSendTimeOut();
+	
+	virtual TInt SendTimeOutVal();
+	
+private:	// methods from CActive
+	virtual void RunL();
+	
+	virtual void DoCancel();
+	
+	virtual TInt RunError(TInt aError);
+
+
+private:	// methods
+	CHttpRequestBatcher(MOutputStream& aOutputStream, const TInt aBufferSize);
+
+	void SendRequestImmediatelyL(const TDesC8& aBuffer);
+
+	void SendRequestsBatchedL(const TDesC8& aBuffer);
+
+	void BatchRequestsL(const TDesC8& aBuffer);
+
+	void HandleExcessDataL();
+
+	void StartTimer();
+
+	void ConstructL();
+
+
+private:	// typedefs
+	typedef void (CHttpRequestBatcher::*TSendFunction)(const TDesC8&);
+
+
+private:	// attributes
+	MOutputStreamObserver*		iObserver;
+
+	MOutputStream*				iOutputStream;
+
+	HBufC8*						iBuffer;
+
+	TPtr8						iDataToSend;
+
+	TPtrC8						iExcessData;
+
+	TInt						iMaxBufferSize;
+
+	TSendFunction				iFuncPtr;
+
+	RTimer						iTimer;
+
+	TBool						iTimerCompleted;
+
+public:	// attributes
+	__FLOG_DECLARATION_MEMBER2
+	};
+
+#endif	// __CHTTPREQUESTBATCHER_H__