/*
* Copyright (c) 2005 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 <ecom/ecom.h>
#include "mceservercore.h"
#include "mceclientserver.h"
#include "mcecsserver.h"
#include "mcecsserverclosetimer.h"
#include "mceactivescheduler.h"
#include "mcecssession.h"
#include "cleanupresetanddestroy.h"
#include "mcesipmanager.h"
#include "fcpluginengine.h"
#include "mcesrvlogs.h"

const TUint KServerCloseWaitTime = 500; // milliseconds

// -----------------------------------------------------------------------------
// CMceServerCore::NewL
// -----------------------------------------------------------------------------
//
CMceServerCore* CMceServerCore::NewL ()
	{
    CMceServerCore* self = CMceServerCore::NewLC();
    CleanupStack::Pop(self);
    return self;
	}

// -----------------------------------------------------------------------------
// CMceServerCore::NewLC
// -----------------------------------------------------------------------------
//
CMceServerCore* CMceServerCore::NewLC ()
	{
	CMceServerCore* self = new(ELeave)CMceServerCore;
    CleanupStack::PushL(self);
    self->ConstructL();
    return self;
	}

// -----------------------------------------------------------------------------
// CMceServerCore::ConstructL
// -----------------------------------------------------------------------------
//
void CMceServerCore::ConstructL ()
	{
    MCESRV_DEBUG("CMceServerCore::ConstructL, Entry");

    MCESRV_DEBUG("MCE Server starting");
    
    iActiveScheduler = new (ELeave) CMceActiveScheduler ();
    CActiveScheduler::Install (iActiveScheduler);
	iCloseTimer = CMceCsServerCloseTimer::NewL();
	iManager = CMceSipManager::NewL( *this );
	iServer = CMceCsServer::NewL(*this);
	iFCPlugInEngine = CFCPlugInEngine::NewL( *this );  
	
    MCESRV_DEBUG("MCE Server READY");
	
    MCESRV_DEBUG("CMceServerCore::ConstructL, Exit");
	}

// -----------------------------------------------------------------------------
// CMceServerCore::CMceServerCore
// -----------------------------------------------------------------------------
//
CMceServerCore::CMceServerCore ()
	{
	}

// -----------------------------------------------------------------------------
// CMceServerCore::~CMceServerCore
// -----------------------------------------------------------------------------
//
CMceServerCore::~CMceServerCore ()
	{
    MCESRV_DEBUG("CMceServerCore::~CMceServerCore, Entry");
	
	// This must be deleted first to remove MCE server from system's
	// list of servers asap.
	delete iServer;
    
	iFCSessions.Reset();
	iFCSessions.Close();
	delete iFCPlugInEngine;
	delete iCloseTimer;
	delete iManager;
    delete iActiveScheduler;
	CActiveScheduler::Install (NULL);
    MCESRV_DEBUG("MCE Server stopped");
    
    MCESRV_DEBUG("CMceServerCore::~CMceServerCore, Exit");
    
	}

// -----------------------------------------------------------------------------
// CMceServerCore::IncrementSessions
// -----------------------------------------------------------------------------
//
void CMceServerCore::IncrementSessions ()
	{
	if (iCloseTimer->IsActive())
        {
        iCloseTimer->Cancel();
        }
    iSessionCount++;
	}

// -----------------------------------------------------------------------------
// CMceServerCore::DecrementSessions
// -----------------------------------------------------------------------------
//
void CMceServerCore::DecrementSessions ()
	{
	if (iSessionCount > 0)
    	{
    	iSessionCount--;    
    	}
	if (iSessionCount == 0 && iManager->OrphanSubSessionCount() == 0)
		{
		iCloseTimer->StopActiveSchedulerAfter(KServerCloseWaitTime);
		}
	}

// -----------------------------------------------------------------------------
// CMceServerCore::InactiveServerCleanup
// -----------------------------------------------------------------------------
//
void CMceServerCore::InactiveServerCleanup()
    {
    if ( iSessionCount == 0 && iManager->OrphanSubSessionCount() == 0)
		{
		iCloseTimer->StopActiveSchedulerAfter(KServerCloseWaitTime);
		} 
    }

// -----------------------------------------------------------------------------
// CMceServerCore::Server
// -----------------------------------------------------------------------------
//
CServer2& CMceServerCore::Server () const
	{
	return *iServer;
	}

// -----------------------------------------------------------------------------
// CMceServerCore::Manager
// -----------------------------------------------------------------------------
//
CMceSipManager& CMceServerCore::Manager() const
    {
    return *iManager;
    }

// -----------------------------------------------------------------------------
// CMceServerCore::FCPluginEngine
// -----------------------------------------------------------------------------
//
CFCPlugInEngine& CMceServerCore::FCPluginEngine() const
	{
	return *iFCPlugInEngine;
	}		

// -----------------------------------------------------------------------------
// CMceServerCore::RegisterFCSession
// -----------------------------------------------------------------------------
//
void CMceServerCore::RegisterFCSessionL( MFCObserver& aFCObserver, 
                                         const CFCSession& aFCSession )
    {
    TMceFCSessionItem item(aFCObserver, aFCSession);
    iFCSessions.AppendL(item);
    }

// -----------------------------------------------------------------------------
// CMceServerCore::DeregisterFCSession
// -----------------------------------------------------------------------------
//
void CMceServerCore::DeregisterFCSession( MFCObserver& aFCObserver, 
                                          const CFCSession& aFCSession )
    {
    TInt count = iFCSessions.Count() - 1;
    for (int i = count; i > 0; i--)
    	{
    	TMceFCSessionItem item = iFCSessions[i];
    	if (&item.iFCObserver == &aFCObserver && &item.iFCSession == &aFCSession)
    		{
    		iFCSessions.Remove(i);
    		}
    	(void)item;	
    	}
    }

// -----------------------------------------------------------------------------
// CMceServerCore::FCReceivedData
// -----------------------------------------------------------------------------
//
void CMceServerCore::FCReceivedData( HBufC8* aData, 
                                     const CFCSession* aFCSession )
    {
    TBool found = EFalse;
    TInt ind = 0;
    while ( !found && ind < iFCSessions.Count() )
        {
        TMceFCSessionItem item = iFCSessions[ ind ];
        if ( &item.iFCSession == aFCSession )
            {
            item.iFCObserver.FCReceivedData( aData, aFCSession );
            found = ETrue;
            }
        }
    }

// -----------------------------------------------------------------------------
// CMceServerCore::FCErrorNotify
// -----------------------------------------------------------------------------
//
void CMceServerCore::FCErrorNotify( TInt aErrCode, 
                                    const CFCSession* aFCSession )
    {
    TBool found = EFalse;
    TInt ind = 0;
    while ( !found && ind < iFCSessions.Count() )
        {
        TMceFCSessionItem item = iFCSessions[ ind ];
        if ( &item.iFCSession == aFCSession )
            {
            item.iFCObserver.FCErrorNotify( aErrCode, aFCSession );
            found = ETrue;
            }
        }
    }

//  End of File