diff -r 000000000000 -r 857a3e953887 nettools/conntest/inc/SocketsRead.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/nettools/conntest/inc/SocketsRead.h	Thu Dec 17 08:39:25 2009 +0200
@@ -0,0 +1,141 @@
+/*
+* 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 "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: CSocketsRead is an active obejct that reads data from 
+* an already open socket and calculates some metrics from the data read
+*
+*/
+
+#ifndef __SOCKETSREAD_H__
+#define __SOCKETSREAD_H__
+
+#include <in_sock.h>
+#include "conntest.hrh"
+
+// CONSTANTS
+
+const TInt KMaximumPacketCount = 4000; // Count to 4000. Fails if ploss is over 20% (1000pckts)
+
+// FORWARD DECLARATIONS
+class MUINotify;
+class CSocketsEngine;
+
+// CLASS DECLARATION
+
+/** 
+*  This class handles reading data from the socket.
+*  In this implementation, any data read is simply
+*  displayed as text on the console.
+*/
+class CSocketsRead : public CActive
+{
+public:
+
+    /**
+    * Create a CSocketsRead object
+    * @param aConsole console to use for ui output
+    * @param aSocket socket to read from
+    * @result a pointer to the created instance of CSocketsRead
+    */
+    static CSocketsRead* NewL(MUINotify& aConsole, RSocket& aSocket, CSocketsEngine& aEngine);
+    
+    /**
+    * Create a CSocketsRead object
+    * @param aConsole console to use for ui output
+    * @param aSocket socket to read from
+    * @result a pointer to the created instance of CSocketsRead
+    */
+    static CSocketsRead* NewLC(MUINotify& aConsole, RSocket& aSocket, CSocketsEngine& aEngine);
+    
+    /**
+    * Destroy the object and release all memory objects
+    */
+    ~CSocketsRead();
+    
+    /**
+    * Initiate the read process.
+    * @param aAddress Address where data is sent (needed by UDP)
+    * @param aProtocol Protocol to be used (TCP or UDP)
+    */
+    void Start(TInetAddr* aAddress, TUint aProtocol);
+
+    /**
+    * Set throughput calculation on or off.
+    * @param aValue If ETrue, measure throughput
+    */
+    void SetPerformance(const TBool aValue);
+
+	/**
+	* Start RAW read
+	*/
+    void StartRAWRead(TInetAddr* aAddress, TUint aProtocol);
+    
+protected: // from CActive
+           
+    /**
+    * Cancel any outstanding operation
+    */
+    void DoCancel();
+    
+    /**
+    * Called when operation complete
+    */
+    void RunL();	
+    
+private:
+
+    /**
+    * Perform the first phase of two phase construction 
+    * @param aConsole console to use for ui output
+    * @param aSocket socket to read from
+    */
+    CSocketsRead(MUINotify& aConsole, RSocket& aSocket, CSocketsEngine& aEngine);
+    
+    /**
+    * Perform the second phase construction of a CSocketsRead 
+    */
+    void ConstructL();
+    
+    /**
+    * Read data from socket
+    */
+    void IssueRead();
+	
+	/**
+	* Calculate packet loss
+	* @return ploss percentage
+	*/
+	TInt32 CalculatePacketLoss();
+    
+private: // Member variables
+//    enum { KReadBufferSize = 4096 }; // 4K
+    //enum { KReadBufferSize = 10240 }; // 10K
+    // Member variables
+    CSocketsEngine&         iEngine;  // connection engine
+    RSocket&                iSocket;  // socket to read data from
+    MUINotify&              iConsole; // console for displaying text etc
+    TBuf8<KReadDataSize>  iBuffer;  // buffer for receiving data
+    TSockXfrLength          iDummyLength; // dummy - length of data read is written here
+    TInt                    iReceivedBytes; 
+    TInt32					iUdpPacketCounter;
+    TBool                   iDoCount; 
+    TBool                   iDoPerformance; 
+    TInetAddr*              iAddress;
+    TUint                   iProtocol;
+    TTime                   iStartTime;
+    TBuf8<2048>             iHeaders;  // buffer for HTTP headers
+    TInt                    iBodySize;
+};
+
+#endif // __SOCKETSREAD_H__
+