/*

* Copyright (c) 2003 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 "CdlServer.h"

CCdlDllsWatcherBase::CCdlDllsWatcherBase(RFs& aFs)

: CActive(CActive::EPriorityStandard), iFs(aFs)

	{

	CActiveScheduler::Add(this);

	}

CCdlServer::CCdlServer()

	:CServer2(0)

	{}

CCdlServer::~CCdlServer()

	{

	delete iDllWatcher;

	delete iAllRefs;

	delete iState;

	delete iEngRef;

	iFs.Close();

	}

CServer2* CCdlServer::NewLC()

	{

	CCdlServer* self=new(ELeave) CCdlServer;

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

//

// 2nd phase construction - ensure the timer and server objects are running

//

void CCdlServer::ConstructL()

	{

	StartL(KCdlServerName);

	iShutdown.ConstructL();

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

	iShutdown.Start();

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

	iEngRef = CdlServerEngine::CreateCdlEngineL();

	iState = CCdlRefs::NewL();

	iAllRefs = CCdlRefs::NewL();

	CCdlDllsWatcherBase::NewL(iDllWatcher, iFs, this);

	}

//

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

//

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

	{

	return new(ELeave) CCdlSession();

	}

//

// A new session is being created

// Cancel the shutdown timer if it was running

//

void CCdlServer::AddSession()

	{

	++iSessionCount;

	iShutdown.Cancel();

	}

//

// A session is being destroyed

// Start the shutdown timer if it is the last session.

//

void CCdlServer::DropSession()

	{

	if (--iSessionCount==0)

		iShutdown.Start();

	}

//

// Handle an error from CCdlSession::ServiceL()

// A bad descriptor error implies a badly programmed client, so panic it;

// otherwise report the error to the client

//

TInt CCdlServer::RunError(TInt aError)

	{

	if (aError == KErrBadDescriptor)

		PanicClient(Message(),EPanicBadDescriptor);

	else if (aError == KErrArgument)

		PanicClient(Message(), EPanicParamOutOfRange);

	else

		Message().Complete(aError);

	//

	// The leave will result in an early return from CServer::RunL(), skipping

	// the call to request another message. So do that now in order to keep the

	// server running.

	ReStart();

	return KErrNone;	// handled the error fully

	}

CCdlRefs* CCdlServer::GetStateLC(const CCdlUids& aUids) const

	{

	return iState->SubsetByUidsLC(aUids);

	}

void CCdlServer::SetStateL(CCdlRefs* aState)

	{

	CCdlUids* uids = aState->UidsLC();

	iState->MergeAndReplaceL(*aState);

	iSessionIter.SetToFirst();

	CSession2* s;

	while ((s = iSessionIter++) != 0)

		static_cast<CCdlSession*>(s)->HandleCustChangeL(*uids);

	CleanupStack::PopAndDestroy(uids);

	}

void CCdlServer::McdoPrepareForChangesL()

	{

	}

void CCdlServer::McdoFileAddedL(const TDesC& aFile)

	{

	CCdlRefCollection* refs = FileContentsLC(aFile);

	iAllRefs->AppendL(*refs);

	CleanupStack::PopAndDestroy(refs);

	}

void CCdlServer::McdoFileRemovedL(const TDesC& aFile)

	{

	iAllRefs->Delete(aFile);

	}

void CCdlServer::McdoChangesCompleteL()

	{

	iSessionIter.SetToFirst();

	CSession2* s;

	while ((s = iSessionIter++) != 0)

		static_cast<CCdlSession*>(s)->HandleRefsChangeL();

	}

const CCdlRefs& CCdlServer::AllRefs() const

	{

	return *iAllRefs;

	}

TInt CCdlServer::IsPluginInRom(const TDesC& aFileName, TBool& aIsInRom)

	{

	return iDllWatcher->IsPluginInRom(aFileName, aIsInRom);

	}

TInt CCdlServer::PluginDrive(const TDesC& aFileName, TDriveUnit& aDrive)

	{

	return iDllWatcher->PluginDrive(aFileName, aDrive);

	}