/*
* Copyright (c) 2002-2005 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:  Issues RConnection::DataTransferredRequest() and sends the
*                data volumes to sessions.
*
*/

#include <es_sock.h>

#include "CDataVolume.h"
#include "ConnMonServ.h"
#include "ConnMonDef.h"
#include "log.h"

// ============================ MEMBER FUNCTIONS ===============================

// -----------------------------------------------------------------------------
// CDataVolume::CDataVolume
// -----------------------------------------------------------------------------
//
CDataVolume::CDataVolume(
        CConnMonServer* aServer,
        RConnection* aConnection,
        const TUint& aConnectionId )
        :
        CActive( EConnMonPriorityNormal ),
        iServer( aServer ),
        iConnection( aConnection ),
        iConnectionId( aConnectionId ),
        iDlData( 0 ),
        iPckgDlData( iDlData ),
        iUlData( 0 ),
        iPckgUlData( iUlData )
    {
    }

// -----------------------------------------------------------------------------
// CDataVolume::Construct
// -----------------------------------------------------------------------------
//
void CDataVolume::Construct()
    {
    CActiveScheduler::Add( this );
    }

// Destructor
CDataVolume::~CDataVolume()
    {
    Cancel();
    }

// -----------------------------------------------------------------------------
// CDataVolume::Receive
// Requests a new event (activity changed) from RConnection
// -----------------------------------------------------------------------------
//
void CDataVolume::Receive()
    {
    if ( IsActive() )
        {
        Cancel();
        }

    iUlData = 0;
    iDlData = 0;

    iConnection->DataTransferredRequest( iPckgUlData, iPckgDlData, iStatus );
    SetActive();
    }

// -----------------------------------------------------------------------------
// CDataVolume::DoCancel
// Cancels the request from RConnection.
// -----------------------------------------------------------------------------
//
void CDataVolume::DoCancel()
    {
    if ( IsActive() )
        {
        // Complete all outstanding data volume requests on this connection
        // Use the latest data volumes got from the ESOCK.
        iServer->SendDataVolumesToSessions(
                iConnectionId,
                iPckgDlData(),
                iPckgUlData(),
                KErrCancel );

        // Cancel the request from RConnection
        iConnection->DataTransferredCancel();
        }
    }

// -----------------------------------------------------------------------------
// CDataVolume::RunL
// Handles the event that has arrived from RConnection
// -----------------------------------------------------------------------------
//
void CDataVolume::RunL()
    {
    //LOGENTRFN("CDataVolume::RunL()")

    // All RunL():s outside CServer-derived main class MUST NOT LEAVE.
    // Use TRAPD when needed.

    LOGIT(".")
    LOGIT1("RunL: CDataVolume, status %d", iStatus.Int())

    if ( iStatus.Int() != KErrNone )
        {
        LOGIT1("SERVER: Data volume request FAILED <%d>", iStatus.Int())
        }
    else
        {
        LOGIT2("SERVER: Data volume request completed: d:%d, u:%d", iPckgDlData(), iPckgUlData())
        }

    // Complete all outstanding data volume requests on this connection
    iServer->SendDataVolumesToSessions(
            iConnectionId,
            iPckgDlData(),
            iPckgUlData(),
            iStatus.Int() );

    // This is a one-shot active object. The object is connection specific,
    // constructed when needed for the first time, and reused as necessary.
    // Delete happens only when the connection specific attribute tables are
    // cleaned up.

    //LOGEXITFN("CDataVolume::RunL()")
    }

// End-of-file