/*

* Copyright (c) 2002 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:  This class provides CJavaEventSource services

*

*/

//  INCLUDE FILES

#include <jdebug.h> // DEBUG

#include <coemain.h>

#include <eikenv.h>

#include "cmmaeventsource.h"

#include "cmmaevent.h"

#include "cmmaplayer.h"

#include "mmmaplayerinstanceobserver.h"

#ifdef RD_JAVA_VOLUME_CONTROL

#include "cmmaglobalvolume.h"

#endif // RD_JAVA_VOLUME_CONTROL

CMMAEventSource::CMMAEventSource()

{

    iFbsSessionConnected = EFalse;

    iJavaVM = 0;

}

CMMAEventSource::~CMMAEventSource()

{

    DEBUG("MMA::CMMAEventSource::~CMMAEventSource()");

    if (iJavaVM)

        iJavaVM->DetachCurrentThread();

#ifdef RD_JAVA_VOLUME_CONTROL

    delete iGlobalVolume;

#endif // RD_JAVA_VOLUME_CONTROL

}

void CMMAEventSource::ConstructL(JNIEnv& aJni,

                                 jobject aPeer,

                                 TJavaEventServer aServer)

{

    DEBUG("MMA::CMMAEventSource::ConstructL +");

    CJavaEventSourceBase::ConstructL(aJni, aPeer, aServer);

    aJni.GetJavaVM(&iJavaVM); // Get pointer to VM

    DEBUG("MMA::CMMAEventSource::ConstructL -");

}

void CMMAEventSource::ConstructSvrL()

{

    // creating fbs session

    User::LeaveIfError(RFbsSession::Connect());

    iFbsSessionConnected = ETrue;

    DEBUG("MMA::CMMAEventSource::ConstructSvrL ok");

}

EXPORT_C void CMMAEventSource::StaticAddObjectFromHandleL(

    CMMAEventSource* aEventSource,

    TInt aHandle)

{

    aEventSource->AddObjectFromHandleL(aHandle);

}

void CMMAEventSource::AddPlayerL(CMMAPlayer* aPlayer)

{

    if (iInstanceObserver)

    {

        iInstanceObserver->AddPlayerNotifyL(aPlayer);

    }

#ifdef RD_JAVA_VOLUME_CONTROL

    if (iGlobalVolume)

    {

        iGlobalVolume->AddPlayerL(aPlayer);

    }

#endif // RD_JAVA_VOLUME_CONTROL

    TInt err = iPlayers.Append(aPlayer);

    if (err != KErrNone)

    {

        // There was no memory to add new player to array,

        // player must be removed from instance observer.

        if (iInstanceObserver)

        {

            iInstanceObserver->RemovePlayerNotify(aPlayer);

        }

#ifdef RD_JAVA_VOLUME_CONTROL

        if (iGlobalVolume)

        {

            iGlobalVolume->RemovePlayer(aPlayer);

        }

#endif // RD_JAVA_VOLUME_CONTROL

        User::Leave(err);

    }

}

void CMMAEventSource::DisposePlayer(CMMAPlayer* aPlayer)

{

    TInt index = iPlayers.Find(aPlayer);

    if (index != KErrNotFound)

    {

        if (iInstanceObserver)

        {

            iInstanceObserver->RemovePlayerNotify(aPlayer);

        }

#ifdef RD_JAVA_VOLUME_CONTROL

        if (iGlobalVolume)

        {

            iGlobalVolume->RemovePlayer(aPlayer);

        }

#endif // RD_JAVA_VOLUME_CONTROL

        delete iPlayers[ index ];

        // remove object from list

        iPlayers.Remove(index);

    }

}

EXPORT_C void CMMAEventSource::SetPlayerInstanceObserver(

    MMMAPlayerInstanceObserver* aObserver)

{

    iInstanceObserver = aObserver;

}

EXPORT_C RPointerArray< CMMAPlayer >& CMMAEventSource::Players()

{

    return iPlayers;

}

void CMMAEventSource::Release()

{

    // If player instance observer is added to event source, remove all

    // players from observer before deleting those.

    if (iInstanceObserver)

    {

        for (TInt i = 0; i < iPlayers.Count(); i++)

        {

            iInstanceObserver->RemovePlayerNotify(iPlayers[ i ]);

#ifdef RD_JAVA_VOLUME_CONTROL

            if (iGlobalVolume)

            {

                iGlobalVolume->RemovePlayer(iPlayers[ i ]);

            }

#endif // RD_JAVA_VOLUME_CONTROL

        }

    }

    iPlayers.ResetAndDestroy();

}

void CMMAEventSource::AddObjectFromHandleL(TInt aHandle)

{

    User::LeaveIfError(iObjects.Append(JavaUnhand< CBase >(aHandle)));

}

void CMMAEventSource::FinalizeSvr()

{

    DEBUG_INT("MMA::CMMAEventSource::FinalizeSvr() object count = %d",

              iObjects.Count());

    DEBUG_INT("MMA::CMMAEventSource::FinalizeSvr() player count = %d",

              iPlayers.Count());

    // After object array alements are deleted all external references to

    // player objects are removed and player array can be deleted.

    iObjects.ResetAndDestroy();

    iPlayers.ResetAndDestroy();

    if (iFbsSessionConnected)

    {

        RFbsSession::Disconnect();

        iFbsSessionConnected = EFalse;

    }

    DEBUG("MMA::CMMAEventSource::FinalizeSvr() ok");

}

void CMMAEventSource::PostEvent(CMMAEvent* aEvent, TInt aPriority)

{

    CJavaEventSource< CMMAEventSource >::PostEvent(aEvent, aPriority);

}

CMMAPlayer* CMMAEventSource::FindPlayer(TInt aPlayerHandle)

{

    DEBUG("CMMAEventSource::FindPlayer");

    CMMAPlayer* player = JavaUnhand< CMMAPlayer >(aPlayerHandle);

    TInt index = iPlayers.Find(player);

    if (index != KErrNotFound)

    {

        player = iPlayers[ index ];

        DEBUG("CMMAEventSource::FindPlayer: player found");

    }

    else

    {

        DEBUG("CMMAEventSource::FindPlayer: player not found");

        player = NULL;

    }

    return player;

}

#ifdef RD_JAVA_VOLUME_CONTROL

void CMMAEventSource::SetGlobalVolume(CMMAGlobalVolume* aGlobalVolume)

{

    delete iGlobalVolume;

    iGlobalVolume = aGlobalVolume;

}

#endif // RD_JAVA_VOLUME_CONTROL

//  END OF FILE