/*
* Copyright (c) 2002-2008 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:  Active object wrapper for SAT Server
*
*/


#include    "csatsactivewrapper.h"
#include    "SatLog.h"

const TInt KShortWait = 200; // 200 microseconds
const TInt KWaitTimes = 5;   // Number of retries

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

// Class constructor.
CSatSActiveWrapper::CSatSActiveWrapper() :
    CActive( EPriorityStandard )
    {
    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::CSatSActiveWrapper \
    calling-exiting" )
    CActiveScheduler::Add( this );
    }

// Destructor
CSatSActiveWrapper::~CSatSActiveWrapper()
    {
    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::~CSatSActiveWrapper calling" )

    if ( iTimer )
        {
        iTimer->Cancel();
        delete iTimer;
        }

    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::~CSatSActiveWrapper exiting" )
    }

// -----------------------------------------------------------------------------
// CSatSActiveWrapper::RequestStatus
// -----------------------------------------------------------------------------
//
TRequestStatus& CSatSActiveWrapper::RequestStatus()
    {
    LOG( DETAILED, "SATENGINE: CSatSActiveWrapper::RequestStatus calling" )

    TInt retries( 0 );
    while ( IsActive() && ( retries++ < KWaitTimes ) )
        {
        // If this wrapper is already active, wait little bit
        After( KShortWait );
        }
    LOG2( DETAILED, "SATENGINE: CSatSActiveWrapper::RequestStatus retries: %d",
          retries )
    // Double check. If still active, cancel
    if ( IsActive() )
        {
        LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::RequestStatus active" )
        CancelWrapper();
        }

    LOG( DETAILED, "SATENGINE: CSatSActiveWrapper::RequestStatus exiting" )
    return iStatus;
    }
// -----------------------------------------------------------------------------
// CSatSActiveWrapper::SetActiveAndWait
// -----------------------------------------------------------------------------
//
TInt CSatSActiveWrapper::SetActiveAndWait()
    {
    LOG( DETAILED, "SATENGINE: CSatSActiveWrapper::SetActiveAndWait calling" )

    TInt returnValue( KErrInUse );
    if ( !IsActive() && !iWait.IsStarted() )
        {
        LOG( DETAILED,
        "SATENGINE: CSatSActiveWrapper::SetActiveAndWait setActiveAndWait" )
        SetActive();
        iWait.Start(); // Blocks until request is complete or cancelled
        returnValue = iStatus.Int();
        }

    LOG( DETAILED, "SATENGINE: CSatSActiveWrapper::SetActiveAndWait exiting" )
    return returnValue;
    }

// -----------------------------------------------------------------------------
// CSatSActiveWrapper::After
// -----------------------------------------------------------------------------
void CSatSActiveWrapper::After(
    const TTimeIntervalMicroSeconds32& aDelay,
    const TTimeIntervalMicroSeconds32& aInterval )
    {
    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::After calling" )

    if ( !iAfterWait.IsStarted() )
        {
        LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::After start iAfterWait" )
        TRAP_IGNORE( ( iTimer = CPeriodic::NewL( EPriorityStandard ) ) )
        iTimer->Start( aDelay, aInterval, TCallBack( DelayCallBack, this ) );
        iAfterWait.Start();

        delete iTimer;
        iTimer = NULL;
        }

    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::After exiting" )
    }

// -----------------------------------------------------------------------------
// CSatSActiveWrapper::DelayCallBack
// Timer call back function
// -----------------------------------------------------------------------------
TInt CSatSActiveWrapper::DelayCallBack( TAny* aPtr )
    {
    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::DelayCallBack calling" )
    CSatSActiveWrapper* ptrThis = static_cast<CSatSActiveWrapper*>( aPtr );
    if ( ptrThis && ( ptrThis->iAfterWait.IsStarted() ) )
        {
        LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::DelayCallBack stop \
             iAfterWait" )
        ptrThis->iAfterWait.AsyncStop();
        }
    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::DelayCallBack exiting" )
    return ( EFalse );
    }

// -----------------------------------------------------------------------------
// CSatSActiveWrapper::AddSubSessionL
// -----------------------------------------------------------------------------
void CSatSActiveWrapper::CancelWrapper()
    {
    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::CancelWrapper calling" )

    // If pending for request, cancel active
    if ( IsActive() )
        {
        LOG( SIMPLE, 
        "SATENGINE: CSatSActiveWrapper::CancelWrapper cancel iWait" )
        // Calls DoCancel which cancels iWait
        Cancel();
        }
    else if ( iAfterWait.IsStarted() )
        {
        LOG( SIMPLE, 
        "SATENGINE: CSatSActiveWrapper::CancelWrapper cancel timer" )
        // Cancels timer
        iAfterWait.AsyncStop();
        }
    else
        {
        LOG( SIMPLE, 
        "SATENGINE: CSatSActiveWrapper::CancelWrapper Wrapper not active" )
        }

    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::CancelWrapper exiting" )
    }

// -----------------------------------------------------------------------------
// CSatSActiveWrapper::Release
// -----------------------------------------------------------------------------
void CSatSActiveWrapper::Release()
    {
    LOG( SIMPLE, "SATENGINE: CSatSActiveWrapper::Release calling-exiting" )
    delete this;
    }

// -----------------------------------------------------------------------------
// CSatSActiveWrapper::RunL
// Synchronous request complete
// -----------------------------------------------------------------------------
//
void CSatSActiveWrapper::RunL()
    {
    LOG( DETAILED, "SATENGINE: CSatSActiveWrapper::RunL calling" )

    iWait.AsyncStop();

    LOG( DETAILED, "SATENGINE: CSatSActiveWrapper::RunL exiting" )
    }

// -----------------------------------------------------------------------------
// CSatSActiveWrapper::DoCancel
// Synchronous request complete
// -----------------------------------------------------------------------------
//
void CSatSActiveWrapper::DoCancel()
    {
    LOG( SIMPLE, "SATENGINE: CSatBIPUtils::DoCancel calling" )

    iWait.AsyncStop();

    LOG( SIMPLE, "SATENGINE: CSatBIPUtils::DoCancel exiting" )
    }