// 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:

// Implementation of the Configurator server Session for on demand loading of CPMs.

// 

//

#include "c32startshared.h"

#include "c32startserv.h"

/**

@file 

Implements Configurator server session implementation.

@publishedPartner

*/

CRsConfiguratorServerSession::CRsConfiguratorServerSession(const CRsConfiguratorServer* aConfiguratorServer)

:CSession2(),

iConfiguratorServer((CRsConfiguratorServer*) aConfiguratorServer)

	/** C'tor

	*/

	{

	}

TInt CRsConfiguratorServerSession::LoadCpm(const RMessage2& aMessage)

	/** Loads comms provider module which is marked as on demand in CMI file.

	*/

	{

	TCFModuleNameF moduleName;

	TInt result = aMessage.Read(0, moduleName);

	if(KErrNone == result)

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L8("CRsConfiguratorServerSession::LoadCpm (%S)"), &moduleName);

		result = iConfiguratorServer->LoadCpm(moduleName, aMessage);

		}

	else

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L("CRsConfiguratorServerSession::LoadCpm error reading module name %d"), result);

		}

	return result;	

	}

TInt CRsConfiguratorServerSession::EnumerateModules(const RMessage2& aMessage)

	/** Returns a module name from list of modules which matches the group name. 

	*/

	{

	__FLOG_STATIC0(KSubsys,KComponent,_L("CRsConfiguratorServerSession::EnumerateModules"));

	TPckgBuf<TRSIter> ipcPosition;

	TInt result = aMessage.Read(0, ipcPosition);

	if(KErrNone == result)

		{

		TInt& position = ipcPosition()();

		TCFGroupNameF groupName;

		result = aMessage.Read(1, groupName);

		TCFModuleNameF moduleName;

		result = iConfiguratorServer->EnumerateModules(groupName,position, moduleName);

		if(KErrNone == result)

       		{

			result = aMessage.Write(2, moduleName);

			if(KErrNone == result)

       			{

				++position;

				result = aMessage.Write(0, ipcPosition);

				}

			}

		}

    return result;

	}

TInt CRsConfiguratorServerSession::GetModuleIniData(const RMessage2& aMessage)

	/** Fetches data contained by [inidata] section of CMI file for Comms Provider Module.

	*/

	{

	TCFModuleNameF moduleName;

	TInt result = aMessage.Read(0, moduleName);

	if(KErrNone == result)

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L8("CRsConfiguratorServerSession::GetModuleIniData (%S)"), &moduleName);

    	result = iConfiguratorServer->GetModuleIniData(moduleName, aMessage);

		}

	else

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L("CRsConfiguratorServerSession::GetModuleIniData error reading module name %d"), result);

		}

    return result;	

	}

void CRsConfiguratorServerSession::ServiceL(const RMessage2& aMessage)

	{	

	TInt result;

	switch(aMessage.Function())

		{

		case CSLoadCpm:

			// if load request is successful KErrNone is returned

			// message is completed once the root server completes loading.

			// if any other error before load request, message is completed here.

			result = LoadCpm(aMessage); 

			if(result!=KErrNone)

				{

				aMessage.Complete(result);

				}

			break;

		case CSUnloadCpm:

			result = UnloadCpm(aMessage);

			if(result!=KErrNone)

				{

				aMessage.Complete(result);

				}

			break;

		case CSCancelLoadCpm:

			result = CancelLoadCpm(aMessage);

			aMessage.Complete(result);

			break;

		case CSCancelUnloadCpm:

			result = CancelUnloadCpm(aMessage);

			aMessage.Complete(result);

			break;

		case CSEnumerateModules: 

			result=EnumerateModules(aMessage);

			aMessage.Complete(result);

			break;

		case CSGetModuleIniData:

			result=GetModuleIniData(aMessage);

			aMessage.Complete(result);

			break;

		default:

			aMessage.Complete(KErrNotSupported);

			break;	

		}

	}

TInt CRsConfiguratorServerSession::UnloadCpm(const RMessage2& aMessage)

	/**Unloads comms Provider Module loaded by the configurator

	*/

	{

	TCFModuleNameF moduleName;

	TInt result = aMessage.Read(0, moduleName);

	if(KErrNone == result)

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L8("CRsConfiguratorServerSession::UnloadCpm (%S)"), &moduleName);

		result = iConfiguratorServer->UnLoadCpm(moduleName, aMessage);

		}

	else

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L("CRsConfiguratorServerSession::UnloadCpm error reading module name %d"), result);

		}

	return result;	

	}

TInt CRsConfiguratorServerSession::CancelLoadCpm(const RMessage2& aMessage)

	/**Cancel asynchronous loading of a comms Provider Module. 

	There is no guarantee the module unloading is canceled. 

	A best effort is made and the asynchronous request waiting for the module 

	to load returns KErrCanceled on success.

	*/

	{

	TCFModuleNameF moduleName;

	TInt result = aMessage.Read(0, moduleName);

	if(KErrNone == result)

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L8("CRsConfiguratorServerSession::CancelLoadCpm (%S)"), &moduleName);

		result = iConfiguratorServer->CancelLoadCpm(moduleName);

		}

	else

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L8("CRsConfiguratorServerSession::CancelLoadCpm error %d reading module name"), result);

		}

	return result;	

	}

TInt CRsConfiguratorServerSession::CancelUnloadCpm(const RMessage2& aMessage)

	/**Cancel asynchronous unloading of a comms Provider Module. 

	There is no guarantee the module unloading is canceled. 

	A best effort is made and the asynchronous request waiting for the module 

	to load returns KErrCanceled on success.

	*/

	{

	TCFModuleNameF moduleName;

	TInt result = aMessage.Read(0, moduleName);

	if(KErrNone == result)

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L8("CRsConfiguratorServerSession::CancelUnloadCpm (%S)"), &moduleName);

		result = iConfiguratorServer->CancelUnLoadCpm(moduleName);

		}

	else

		{

		__FLOG_STATIC1(KSubsys,KComponent,_L8("CRsConfiguratorServerSession::CancelUnloadCpm error %d reading module name"), result);

		}

	return result;	

	}