/*

* Copyright (c) 2006-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:  Implementation of the public preset notifier

*

*/

#include <pspresetnotifier.h>

#include <psserv.h>

#include "psservnotifier.h"

const TInt KPSDefaultNotifierPriority = CActive::EPriorityLow; // Priority of the non-preset notifiers.

const TInt KPSPresetNotifierPriority = CActive::EPriorityStandard; // Priority of the preset notifiers.

const TInt KPSFailedRequestDelay = 5000000; // The delay after which a failed notify request is reissued to the server.

// ======== LOCAL FUNCTIONS ========

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

// ---------------------------------------------------------------------------

// Two-phased constructor.

// ---------------------------------------------------------------------------

//

EXPORT_C CPSPresetNotifier* CPSPresetNotifier::NewL( RPSServ& aServ, MPSPresetObserver& aObserver )

    {

    CPSPresetNotifier* self = new ( ELeave ) CPSPresetNotifier( aServ, aObserver, KPSDefaultNotifierPriority );

    CleanupStack::PushL( self );

    self->ConstructL( KErrNotFound );

    CleanupStack::Pop( self );

    return self;

    }

// ---------------------------------------------------------------------------

// Non-exported two-phased constructor.

// ---------------------------------------------------------------------------

//

CPSPresetNotifier* CPSPresetNotifier::NewL( RPSServ& aServ, MPSPresetObserver& aObserver, TInt aId )

    {

    CPSPresetNotifier* self = new ( ELeave ) CPSPresetNotifier( aServ, aObserver, KPSPresetNotifierPriority );

    CleanupStack::PushL( self );

    self->ConstructL( aId );

    CleanupStack::Pop( self );

    return self;

    }     

// ---------------------------------------------------------------------------

// Constructor.

// ---------------------------------------------------------------------------

//

CPSPresetNotifier::CPSPresetNotifier( RPSServ& aServ, MPSPresetObserver& aObserver, TInt aPriority )

    : CActive( aPriority ), iServ( aServ ), iObserver( aObserver )

    {

    CActiveScheduler::Add( this );

    }

// ---------------------------------------------------------------------------

// Second-phase constructor.

// ---------------------------------------------------------------------------

//

void CPSPresetNotifier::ConstructL( TInt aId )

    {

    iTimer = CPeriodic::NewL( CActive::EPriorityStandard );

    iNotifier = new ( ELeave ) RPSServNotifier( iServ, aId );

    iNotifier->Notify( iStatus );

    SetActive();

    }

// ---------------------------------------------------------------------------

// Destructor.

// ---------------------------------------------------------------------------

//

EXPORT_C CPSPresetNotifier::~CPSPresetNotifier()

    {

    Cancel();

    delete iNotifier;

    delete iTimer;

    }

// ---------------------------------------------------------------------------

// Cancels the pending notify.

// ---------------------------------------------------------------------------

//

void CPSPresetNotifier::DoCancel()

    {

    if ( iNotifier )

        {

        iNotifier->CancelNotify();

        }

    if ( iTimer )

        {

        iTimer->Cancel();

        }

    }

// ---------------------------------------------------------------------------

// Invoked when a preset is changed.

// ---------------------------------------------------------------------------

//

void CPSPresetNotifier::RunL()

    {

    User::LeaveIfError( iStatus.Int() );

    iObserver.HandlePresetChangedL( iNotifier->Id(), iNotifier->DataHandler(), iNotifier->Reason() );

    // Requesting the new notification must be done after the observer has been

    // notified of the current one, as the request may complete synchronously on the 

    // server side, causing it to overwrite the existing notify package and thus notifying

    // the observer incorrectly.

    iNotifier->Notify( iStatus );

    SetActive();

    }

// ---------------------------------------------------------------------------

// Called when RunL leaves.

// ---------------------------------------------------------------------------

//

TInt CPSPresetNotifier::RunError( TInt /*aError*/ )

    {

    // After a notification fails for any reason, whether it is because the server side

    // code has caused a leave or the observer's implementation of preset handling

    // call back fails, we will request a new notification with a set delay. This

    // prevents the notifier from being in a state where it can no longer keep track

    // of its state.

    iTimer->Cancel();

    iTimer->Start( KPSFailedRequestDelay, KPSFailedRequestDelay, TCallBack( StaticDelayedNotifyCallBack, this ) );

    return KErrNone;

    }

// ---------------------------------------------------------------------------

// Static notify call back that is used after a failed notification.

// ---------------------------------------------------------------------------

//

TInt CPSPresetNotifier::StaticDelayedNotifyCallBack( TAny* aSelf )

    {

    CPSPresetNotifier* self = static_cast<CPSPresetNotifier*>( aSelf );

    if ( self )

        {

        self->iTimer->Cancel();

        self->iNotifier->Notify( self->iStatus );

        self->SetActive();

        }

    return KErrNone;

    }

// ======== GLOBAL FUNCTIONS ========