sl@0: // Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // The Implementation of the CEComServer singleton class which
sl@0: // instantiates an instance of the requested ECom Interface Implementation.
sl@0: // 
sl@0: //
sl@0: 
sl@0: /**
sl@0:  @internalComponent
sl@0:  @file
sl@0: */
sl@0: #include <e32base.h>
sl@0: #include <bautils.h>
sl@0: #include <startupdomaindefs.h>
sl@0: #include "EComDebug.h"
sl@0: #include <ecom/ecom.h>
sl@0: #include <ecom/ecomerrorcodes.h>
sl@0: #include <ecom/ecomresolverparams.h>
sl@0: #include <ecom/implementationinformation.h>
sl@0: 
sl@0: #include "ServerStartupManager.h"
sl@0: #include "RegistryData.h"
sl@0: #include "Registrar.h"
sl@0: #include "DefaultResolver.h"
sl@0: #include "RomOnlyResolver.h"
sl@0: #include "TlsData.h"
sl@0: #include "EComServerStart.h"
sl@0: #include "EComMessageIds.h"
sl@0: #include "EComServerSession.h"
sl@0: #include "EComServer.h"
sl@0: #include "EComUidCodes.h"
sl@0: #include "EComPerformance.h"
sl@0: #include "DriveInfo.h"
sl@0: #include "FileUtils.h"
sl@0: #include "RegistryResolveTransaction.h"
sl@0: #include "resolvercache.h"
sl@0: #include "EComPatchDataConstantv2.h"
sl@0: 
sl@0: #define UNUSED_VAR(a) a = a
sl@0: 
sl@0: /** enum for special system events */
sl@0: enum TSpecialEvents
sl@0: 	{
sl@0: 	EBURInProgress,
sl@0: 	ESWIInProgress
sl@0: 	};
sl@0: 
sl@0: /** The location of server INI file. */
sl@0: _LIT(KEComSrvrIniFile,"_:\\private\\10009D8F\\EComSrvr.ini");
sl@0: /** Buffer descriptor to hold full path and name of server INI file. */
sl@0: typedef TBuf<32> TEComSrvrIniFileName;
sl@0: 
sl@0: _LIT(KEComSrvrIniFileROM,"Z:\\private\\10009D8F\\EComSrvr.ini");
sl@0: 
sl@0: static void CloseAndDeleteImplInfoArray(TAny* aObject)
sl@0: 	{
sl@0: 	RImplInfoArray* array=reinterpret_cast<RImplInfoArray*>(aObject);
sl@0: 	if (array)
sl@0: 		{
sl@0: 		array->Close();
sl@0: 		}
sl@0: 	delete array;
sl@0: 	}
sl@0: //
sl@0: // Initiate server exit when the timer expires
sl@0: // by stopping the local scheduler.
sl@0: void CShutdown::RunL()
sl@0: 	{
sl@0: 	CActiveScheduler::Stop();
sl@0: 	}
sl@0: 
sl@0: CEComServer* CEComServer::NewLC()
sl@0: 	{
sl@0: 	// Standard 2 phase construction code
sl@0: 	CEComServer* instance = new(ELeave) CEComServer;
sl@0: 	CleanupStack::PushL(instance);
sl@0: 	instance->ConstructL();
sl@0: 	return instance;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CEComServer::~CEComServer()
sl@0: 	{
sl@0: 	// Uninstall callbacks first. Do not want to receive any callback
sl@0: 	// in destructor. TCallBackWithArg constructed with no argument
sl@0: 	// is a null callback.
sl@0: 	TCallBackWithArg nullCallback;
sl@0: 	if (iRegistrar)
sl@0: 		{
sl@0: 		iRegistrar->InstallSwiEventCallBack(nullCallback);
sl@0: 		iRegistrar->InstallBurEventCallBack(nullCallback);
sl@0: 		}
sl@0: 	if (iRegistryData)
sl@0: 		{
sl@0: 		iRegistryData->SetImplUpgradeCallBack(nullCallback);
sl@0: 		}
sl@0: 
sl@0: 	// Ensure this deletion order is maintained - in particular the registrydata 
sl@0: 	// must last longer than the others which hold a reference to it.
sl@0: 
sl@0: 	//remove the CServerStartupMgr
sl@0: 	delete iServerStartupMgr;
sl@0: 	// Then destroy the registrar object
sl@0: 	delete iRegistrar;
sl@0: 	// remove the registry data
sl@0: 	delete iRegistryData;
sl@0: 	
sl@0: 	delete iResolverCache;
sl@0: 
sl@0: 	// Finally close down the file server connection
sl@0: 	iFs.Close();
sl@0: 	// Make sure the non-default resolver library is closed
sl@0: 	iResolverLibrary.Close();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CEComServer::CEComServer()
sl@0: : CServer2(CActive::EPriorityStandard)
sl@0: 	{
sl@0: 	// Do nothing
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CEComServer::ConstructL()
sl@0: 	{
sl@0: 	START_TIMER
sl@0: 	START_HEAP
sl@0: 	StartL(KEComServerName);
sl@0: 	// Connect to the file server
sl@0: 	User::LeaveIfError(iFs.Connect());
sl@0: 	__ECOM_TRACE("ECOM: Server INIT - File Server session initialised");
sl@0: 	// construct the registry data handling object here
sl@0: 	iRegistryData = CRegistryData::NewL(iFs);
sl@0: 	__ECOM_TRACE("ECOM: Server INIT - Registry Data initialised");
sl@0: 	// Then the registrar
sl@0: 	iRegistrar = CRegistrar::NewL(*iRegistryData, *this, iFs);
sl@0: 	__ECOM_TRACE("ECOM: Server INIT - Registrar initialised");
sl@0: 	
sl@0: 	//Then the CServerStartupMgr
sl@0: 
sl@0: #ifdef SYMBIAN_SYSTEM_STATE_MANAGEMENT
sl@0: 	iServerStartupMgr = new(ELeave) CServerStartupMgr(KDmHierarchyIdStartup, KSM2OSServicesDomain3, iFs);
sl@0: #else
sl@0: 	iServerStartupMgr = new(ELeave) CServerStartupMgr(KDmHierarchyIdStartup, KBaseServicesDomain3, iFs);
sl@0: #endif //SYMBIAN_SYSTEM_STATE_MANAGEMENT
sl@0: 
sl@0: 	__ECOM_TRACE("ECOM: Server INIT - ServerStartupMgr initialised");
sl@0: 	iServerStartupMgr->RegisterObserverL(iRegistrar);
sl@0: 	
sl@0: 	iServerStartupMgr->InitialiseL(IsSSA(iFs));
sl@0: 	
sl@0: 	iResolverCache = CCustomResolverCache::NewL(KCustomResolverCacheSize,
sl@0: 		KCustomResolverCacheTimeout);
sl@0: 
sl@0: 	TCallBackWithArg eventCallback(&CEComServer::NotifyEvents, this);
sl@0: 	iRegistrar->InstallSwiEventCallBack(eventCallback);
sl@0: 	iRegistrar->InstallBurEventCallBack(eventCallback);
sl@0: 	iRegistryData->SetImplUpgradeCallBack(eventCallback);
sl@0: 
sl@0: 	// The server is about to start so construct the transient shutdown guy
sl@0: 	iShutdown.ConstructL();
sl@0: 	// ensure that the server still exits even
sl@0: 	// if the server start fails or the
sl@0: 	// 1st client fails to connect
sl@0: 	iShutdown.Start();
sl@0: 	RECORD_INITIALISE_HEAP
sl@0: 	RECORD_INITIALISE_RESULT
sl@0: 	}
sl@0: 	
sl@0: TBool CEComServer::IsSSA(RFs& aFs)
sl@0: 	{
sl@0: 	// Check Z drive first.
sl@0: 	TBool isFileExisting = BaflUtils::FileExists(aFs, KEComSrvrIniFileROM);
sl@0: 	// Check system drive next
sl@0: 	if(!isFileExisting)
sl@0: 		{
sl@0: 		TEComSrvrIniFileName iniFile(KEComSrvrIniFile);
sl@0: 		TEComFileUtils::SetToDrive(iniFile,iRegistryData->iSystemDrive);
sl@0: 		isFileExisting = BaflUtils::FileExists(aFs, iniFile);
sl@0: 		}
sl@0: 	return !isFileExisting;		
sl@0: 	}
sl@0: 
sl@0: // Get implementation info for one implementation, and return to client
sl@0: void CEComServer::GetImplementationInformationL(const TUid& aImplementationUid,
sl@0: 												CImplementationInformation*& aImplInfo,
sl@0: 												const TClientRequest& aClientRequest)
sl@0: 	{
sl@0: 	TEntry dllInfo;
sl@0: 	User::LeaveIfError(iRegistryData->GetImplementationDllInfoForClientL(
sl@0: 		aClientRequest, aImplementationUid, KNullUid, dllInfo, aImplInfo, ETrue));
sl@0: 	}
sl@0: 
sl@0: RImplInfoArray* CEComServer::ListImplementationsL(TUid aInterfaceUid, 
sl@0: 												   const TEComResolverParams& aAdditionalParameters, 
sl@0: 												   TUid aResolverUid,
sl@0: 												   const RExtendedInterfacesArray& aExtendedInterfaces,
sl@0: 												   const TClientRequest& aMessage
sl@0: 												   ) 
sl@0: 	{
sl@0: 	RImplInfoArray* result = NULL;
sl@0: 	CResolver* resolver = NULL;
sl@0: 	//create registry resolver transaction
sl@0: 	//get the TListImplParam parameters
sl@0: 	TBool capability= ETrue;
sl@0: 	if(!(aMessage.IsNull()))
sl@0: 		{
sl@0: 		TListImplParam listParam;
sl@0:   		TPckg<TListImplParam> listParamPkg(listParam);
sl@0:   		aMessage.ReadL(2,listParamPkg);
sl@0:   		capability=listParam.iCapabilityCheck;
sl@0: 		}
sl@0:   	
sl@0:   	
sl@0: 	CRegistryResolveTransaction* registryResolveTransaction = CRegistryResolveTransaction::NewL(*iRegistryData,
sl@0: 																								aExtendedInterfaces,
sl@0: 																								aMessage,capability);
sl@0: 	CleanupStack::PushL(registryResolveTransaction);
sl@0: 	//create resolver
sl@0: 	resolver = CreateResolverLC(aResolverUid,registryResolveTransaction);
sl@0: 	result = ListImplementationsL(aInterfaceUid, aAdditionalParameters, resolver);
sl@0: 	//clean up
sl@0: 	CleanupStack::PopAndDestroy(resolver);
sl@0: 	CleanupStack::PopAndDestroy(registryResolveTransaction);
sl@0: 	if ((aResolverUid != KDefaultResolverUid) && (aResolverUid != KRomOnlyResolverUid))
sl@0: 		{
sl@0: 		iResolverLibrary.Close();
sl@0: 		}
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: RImplInfoArray* CEComServer::ListImplementationsL(TUid aInterfaceUid, 
sl@0: 												   TUid aResolverUid,
sl@0: 												   const RExtendedInterfacesArray& aExtendedInterfaces,
sl@0: 												   const TClientRequest& aMessage
sl@0: 												   ) 
sl@0: 	{
sl@0: 	RImplInfoArray* result = NULL;
sl@0: 	CResolver* resolver = NULL;
sl@0: 	//create registry resolver transaction
sl@0: 	//get the TListImplParam parameters
sl@0:   		//get the TListImplParam parameters
sl@0: 	TBool capability= ETrue;
sl@0: 	if(!(aMessage.IsNull()))
sl@0: 		{
sl@0: 		TListImplParam listParam;
sl@0:   		TPckg<TListImplParam> listParamPkg(listParam);
sl@0:   		aMessage.ReadL(2,listParamPkg);
sl@0:   		capability=listParam.iCapabilityCheck;
sl@0: 		}
sl@0: 	CRegistryResolveTransaction* registryResolveTransaction = CRegistryResolveTransaction::NewL(*iRegistryData,
sl@0: 																								aExtendedInterfaces,
sl@0: 																								aMessage,capability);
sl@0: 	CleanupStack::PushL(registryResolveTransaction);
sl@0: 	//create resolver
sl@0: 	resolver = CreateResolverLC(aResolverUid,registryResolveTransaction);
sl@0: 	result = ListImplementationsL(aInterfaceUid, resolver);
sl@0: 	//clean up
sl@0: 	CleanupStack::PopAndDestroy(resolver);
sl@0: 	CleanupStack::PopAndDestroy(registryResolveTransaction);
sl@0: 	if ((aResolverUid != KDefaultResolverUid) && (aResolverUid != KRomOnlyResolverUid))
sl@0: 		{
sl@0: 		iResolverLibrary.Close();
sl@0: 		}
sl@0: 	return result;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: RImplInfoArray* CEComServer::ListImplementationsL(TUid aInterfaceUid, 
sl@0: 												   const TEComResolverParams& aAdditionalParameters,
sl@0: 												   const RExtendedInterfacesArray& aExtendedInterfaces,
sl@0: 												   const TClientRequest& aMessage) 
sl@0: 	{
sl@0: 	// Use the default resolver in the overloaded method.
sl@0: 	return ListImplementationsL(aInterfaceUid, aAdditionalParameters, KDefaultResolverUid,aExtendedInterfaces, aMessage);
sl@0: 	}
sl@0: 
sl@0: RImplInfoArray* CEComServer::ListImplementationsL(TUid aInterfaceUid,
sl@0: 												  const RExtendedInterfacesArray& aExtendedInterfaces,	
sl@0: 												  const TClientRequest& aMessage) 
sl@0: 	{
sl@0: 	// Use the default resolver in the overloaded method.
sl@0: 	return ListImplementationsL(aInterfaceUid, KDefaultResolverUid,aExtendedInterfaces, aMessage);
sl@0: 	}
sl@0: 
sl@0: // The private helper
sl@0: 
sl@0: RImplInfoArray* CEComServer::ListImplementationsL(TUid aInterfaceUid, 
sl@0: 												   const TEComResolverParams& aAdditionalParameters, 
sl@0: 												   CResolver* aResolver) const
sl@0: 	{
sl@0: 	if(!aResolver)
sl@0: 		User::Leave(KEComErrNoResolver);
sl@0: 	// Use the client provided resolver to build up the list.
sl@0: 	RImplInfoArray* infoArray = aResolver->ListAllL(aInterfaceUid, aAdditionalParameters);
sl@0: 	return infoArray;
sl@0: 	}
sl@0: 
sl@0: RImplInfoArray* CEComServer::ListImplementationsL(TUid aInterfaceUid, 
sl@0: 												  CResolver* aResolver) const
sl@0: 	{
sl@0: 	if(!aResolver)
sl@0: 		User::Leave(KEComErrNoResolver);
sl@0: 	// Use the provided resolver to build up the list.
sl@0: 	RImplInfoArray* infoArray = &aResolver->ListAllL(aInterfaceUid);
sl@0: 	// infoArray points to iImplementationInfo, which is owned by CRegistryResolveTransaction. 
sl@0: 	// CRegistryResolveTransaction object is transient and will be destroyed before return the implementation
sl@0: 	// info list to the CEComServerSession. Therefore, we need to have a copy to return
sl@0: 	RImplInfoArray* retList = new (ELeave) RImplInfoArray;
sl@0: 	CleanupStack::PushL(TCleanupItem(CloseAndDeleteImplInfoArray,retList));
sl@0: 	const TInt numImps = infoArray->Count();
sl@0: 	for(TInt index = 0; index < numImps; ++index)
sl@0: 		{	
sl@0: 		retList->AppendL((*infoArray)[index]);
sl@0: 		}
sl@0: 	// Reset the member variable because we are passing ownership back
sl@0: 	CleanupStack::Pop();
sl@0: 	return retList;
sl@0: 	}
sl@0: 
sl@0: void CEComServer::GetResolvedDllInfoL(	const TUid aImplementationUid,
sl@0: 										TEntry& aDllInfo,
sl@0: 										TUid& aDtor_Key,
sl@0: 										const TClientRequest& aClientRequest)
sl@0: 	{
sl@0: 	// No resolution to do create directly.
sl@0: 	aDtor_Key = aImplementationUid;
sl@0: 	CImplementationInformation* implInfo = NULL;
sl@0: 	TUid dummyUid={0x00000000};
sl@0: 	//We need to do the security check for the case that implementationUid is known.
sl@0: 	//if implementationUid is unknown, the security check will be done in ListImplementationsL.
sl@0: 	User::LeaveIfError(iRegistryData->GetImplementationDllInfoForClientL(
sl@0: 		aClientRequest, aImplementationUid, dummyUid, aDllInfo, implInfo, ETrue));
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CEComServer::GetResolvedDllInfoL(  const TUid aInterfaceUid,
sl@0: 										const TEComResolverParams& aAdditionalParameters,
sl@0: 										const RExtendedInterfacesArray& aExtendedInterfaces,
sl@0: 										TEntry& aDllInfo, 
sl@0: 										TUid& aDtor_Key,
sl@0: 										const TClientRequest& aClientRequest)
sl@0: 	{
sl@0: 	GetResolvedDllInfoL(aInterfaceUid, aAdditionalParameters, KDefaultResolverUid, aExtendedInterfaces, aDllInfo, aDtor_Key, aClientRequest);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CEComServer::GetResolvedDllInfoL(  const TUid aInterfaceUid,
sl@0: 										const TEComResolverParams& aAdditionalParameters,
sl@0: 										const TUid aResolverUid,
sl@0: 										const RExtendedInterfacesArray& aExtendedInterfaces,
sl@0: 										TEntry& aDllInfo,
sl@0: 										TUid& aDtor_Key,
sl@0: 										const TClientRequest& aClientRequest)
sl@0: 	{
sl@0: 	CResolver* resolver = NULL;
sl@0: 	TBool capability= ETrue;
sl@0: 	//create registry resolver transaction
sl@0: 	CRegistryResolveTransaction* registryResolveTransaction = CRegistryResolveTransaction::NewL(*iRegistryData,
sl@0: 																								aExtendedInterfaces,
sl@0: 																								aClientRequest,capability);
sl@0: 	CleanupStack::PushL(registryResolveTransaction);
sl@0: 	//create resolver
sl@0: 	resolver = CreateResolverLC(aResolverUid,registryResolveTransaction);
sl@0: 	aDtor_Key = resolver->IdentifyImplementationL(aInterfaceUid, aAdditionalParameters);
sl@0: 
sl@0: 	//clean up
sl@0: 	CleanupStack::PopAndDestroy(resolver);
sl@0: 	CleanupStack::PopAndDestroy(registryResolveTransaction);
sl@0: 	if ((aResolverUid != KDefaultResolverUid) && (aResolverUid != KRomOnlyResolverUid))
sl@0: 		{
sl@0: 		iResolverLibrary.Close();
sl@0: 		}
sl@0: 	CImplementationInformation* implInfo = NULL;
sl@0: 	//Don't need to do the security check because it has been done in IdentifyImplementationL.
sl@0: 	User::LeaveIfError(iRegistryData->GetImplementationDllInfoForClientL(
sl@0: 		aClientRequest, aDtor_Key, aInterfaceUid, aDllInfo, implInfo, EFalse));
sl@0: 	}
sl@0: 
sl@0: // Server Session management
sl@0: CSession2* CEComServer::NewSessionL(const TVersion& aVersion,const RMessage2& /* aMessage*/) const
sl@0: 	{
sl@0: 	const TVersionName version = CONST_CAST(TVersion&,aVersion).Name();
sl@0: 	const TVersionName thisVersion = TVersion(KEComServerMajorVN,KEComServerMinorVN,KEComServerBuildVN).Name();
sl@0: 	if(thisVersion != version)
sl@0: 		User::Leave(KErrNotSupported);
sl@0: 	return new(ELeave) CEComServerSession();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // A new session is being created
sl@0: // Cancel the shutdown timer if it was running
sl@0: //
sl@0: void CEComServer::AddSession()
sl@0: 	{
sl@0: 	++iSessionCount;
sl@0: 	iShutdown.Cancel();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // A session is being destroyed
sl@0: // Start the shutdown timer if it is the last session.
sl@0: //
sl@0: void CEComServer::DropSession()
sl@0: 	{
sl@0: 	if (--iSessionCount==0)
sl@0: 		iShutdown.Start();
sl@0: 	}
sl@0: 
sl@0: void CEComServer::Notification(TInt aCompletionCode)
sl@0: //
sl@0: // Pass on the signal to all clients
sl@0: //
sl@0: 	{
sl@0: 	iSessionIter.SetToFirst();
sl@0: 	CSession2* s;
sl@0: 	while ((s = iSessionIter++)!=0)
sl@0: 		STATIC_CAST(CEComServerSession*,s)->CompleteNotifications(aCompletionCode);
sl@0: 	}
sl@0: 
sl@0: TInt CEComServer::RunError(TInt aError)
sl@0: //
sl@0: // Handle an error from CMySession::ServiceL()
sl@0: // A bad descriptor error implies a badly programmed client, so panic it;
sl@0: // otherwise report the error to the client
sl@0: //
sl@0: 	{
sl@0: 	if (aError == KErrBadDescriptor)
sl@0: 		{
sl@0: 		PanicClient(Message(), aError);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		Message().Complete(aError);
sl@0: 		}
sl@0: 	//
sl@0: 	// The leave will result in an early return from CServer::RunL(), skipping
sl@0: 	// the call to request another message. So do that now in order to keep the
sl@0: 	// server running.
sl@0: 	ReStart();
sl@0: 	return KErrNone;	// handled the error fully
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Creates resolver object with aResolverUid UID.
sl@0: The method leaves resolver onto the cleanup stack.
sl@0: @param aResolverUid Resolver UID.
sl@0: @param			aRegistryResolveTransaction A pointer to Registry resolve transaction object
sl@0: @return A pointer to the created CResolver object.
sl@0: @leave System-wide error codes, including KErrNoMemory.
sl@0: */
sl@0: CResolver* CEComServer::CreateResolverLC(const TUid& aResolverUid,CRegistryResolveTransaction* aRegistryResolveTransaction)
sl@0: 	{
sl@0: 	CResolver* resolver = NULL;
sl@0: 	if(aResolverUid == KDefaultResolverUid)
sl@0: 		{
sl@0: 		// Create default resolver
sl@0: 		resolver = static_cast<CResolver*>(CDefaultResolver::NewL(*aRegistryResolveTransaction));
sl@0: 		CleanupStack::PushL(resolver);
sl@0: 		}
sl@0: 	else if(aResolverUid == KRomOnlyResolverUid)
sl@0: 		{
sl@0: 		// Create Rom Only resolver
sl@0: 		resolver = static_cast<CResolver*>(CRomOnlyResolver::NewL(*aRegistryResolveTransaction));
sl@0: 		CleanupStack::PushL(resolver);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		// Create Custom Resolver
sl@0: 		resolver = CreateCustomResolverLC(aResolverUid, aRegistryResolveTransaction);
sl@0: 		}
sl@0: 	return resolver;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Creates custom resolver object with aResolverUid UID.
sl@0: The method leaves custom resolver onto the cleanup stack.
sl@0: @param aResolverUid Custom resolver UID.
sl@0: @param			aRegistryResolveTransaction A pointer to Registry resolve transaction object
sl@0: @return A pointer to the created CResolver object.
sl@0: @leave System-wide error codes, including KErrNoMemory.
sl@0: */
sl@0: CResolver* CEComServer::CreateCustomResolverLC(TUid aResolverUid,CRegistryResolveTransaction* aRegistryResolveTransaction)
sl@0: 	{
sl@0: 	typedef CResolver* (*TNewL)(MPublicRegistry&);
sl@0: 	TNewL newL = NULL;
sl@0: 	CResolver* resolver=NULL;
sl@0: 
sl@0: 	TProxyNewLPtr tmpPtr;
sl@0: 	if (iResolverCache->CacheLookup(aResolverUid, tmpPtr)) // cache hit
sl@0: 		{
sl@0: 		newL = reinterpret_cast<TNewL>(tmpPtr);
sl@0: 		resolver = newL(*aRegistryResolveTransaction);
sl@0: 		CleanupStack::PushL(resolver);
sl@0: 		return resolver;
sl@0: 		}
sl@0: 
sl@0: 	TEntry resolverDllInfo;
sl@0: 	// We should only load custom resolvers that are in the ROM
sl@0: 	//Initialize the server cap to ProtServ
sl@0: 	TCapabilitySet servercap(ECapabilityProtServ);
sl@0: 	CImplementationInformation* implInfo = NULL;
sl@0: 	TBool onWritableDrv = EFalse;  
sl@0: 	User::LeaveIfError(iRegistryData->GetImplementationDllInfoForServer(
sl@0: 		servercap, aResolverUid, KEComResolverInterfaceUid, resolverDllInfo,
sl@0: 		implInfo, onWritableDrv));
sl@0: 
sl@0: 	// Type of the function pointer which is the proxy into the interface implementation collection
sl@0: 	typedef TImplementationProxy* (*TInstantiationL)(TInt&);
sl@0: 	// Function at ordinal 1 is InstantiationMethodL()
sl@0: 	const TInt KImplementationGroupProxy = 1;
sl@0: 	// So cast to the correct type : This gives an ANSI C++ warning
sl@0: 	// When using a REINTERPRET_CAST so simply cast instead
sl@0: 
sl@0: 	const TDesC& libraryPath = resolverDllInfo.iName;
sl@0: 	// Make sure the non-default resolver library is closed
sl@0: 	iResolverLibrary.Close();
sl@0: 	User::LeaveIfError(iResolverLibrary.Load(libraryPath, resolverDllInfo.iType));
sl@0: 	__ECOM_TRACE2("ECOM: Resolver Loaded UID:0x%X - %S", aResolverUid.iUid, &resolverDllInfo.iName);
sl@0: 	TInstantiationL proxy= REINTERPRET_CAST(TInstantiationL, iResolverLibrary.Lookup(KImplementationGroupProxy));
sl@0: 
sl@0: 	// Scan the returned table for a UID match, and return the associated
sl@0: 	// creation method if found.
sl@0: 	TInt count = 0;
sl@0: 	TImplementationProxy* implementationTable = proxy(count);
sl@0: 	for(TInt i = 0; i < count; ++i)
sl@0: 		{
sl@0: 		if(aResolverUid == implementationTable[i].iImplementationUid)
sl@0: 			{
sl@0: 			newL = (TNewL)(implementationTable[i].iNewLFuncPtr);
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	if(newL)
sl@0: 		{
sl@0: 		if (IsCachable(onWritableDrv))
sl@0: 			{
sl@0: 			TUint32 flags = (onWritableDrv) ? EEntryIsOnReadWriteDrive : EEntryFlagsNone;
sl@0: 			User::LeaveIfError(iResolverCache->CacheResolver(aResolverUid,
sl@0: 				iResolverLibrary, (TProxyNewLPtr)newL, flags));
sl@0: 			// Handle is now owned by iResolverCache.
sl@0: 			iResolverLibrary.SetHandle(KNullHandle);
sl@0: 			}
sl@0: 
sl@0: 		// Create the non-default resolver
sl@0: 		resolver = newL(*aRegistryResolveTransaction);
sl@0: 		CleanupStack::PushL(resolver);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		User::Leave(KEComErrNoResolver);
sl@0: 		}
sl@0: 	return resolver;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TBool CEComServer::RegistryIndexValid() const
sl@0: 	{
sl@0: 	return iRegistryData->IndexValid();
sl@0: 	}
sl@0: 	
sl@0: /** Callback function. CRegistryData uses this to notify of implementation
sl@0: upgrade. CDiscoverer uses this to notify state changes in SWI/BUR.
sl@0: @param aObj Pointer to CEComServer object.
sl@0: @param aEvent Identify the event.
sl@0: @param aData Data associated with the callback.
sl@0: @return none, not-used, ignored.
sl@0: */
sl@0: TInt CEComServer::NotifyEvents(TAny* aObj, TInt aEvent, TAny* aData)
sl@0: 	{
sl@0: 	CEComServer* self = static_cast<CEComServer*>(aObj);
sl@0: 	switch (aEvent)
sl@0: 		{
sl@0: 		case ECallBackId_ImplUpgrade:
sl@0: 			{
sl@0: 			TUid* uid = static_cast<TUid*>(aData);
sl@0: 			self->NotifyUpgrade(*uid);
sl@0: 			}
sl@0: 			break;
sl@0: 		case ECallBackId_SwiEvent:
sl@0: 			self->NotifySWIEvent(aData);
sl@0: 			break;
sl@0: 		case ECallBackId_BurEvent:
sl@0: 			self->NotifyBUREvent(aData);
sl@0: 			break;
sl@0: 		default:
sl@0: 			__ECOM_TRACE1("ECOM: CEComServer::NotifyEvents received unknown event %d", aEvent);
sl@0: 		}
sl@0: 
sl@0: 	return 0;
sl@0: 	}
sl@0: 
sl@0: /** This method is called when an implementation is upgraded.
sl@0: @param aImplementationUid identify the implementation being upgraded.
sl@0: */
sl@0: void CEComServer::NotifyUpgrade(const TUid aImplementationUid)
sl@0: 	{
sl@0: 	// Ignore return code which indicates if the UID is actually in cache.
sl@0: 	(void)iResolverCache->Remove(aImplementationUid);
sl@0: 	}
sl@0: 
sl@0: /** Called when there is SWI status change.
sl@0: @param aData is TCallBackState* indicating start or end of SWI. 
sl@0: */
sl@0: void CEComServer::NotifySWIEvent(TAny* aData)
sl@0: 	{
sl@0: 	TCallBackState* state = static_cast<TCallBackState*>(aData);
sl@0: 	UpdateSpecialEvents(ESWIInProgress, *state);
sl@0: 	}
sl@0: 
sl@0: /** Called when there is BUR status change.
sl@0: @param aData is TCallBackState* indicating start or end of BUR. 
sl@0: */
sl@0: void CEComServer::NotifyBUREvent(TAny* aData)
sl@0: 	{
sl@0: 	TCallBackState* state = static_cast<TCallBackState*>(aData);
sl@0: 	UpdateSpecialEvents(EBURInProgress, *state);
sl@0: 	}
sl@0: 
sl@0: /** Updates the BUR/SWI status.
sl@0: @param aBit Indicate which bit to update.
sl@0: @param aState Indicate start or end of event.
sl@0: */
sl@0: void CEComServer::UpdateSpecialEvents(TUint32 aBit, TCallBackState aState)
sl@0: 	{
sl@0: 	TBitFlags32 oldstate = iSpecialEvents;
sl@0: 
sl@0: 	if (aState == ECallBackState_EventStart)
sl@0: 		{
sl@0: 		iSpecialEvents.Set( aBit );
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		iSpecialEvents.Clear( aBit );
sl@0: 		}
sl@0: 
sl@0: 	if (oldstate.Value() == 0 && iSpecialEvents.Value() != 0)
sl@0: 		{
sl@0: 		// BUR or SWI start. Need to evict cached resolvers on RW drives.
sl@0: 		iResolverCache->RemoveItemsWithFlags(EEntryIsOnReadWriteDrive);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /** Determine if a resolver entry is cachable.
sl@0: @param aResolverEntry the resolver to check.
sl@0: @return ETrue if the resolver should be added to cache. EFalse otherwise.
sl@0: */
sl@0: TBool CEComServer::IsCachable(TBool aEntryIsOnRWDrive)
sl@0: 	{
sl@0: 	// Check the following conditions:
sl@0: 	// 1. DLL is on RW drive with BUR or SWI in progress.
sl@0: 	// 2. Cache size and cache timeout non-zero.
sl@0: 	return	iResolverCache->CachingEnabled() &&
sl@0: 			!(iSpecialEvents.Value() && aEntryIsOnRWDrive);
sl@0: 	}
sl@0: 
sl@0: #ifdef __ECOM_SERVER_TESTABILITY__
sl@0: void CEComServer::ChangeStartupStateL(TInt aState) const
sl@0: 	{
sl@0: 	iServerStartupMgr->ChangeStartupStateL(aState);
sl@0: 	}
sl@0: 
sl@0: void CEComServer::ProcessCurrentStartupStateL() const
sl@0: 	{
sl@0: 	iServerStartupMgr->ResetRequestTransitionNotificationL();
sl@0: 	iServerStartupMgr->ResetLastStateAcknowledgedL();
sl@0: 	iServerStartupMgr->RunL();
sl@0: 	}
sl@0: 	
sl@0: TInt CEComServer::GetCurrentStartupState() const
sl@0: 	{
sl@0: 	return iServerStartupMgr->CurrentStartupState();
sl@0: 	}
sl@0: #endif //__ECOM_SERVER_TESTABILITY__
sl@0: 
sl@0: #ifdef __ECOM_SERVER_PERFORMANCE__
sl@0: void CEComServer::GetRegistryCountsL(TInt aType, RegistryCounts::TRegistryCounts& aCounts) const
sl@0: 	{
sl@0: 	iRegistryData->GetRegistryCountsL(aType, aCounts);
sl@0: 	}	
sl@0: #endif //__ECOM_SERVER_PERFORMANCE__