// Copyright (c) 2005-2009 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:

// Name          : CSipServerCore.cpp

// Part of       : SIPServerCore

// Version       : SIP/4.0

//

#include <ecom/ecom.h>

#include <featmgr.h>

#include "CSipServerCore.h"

#include "sipclientserver.h"

#include "CleanupResetAndDestroy.h"

#include "CSipCSServer.h"

#include "CSipCSServerITC.h"

#include "CSipCSServerCloseTimer.h"

#include "CSipActiveScheduler.h"

#include "CSipCSSession.h"

#include "TimerManager.h"

#include "CSIPRoutingRequestStore.h"

#include "SipRequestHandlerBase.h"

#include "SipRequestHandlerInitParams.h"

#include "sipsec.h"

#include "CTransactionUser.h"

#include "CSipDialogMgr.h"

#include "MSipDialogs.h"

#include "CSIPRegistrationMgr.h"

#include "CSipRefreshMgr.h"

#include "CSipConnectionMgr.h"

#include "SipLogs.h"

#include "sipstrings.h"

#include "SIPHeaderLookup.h"

const TUint KServerCloseWaitTime = 500; // milliseconds

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

// CSipServerCore::NewL

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

//

CSipServerCore* CSipServerCore::NewL ()

	{

    CSipServerCore* self = CSipServerCore::NewLC();

    CleanupStack::Pop(self);

    return self;

	}

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

// CSipServerCore::NewLC

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

//

CSipServerCore* CSipServerCore::NewLC ()

	{

	CSipServerCore* self = new(ELeave)CSipServerCore;

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

	}

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

// CSipServerCore::ConstructL

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

//

void CSipServerCore::ConstructL ()

	{

	SIPStrings::OpenL();

	SIPHeaderLookup::OpenL();

	SIPHeaderLookup::SetConvertToSIPURI();

	FeatureManager::InitializeLibL();

	iFeatMgrInitialized = ETrue;

    iActiveScheduler = new (ELeave) CSipActiveScheduler ();

    CActiveScheduler::Install (iActiveScheduler);

	iITC = CSipCSServerITC::NewL();

    iContainerIndex = CObjectConIx::NewL ();

	iCloseTimer = CSipCSServerCloseTimer::NewL();

    iTimerMgr = CTimerManager::NewL ();

	iRoutingRequestStore = CSIPRoutingRequestStore::NewL(*this);

	LoadRequestHandlerL();

    iTU = CTransactionUser::NewL (iRoutingRequestStore,iTimerMgr,*this);

	iRefreshMgr = CSipRefreshMgr::NewL (*iTU,*iTimerMgr,SIPSec());

	iRegistrationMgr = CSIPRegistrationMgr::NewL(*iTU,*iRefreshMgr,*iTimerMgr,

	                                             SIPSec(),SigComp(),

	                                             iTU->SipConnectionMgr());

	iTU->SetRegistrations (iRegistrationMgr,iRegistrationMgr);

	iDialogMgr = CSipDialogMgr::NewL(*iTU,*iRefreshMgr,*iRegistrationMgr,

	                                 SIPSec(),SigComp());

	iTU->SetDialogs (iDialogMgr);

	iServer = CSipCSServer::NewL(*this);

    __SIP_LOG("SIP Server Created")

	}

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

// CSipServerCore::CSipServerCore

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

//

CSipServerCore::CSipServerCore ()

	{

	iFeatMgrInitialized = EFalse;

	}

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

// CSipServerCore::~CSipServerCore

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

//

CSipServerCore::~CSipServerCore ()

	{

	// This must be deleted first to remove SIP server from system's

	// list of servers asap.

	delete iServer;

    delete iDialogMgr;

    delete iRegistrationMgr;

    delete iRefreshMgr;

    delete iTU;

    delete iRequestHandler;

    delete iRoutingRequestStore;

    delete iTimerMgr;

	delete iCloseTimer;

    delete iContainerIndex;

	delete iITC;

    delete iActiveScheduler;

	CActiveScheduler::Install (NULL);

	SIPHeaderLookup::Close();

	SIPStrings::Close();

	REComSession::FinalClose();

	if(iFeatMgrInitialized)

		{

		FeatureManager::UnInitializeLib();

		}

	__SIP_LOG("SIP server shutdown completed")

#ifdef _BullseyeCoverage

    // Store coverage measurement

    cov_write();

#endif	

	}

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

// CSipServerCore::IncrementSessions

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

//

void CSipServerCore::IncrementSessions ()

	{

	if (iCloseTimer->IsActive())

        {

        iCloseTimer->Cancel();

        }

    iSessionCount++;

	}

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

// CSipServerCore::DecrementSessions

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

//

void CSipServerCore::DecrementSessions ()

	{

    iSessionCount--;

	if (iSessionCount == 0)

		{

		iCloseTimer->StopActiveSchedulerAfter(KServerCloseWaitTime);

		}

	}

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

// CSipServerCore::CreateTransportOwnerId

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

//

TUint32 CSipServerCore::CreateTransportOwnerId()

	{

	if (iTransportOwnerIdCounter < KMaxTUint32)

		{

		iTransportOwnerIdCounter++;

		}

	else

		{

		iTransportOwnerIdCounter = 1;

		}	

	return iTransportOwnerIdCounter;

	}	

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

// CSipServerCore::Server

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

//

CServer2& CSipServerCore::Server ()

	{

	return *iServer;

	}

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

// CSipServerCore::ObjectConIx

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

//

CObjectConIx& CSipServerCore::ObjectConIx ()

	{

	return *iContainerIndex;

	}

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

// CSipServerCore::ITC

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

//

CSipCSServerITC& CSipServerCore::ITC ()

	{

	return *iITC;

	}

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

// CSipServerCore::TU

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

//

CTransactionUser& CSipServerCore::TU ()

	{

    return *iTU;

	}

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

// CSipServerCore::DialogMgr

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

//

CSipDialogMgr& CSipServerCore::DialogMgr ()

	{

    return *iDialogMgr;

	}

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

// CSipServerCore::RegistrationMgr

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

//

CSIPRegistrationMgr& CSipServerCore::RegistrationMgr ()

	{

    return *iRegistrationMgr;

	}

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

// CSipServerCore::Registrations

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

//

MSipRegistrations& CSipServerCore::Registrations ()

	{

    return *iRegistrationMgr;

	}

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

// CSipServerCore::RefreshMgr

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

//

MSipRefreshMgr& CSipServerCore::RefreshMgr ()

	{

    return *iRefreshMgr;

	}

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

// CSipServerCore::SIPSec

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

//	

CSIPSec& CSipServerCore::SIPSec()

    {

    return iTU->SIPSec();

    }

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

// CSipServerCore::RequestHandler

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

//	   

CSIPRequestHandlerBase& CSipServerCore::RequestHandler()

	{

	return *iRequestHandler;

	}

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

// CSipServerCore::SigComp

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

//	

MSigComp& CSipServerCore::SigComp()

    {

    return iTU->SipConnectionMgr();

    }

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

// CSipServerCore::ConnectionMgr

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

//    

CSipConnectionMgr& CSipServerCore::ConnectionMgr()

    {

    return iTU->SipConnectionMgr();

    }	

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

// CSipServerCore::FindOwner

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

//    

MTransactionOwner* CSipServerCore::FindOwner(TUint32 aIapId, const TUid& aUid)

	{

	return iServer->FindOwner(aIapId,aUid);

	}

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

// CSipServerCore::ConnectionStateChangedL

// From MConnectionStateObserver:

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

//

void CSipServerCore::ConnectionStateChangedL (TUint32 aIapId,

                                              CSIPConnection::TState aState)

	{

	if (iServer)

		{

		iServer->ConnectionStateChangedL(aIapId,aState);

		}

	// inform all the interested subsystems if they exist

	if (iRefreshMgr)

        {

        iRefreshMgr->ConnectionStateChangedL (aIapId,aState);

        }

	if (iRegistrationMgr)

        {

        iRegistrationMgr->ConnectionStateChangedL(aIapId,aState);

        }

	if (iDialogMgr)

        {

        iDialogMgr->ConnectionStateChangedL (aIapId,aState);

        }

	}

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

// CSipServerCore::LoadRequestHandlerL

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

//	

void CSipServerCore::LoadRequestHandlerL()

	{

	RImplInfoPtrArray infoArray;

	REComSession::ListImplementationsL(KSIPRequestHandlerIFUid,

	                                   infoArray);

	CleanupResetAndDestroyPushL(infoArray);

	if (infoArray.Count() > 0 && infoArray[ 0 ])

	    {

	    CImplementationInformation& info = *(infoArray[ 0 ]);

	    TSIPRequestHandlerInitParams initParams(KServerUid3,

	                                            iRoutingRequestStore);

	    TEComResolverParams resolverParams;                                        

	    resolverParams.SetDataType(info.DataType());

		iRequestHandler = 

	        reinterpret_cast< CSIPRequestHandlerBase* >( 

	            REComSession::CreateImplementationL(

	                KSIPRequestHandlerIFUid, 

                    _FOFF(CSIPRequestHandlerBase,iInstanceKey),

                    &initParams,

                    resolverParams));

	    }

	else

	    {

	    User::Leave(KErrNotFound);

	    }

	CleanupStack::PopAndDestroy(1); // infoArray		

	}

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

// CSipServerCore::RefreshConnection

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

//

void CSipServerCore::RefreshConnectionL(TUint32 aIapId)

	{

    ConnectionMgr().RefreshConnectionL(aIapId);

	}

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

// CSipServerCore::GetConnectionErrorL

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

//

void CSipServerCore::GetConnectionErrorL(TUint32 aIapId,TInt& aError)

	{

	aError = ConnectionMgr().ConnectionErrorL(aIapId);

	}