/*

* Copyright (c) 2008-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:  Java RemCon Observer

*

*/

#include <jdebug.h>

#include "javaremconmanager.h"

#include "javaremconobservable.h"

#include "panics.h"

// ======== STATIC VARIABLES ========

/**

* Singleton

*/

NONSHARABLE_CLASS(RemConnGlobals)

{

public:

    RemConnGlobals() : mObservable(0) {}

public:

    CJavaRemConObservable* mObservable;

};

#if defined(__WINSCW__)

#include <pls.h>

RemConnGlobals* getRemConnGlobals()

{

    // Access the PLS of this process

    RemConnGlobals* globals  =

        Pls<RemConnGlobals>(TUid::Uid(0x200211E1));

    return globals;

}

#else

static RemConnGlobals* sGlobals = 0;

RemConnGlobals* getRemConnGlobals()

{

    if (sGlobals == 0)

    {

        sGlobals = new RemConnGlobals();

    }

    return sGlobals;

}

#endif

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

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

// CJavaRemConManager::ConstructL()

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

//

void CJavaRemConManager::ConstructL()

{

    DEBUG("+ CJavaRemConManager::ConstructL()");

    RemConnGlobals* globals = getRemConnGlobals();

    if (globals->mObservable == 0)

    {

        globals->mObservable = CJavaRemConObservable::NewL();

        RThread thread;

        iCreatorThreadId = thread.Id();

    }

    DEBUG("- CJavaRemConManager::ConstructL()");

}

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

// CJavaRemConManager* CJavaRemConManager::NewL()

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

//

EXPORT_C CJavaRemConManager* CJavaRemConManager::NewL()

{

    CJavaRemConManager* self = CJavaRemConManager::NewLC();

    CleanupStack::Pop(self);

    return self;

}

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

// CJavaRemConManager* CJavaRemConManager::NewLC()

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

//

EXPORT_C CJavaRemConManager* CJavaRemConManager::NewLC()

{

    CJavaRemConManager* self = new(ELeave) CJavaRemConManager;

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

}

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

// CJavaRemConManager::CJavaRemConManager()

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

//

CJavaRemConManager::CJavaRemConManager() : iSet(EFalse)

{

    DEBUG("+ CJavaRemConManager::CJavaRemConManager()");

    DEBUG("- CJavaRemConManager::CJavaRemConManager()");

}

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

// CJavaRemConManager::~CJavaRemConManager()

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

//

CJavaRemConManager::~CJavaRemConManager()

{

    DEBUG("+ CJavaRemConManager::~CJavaRemConManager()");

    __ASSERT_DEBUG(!iSet, User::Panic(KJavaRemConPanicCategory,

                                      EJavaRemConPanicObserverNotRemoved)

                  );

    RThread thread;

    if (thread.Id() == iCreatorThreadId)

    {

        delete getRemConnGlobals()->mObservable;

        getRemConnGlobals()->mObservable = NULL;

    }

    DEBUG("- CJavaRemConManager::~CJavaRemConManager()");

}

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

// CJavaRemConManager::SetObserver

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

//

EXPORT_C void CJavaRemConManager::SetObserverL(

    CJavaRemConObserver &aObserver)

{

    DEBUG("+ CJavaRemConManager::SetObserverL()");

    if (iSet)

    {

        User::Leave(KErrInUse);

    }

    getRemConnGlobals()->mObservable->AddObserverL(aObserver);

    iSet = ETrue;

    DEBUG("- CJavaRemConManager::SetObserverL()");

}

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

// CJavaRemConManager::RemoveObserver

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

//

EXPORT_C void CJavaRemConManager::RemoveObserver(

    CJavaRemConObserver &aObserver)

{

    DEBUG("+ CJavaRemConManager::RemoveObserverL()");

    __ASSERT_DEBUG(iSet, User::Panic(KJavaRemConPanicCategory,

                                     EJavaRemConPanicObserverNotSet)

                  );

    CJavaRemConObservable* observable = getRemConnGlobals()->mObservable;

    if (observable)

    {

        observable->RemoveObserver(aObserver);

    }

    iSet = EFalse;

    DEBUG("- CJavaRemConManager::RemoveObserver()");

}

// End Of File