diff -r 000000000000 -r 3553901f7fa8 cellularsrvapitest/datatransferhaitest/esock/inc/T_RSocketData.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/cellularsrvapitest/datatransferhaitest/esock/inc/T_RSocketData.h	Tue Feb 02 01:41:59 2010 +0200
@@ -0,0 +1,136 @@
+/*
+* Copyright (c) 2005-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 T_RSOCKET_DATA_H
+#define T_RSOCKET_DATA_H
+
+//	User Includes
+#include "DataWrapperBase.h"
+#include "BreathSaver.h"
+//	EPOC includes
+#include <datawrapper.h>
+#include <w32std.h>
+#include <e32std.h>
+
+#include <es_sock.h> // TSockAddr address 
+#include <in_sock.h> // TCP/IP Protocol and address family
+
+
+// For ETel API.
+#include <etelmm.h>
+
+
+class CT_RSocketData: public CDataWrapperBase
+	{
+public:
+	/**
+	* Two phase constructor
+	*/
+	static CT_RSocketData*	NewL();
+	
+	virtual TAny*	GetObject();
+	virtual TBool	DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);
+	
+	~CT_RSocketData();
+
+public:
+	void RunL(CActive* aActive, TInt aIndex);
+
+protected:
+	/**
+	* Protected constructor. First phase construction
+	*/
+	CT_RSocketData();
+
+	void ConstructL();
+		
+private:
+	void InitialiseL();
+	void CloseSocketServer();
+
+	void DoCmdOpenL(const TTEFSectionName& aSection);
+	void DoCmdInfoL(const TTEFSectionName& aSection);
+	void DoCmdConnectL(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);
+	void DoCmdShutDown(const TInt aAsyncErrorIndex);
+	void DoCmdClose();
+	void DoCmdRecvOneOrMore(const TTEFSectionName& aSection);
+	void DoCmdWrite(const TInt aAsyncErrorIndex);
+	void DoCmdSendBytesToSocket(const TTEFSectionName& aSection);
+	void DoCmdWriteRequest(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);
+	void DoCmdUtilityStartFile(const TTEFSectionName& aSection);
+	void DoCmdUtilityStartDealer(const TTEFSectionName& aSection);
+	void DoCmdUtilityEndFile(const TTEFSectionName& aSection);
+	void DoCmdUtilityCalculateDownloadStats(const TTEFSectionName& aSection);
+	void DoCmdUtilityCheckHSDPAL(const TTEFSectionName& aSection);
+	void DoCmdResponseFromServer(const TTEFSectionName& aSection);
+	
+	//Helpers
+    TBool CheckHSDPAIndicator();
+    TBool CheckHSDPASupportL(RMobilePhone &aMobilePhone);
+    TBool CheckHSDPAUsageL(RMobilePhone &aMobilePhone);
+	
+	//Upload
+	void DoCmdUtilityBuildRequest(const TTEFSectionName& aSection);
+	void DoCmdUtilityEndRequest();
+	///End Upload
+	TInt SendBytesToSocket(TInt aBytes, TInt aDuration);
+	TReal ThroughputInKiloBits( TTimeIntervalMicroSeconds aDuration, TInt aBytes );
+	TReal ThroughputInMegaBits( TTimeIntervalMicroSeconds aDuration, TInt aBytes );
+	TInt SetThroughput( const TReal aThroughput );
+
+private:
+	/**
+	 * RSocket
+	 */    
+    RSocket* 	iSocket;
+    /**
+     * CActive callback for asynchronous functions
+     */
+    CActiveCallback* iActiveCallback;
+    /**
+	 * Name entry stores name record for IPC.
+	 */
+	TNameEntry iNameEntry;
+	/**
+	 * Timestamps 
+	 */
+	TTime iEnd;
+	TTime iStart;
+	/**
+	 * Total bytes received
+	 */
+	TInt iTotalReceived;
+	
+	/**
+	 * Helper class that is used to save data.
+	 */
+    CBreathSaver* iBreathSaver;
+    
+    /**
+     * TBuf used to send http requests
+     */
+    TBuf8<456> iRequest;
+    
+    TUid iPropertyCategory;
+    TUint iPropertyKey;
+    TInt iMaxPropertyLength;
+    
+	};
+
+#endif //T_RSOCKET_DATA_H
+