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

//

#include "LogServServer.h"

#include "logservsession.h"

#include "logservpanic.h"

#include "LogServShutdownTimer.h"

#include "LogServDatabaseMarshall.h"

#include "LogServDatabaseDriver.h"

#include "LogServBackupManager.h"

#include "LogServOperationQueue.h"

#include "LogServResourceInterpreter.h"

#include "LogServDatabaseChangeTracker.h"

#include "LogServRecentListManager.h"

/////////////////////////////////////////////////////////////////////////////////////////

// -----> CLogServServer (source)

/////////////////////////////////////////////////////////////////////////////////////////

CLogServServer::CLogServServer()

:	CServer2(CActive::EPriorityStandard, ESharableSessions)

	{

	}

CLogServServer::~CLogServServer()

	{

	LOGTEXT("CLogServServer::~CLogServServer()");

	TDblQueIter<CSession2> iter(iSessionIter);

	iter.SetToFirst();

	for (CSession2* session = iter++; session != NULL; session = iter++)

		{

		delete session;

		}

	// Order is important

	delete iOperationQueue;

	//

	delete iDatabaseDriver;

	delete iChangeTracker;

	delete iDatabaseMarshall;

	//

	delete iRecentListManager;

	delete iResourceInterpreter;

	//

	delete iBackupManager;

	delete iShutdownTimer;

	iFsSession.Close();

	LOGTEXT("CLogServServer::~CLogServServer() - end");

	}

void CLogServServer::ConstructL()

	{

	LOGTEXT("CLogServServer::ConstructL() - about to connect to file server");

	User::LeaveIfError(iFsSession.Connect());

	LOGTEXT("CLogServServer::ConstructL() - about to start server");

	StartL(KLogServerFullName);

	// Low level objects

	LOGTEXT("CLogServServer::ConstructL() - about to create shutdown timer");

	iShutdownTimer = CLogServShutdownTimer::NewL(Priority() + 1);

	LOGTEXT("CLogServServer::ConstructL() - about to create backup manager");

	iBackupManager = CLogServBackupManager::NewL(Priority());

	LOGTEXT("CLogServServer::ConstructL() - about to create resource interpreter");

	iResourceInterpreter = CLogServResourceInterpreter::NewL(iFsSession);

	LOGTEXT("CLogServServer::ConstructL() - about to create recent list manager");

	iRecentListManager = CLogServRecentListManager::NewL(*iResourceInterpreter, R_LOG_RECENT);

	// Medium level objects

	LOGTEXT("CLogServServer::ConstructL() - about to create database marshall");

	iDatabaseMarshall = CLogServDatabaseMarshall::NewL(iFsSession, *iResourceInterpreter, *iBackupManager);

	LOGTEXT("CLogServServer::ConstructL() - about to create change tracker");

	iChangeTracker = CLogServDatabaseChangeTracker::NewL(*iDatabaseMarshall, *iBackupManager, Priority() + 1);

	// Setup the pointer to the change tracker from within the database marshall (since its underlying

	// mixin provides a means of submitting change events)

	LOGTEXT("CLogServServer::ConstructL() - about to set change interface for database marshall ");

	iDatabaseMarshall->SetChangeInterface(*iChangeTracker);

	// These objects are quite high level... i.e. they use the engine objects above

	LOGTEXT("CLogServServer::ConstructL() - about to create database driver");

	iDatabaseDriver = CLogServDatabaseDriver::NewL(*iBackupManager, *iDatabaseMarshall, *iResourceInterpreter, *iRecentListManager, Priority() - 1);

	LOGTEXT("CLogServServer::ConstructL() - about to create operation queue");

	iOperationQueue = CLogServOperationQueue::NewL(*iDatabaseDriver, Priority());

	// Ensure that the server still exits even if the 1st client fails to connect

	// Only shutdown the server if it's transient - by default it isn't, but keeping

	// this code here in case this changes

	if	(iTransient)

		iShutdownTimer->Start();

	LOGTEXT("CLogServServer::ConstructL() - end");

	}

CLogServServer* CLogServServer::NewLC()

	{

	CLogServServer* self = new(ELeave) CLogServServer;

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

void CLogServServer::SLOHandleEvent(TLogServSessionId /*aId*/, TLogServSessionEvent aEvent)

	{

	switch(aEvent)

		{

	case ELogServSessionEventCreated:

		iShutdownTimer->Cancel();

		++iSessionCount;

		break;

	case ELogServSessionEventDestroyed:

		// Only shutdown the server if it's transient - by default it isn't

		if	(--iSessionCount == 0 && iTransient)

			iShutdownTimer->Start();

		break;

		}

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

CSession2* CLogServServer::NewSessionL(const TVersion& /*aVersion*/,const RMessage2& /*aMessage*/) const

//

//	Create a new client session. This should really check the version number.

//

	{

	CLogServServer* self = const_cast<CLogServServer*>(this);

	const TLogServSessionId sessionId = ++self->iNextFreeSessionId;

	LOGTEXT2("CLogServServer::NewSessionL() - session id is: %d", sessionId);

	//

	CLogServSession* session = new(ELeave) CLogServSession(sessionId, 

												*self,

												*iBackupManager,

												*iDatabaseDriver,

												*iOperationQueue,

												*iChangeTracker,

												*iDatabaseMarshall);

	LOGTEXT("CLogServServer::NewSessionL() - end");

	return session;

	}

#ifdef _DEBUG

void CLogServServer::MakeTransient(TBool aTransient)

	{

	iTransient = aTransient;

	}

#endif//_DEBUG

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////