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