/*

* 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__