/*

* Copyright (c) 2007 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:

*

*/

#include "globalmsgobserver.h"

using namespace java::runtimeui;

EXPORT_C GlobalMsgObserver* GlobalMsgObserver::NewL()

{

    GlobalMsgObserver* self = new(ELeave) GlobalMsgObserver();

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop();

    return self;

}

EXPORT_C GlobalMsgObserver* GlobalMsgObserver::NewLC()

{

    GlobalMsgObserver* self = new(ELeave) GlobalMsgObserver();

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

}

EXPORT_C int GlobalMsgObserver::getAnswer()

{

    // set the active object as active

    SetActive();

    // enter scheduler loop

    iActiveSchedulerWait->Start();

    return iStatus.Int();

}

void GlobalMsgObserver::ConstructL()

{

    if (!CActiveScheduler::Current())

    {

        // create own ActiveScheduler since one doesn't exist yet

        iActiveScheduler = new(ELeave) CActiveScheduler;

        CActiveScheduler::Install(iActiveScheduler);

    }

    // register myself as an active object

    CActiveScheduler::Add(this);

    // create wait object for nested loop control

    iActiveSchedulerWait = new(ELeave) CActiveSchedulerWait;

}

GlobalMsgObserver::~GlobalMsgObserver()

{

    // cancel any outstanding requests

    Cancel();

    // delete own active scheduler if it was created

    delete iActiveScheduler;

    // delete wait object that is always created

    delete iActiveSchedulerWait;

}

void GlobalMsgObserver::Complete()

{

    // stop the active scheduler loop

    iActiveSchedulerWait->AsyncStop();

}

void GlobalMsgObserver::DoCancel()

{

    // This implementation is not correct. It should call the cancel provided

    // by the asynchronous service provider. If something leaves while in the

    // scheduler loop in getAnswer() then now it will try to stop the scheduler

    // which isn't running anymore because of the leave and there will be

    // TooManyStops panic.

    Complete();

}

void GlobalMsgObserver::RunL()

{

    Complete();

}