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: // Server session object implementation.
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include "EComServerStart.h"
sl@0: #include "EComMessageIds.h"
sl@0: #include <ecom/ecomerrorcodes.h>
sl@0: #include <ecom/implementationinformation.h>
sl@0: #include "EComServerSession.h"
sl@0: #include "EComSessionAux.h"
sl@0: #include "EComServer.h"
sl@0: #include "TestUtilities.h"	// For __FILE__LINE__
sl@0: #include "EComPerformance.h"
sl@0: #include "EComDebug.h"
sl@0: 
sl@0: //
sl@0: // RMessage::Panic() completes the message. This is:
sl@0: // (a) important for efficient cleanup within the kernel.
sl@0: // (b) a problem if the message is completed a second time.
sl@0: //
sl@0: void PanicClient(const TClientRequest& aMessage, TInt aPanicCode)
sl@0: 	{
sl@0: 	aMessage.Panic(KEComServerPanicCategory, aPanicCode);
sl@0: 	}
sl@0: 
sl@0: //
sl@0: //	class CEComServerSession
sl@0: //
sl@0: CEComServerSession::CEComServerSession()
sl@0: 	: CSession2()
sl@0: 	{
sl@0: 	// Do nothing
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // 2nd phase construct for sessions - called by the CServer framework
sl@0: //
sl@0: void CEComServerSession::CreateL()
sl@0: 	{
sl@0: 	Server().AddSession();
sl@0: 	}
sl@0: 
sl@0: CEComServerSession::~CEComServerSession()
sl@0: 	{
sl@0: 	CleanupInternalList();
sl@0: 	CompleteNotifications(KErrCancel);
sl@0: 	delete iMemoryStore;
sl@0: 	Server().DropSession();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Deliver the notification message to the client
sl@0: //
sl@0: void CEComServerSession::CompleteNotifications(TInt aCompletionCode)
sl@0: 	{
sl@0: 	const TInt count = iNotificationRequests.Count();
sl@0: 	for(TInt i = 0; i < count; ++i)
sl@0: 		{
sl@0: 		  iNotificationRequests[i].iMessage.Complete(aCompletionCode);
sl@0: 
sl@0: 		}
sl@0: 	iNotificationRequests.Reset();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Handle a client request.
sl@0: // Leaving is handled by CEComServer::RunError() which reports the error code
sl@0: // to the client.
sl@0: //
sl@0: void CEComServerSession::ServiceL(const RMessage2& aMessage)
sl@0: {
sl@0: 	const TClientRequest msg(aMessage);
sl@0: 	ServiceL(msg);
sl@0: }
sl@0: 
sl@0: void CEComServerSession::ServiceL(const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	TInt completionCode = KErrNone;
sl@0: 	TBool asyncRequest = EFalse;
sl@0: 
sl@0: 	switch (aMessage.Function())
sl@0: 		{
sl@0: 	case ENotifyOnChange:
sl@0: 		{
sl@0: RECORD_CLIENT_REQUEST_START_TIMER_RESULT(EEComNotifyOnChangeRequestType, Server().GetCurrentStartupState());
sl@0: 		SEComNotification notif;
sl@0: 		notif.iMessage=aMessage;
sl@0: 		// the TRequestStatus as a TInt is stored for later comparisons
sl@0: 		notif.iRequestStatusHandle=aMessage.Int0();
sl@0: 		//Check that this TRequestStatus is not already being used.
sl@0: 		const TInt count = iNotificationRequests.Count();
sl@0: 		for(TInt i = 0; i < count; ++i)
sl@0: 		{
sl@0: 			if(iNotificationRequests[i].iRequestStatusHandle == notif.iRequestStatusHandle)
sl@0: 				User::Leave(KErrArgument);
sl@0: 
sl@0: 		}
sl@0: 		User::LeaveIfError(iNotificationRequests.Append(notif));
sl@0: 		asyncRequest = ETrue;
sl@0: RECORD_CLIENT_REQUEST_END_TIMER_RESULT;
sl@0: 		break;
sl@0: 		}
sl@0: 
sl@0: 	case ECancelNotifyOnChange:
sl@0: 			{
sl@0: RECORD_CLIENT_REQUEST_START_TIMER_RESULT(EEComCancelNotifyOnChangeRequestType, Server().GetCurrentStartupState());
sl@0: 			TInt statusHandle = aMessage.Int0();
sl@0: 
sl@0: 			const TInt count = iNotificationRequests.Count();
sl@0: 			for(TInt i = 0; i < count; ++i)
sl@0: 				{
sl@0: 				if(iNotificationRequests[i].iRequestStatusHandle == statusHandle)
sl@0: 					{
sl@0: 						iNotificationRequests[i].iMessage.Complete(KErrCancel);
sl@0: 						iNotificationRequests.Remove(i);
sl@0: 						break;  // Terminate the loop
sl@0: 					}
sl@0: 				}
sl@0: 			}
sl@0: RECORD_CLIENT_REQUEST_END_TIMER_RESULT;
sl@0: 		break;
sl@0: 
sl@0: 	case EListImplementations:
sl@0: 	case EListResolvedImplementations:
sl@0: 	case EListCustomResolvedImplementations:
sl@0: 		if(Server().RegistryIndexValid())
sl@0: 			{
sl@0: RECORD_CLIENT_REQUEST_START_TIMER_RESULT(EEComListRequestType, Server().GetCurrentStartupState());
sl@0: 			DoListImplementationsL(aMessage);
sl@0: RECORD_CLIENT_REQUEST_END_TIMER_RESULT;
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			if(ReceivePending())
sl@0: 				User::Leave(KEComErrListInvalidAwaitNotification);
sl@0: 			else
sl@0: 				User::Leave(KEComErrListCurrentlyUnavailable);
sl@0: 			}
sl@0: 		break;
sl@0: 
sl@0: 	case ECollectImplementationsList:
sl@0: RECORD_CLIENT_REQUEST_START_TIMER_RESULT(EEComCollectImplementationsRequestType, Server().GetCurrentStartupState());
sl@0: 		if(!DoCollectListL(aMessage))
sl@0: 			completionCode = KErrNotReady;
sl@0: RECORD_CLIENT_REQUEST_END_TIMER_RESULT;
sl@0: 		break;
sl@0: 
sl@0: 	case EGetImplementationCreationMethod:
sl@0: 	case EGetResolvedCreationMethod:
sl@0: 	case EGetCustomResolvedCreationMethod:
sl@0: RECORD_CLIENT_REQUEST_START_TIMER_RESULT(EEComCreateRequestType, Server().GetCurrentStartupState());
sl@0: 		DoGetResolvedImplementationL(aMessage);
sl@0: RECORD_CLIENT_REQUEST_END_TIMER_RESULT;
sl@0: 		break;
sl@0: 
sl@0: 	case EListExtendedInterfaces:
sl@0: RECORD_CLIENT_REQUEST_START_TIMER_RESULT(EEComListExtendedInterfacesRequestType, Server().GetCurrentStartupState());
sl@0: 		DoListExtendedInterfacesL(aMessage);
sl@0: RECORD_CLIENT_REQUEST_END_TIMER_RESULT;
sl@0: 		break;
sl@0: 
sl@0: 	case EEnableImplementation:
sl@0: 	case EDisableImplementation:
sl@0: 		// Ommissions for 6.2
sl@0: 		completionCode = KErrNotSupported;
sl@0: 		break;
sl@0: #if defined(__ECOM_SERVER_TESTABILITY__) || defined(__ECOM_SERVER_PERFORMANCE__)
sl@0: 	case ESetGetParameters:
sl@0: 		DoSetGetParametersL(aMessage);
sl@0: 		break;
sl@0: #endif
sl@0: 	//EDestroyedImplementation obsolete due to implementation creation
sl@0: 	//relocation to client side from server
sl@0: 	case EDestroyedImplementation:
sl@0: 	default:
sl@0: 		// Something badly wrong if we get here.
sl@0: 		PanicClient(aMessage,KEComErrUnknownService);
sl@0: 		// RMessage::Panic() has completed the message
sl@0: 		// so treat this as an asynch request.
sl@0: 		asyncRequest = ETrue;
sl@0: 		}
sl@0: 	if (!asyncRequest)
sl@0: 		aMessage.Complete(completionCode);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: 
sl@0: 	
sl@0: TInt const KDefaultStoreSize = 256;	// Enough space for approx 1 implementation : will grow to fit if required
sl@0: 
sl@0: /**
sl@0: UnPack the match string and extended interface from the client supplied parameters.
sl@0: @param			aMessage 
sl@0: @param			aExtendedInterfaces Return value consisting of an array containing the extended interfaces.
sl@0: @param			aMatchStr Return value consisting of the matching string.
sl@0: */
sl@0: void CEComServerSession::UnpackMatchStrAndExtendedInterfacesFromClientL(const TClientRequest& aMessage,
sl@0: 													RExtendedInterfacesArray& aExtendedInterfaces,
sl@0: 													RBuf8& aMatchStr)
sl@0: 	{
sl@0: 	
sl@0: 	//now get the matchString and extendedInterfaces
sl@0: 	TInt sizeOfMatchStrExtInfBuf = aMessage.GetDesLength(KIPCParameterMatchStrExtInf);
sl@0: 	User::LeaveIfError(sizeOfMatchStrExtInfBuf);
sl@0: 	RBuf8 matchStrExtInfBuf;
sl@0: 	matchStrExtInfBuf.CreateMaxL(sizeOfMatchStrExtInfBuf);
sl@0: 	matchStrExtInfBuf.CleanupClosePushL();
sl@0: 	
sl@0: 	aMessage.ReadL(KIPCParameterMatchStrExtInf,matchStrExtInfBuf);
sl@0: 	RDesReadStream readStream;
sl@0: 	CleanupClosePushL(readStream);
sl@0: 	readStream.Open(matchStrExtInfBuf);
sl@0: 	TInt lenOfMatchStr = readStream.ReadInt32L();
sl@0: 	aMatchStr.CreateMaxL(lenOfMatchStr);
sl@0: 	aMatchStr.CleanupClosePushL();
sl@0: 	if (lenOfMatchStr>0)
sl@0: 		{
sl@0: 		readStream.ReadL(aMatchStr,lenOfMatchStr);		
sl@0: 		}
sl@0: 	TInt numOfExtendedInterfaces = readStream.ReadInt32L();
sl@0: 	CleanupClosePushL(aExtendedInterfaces);
sl@0: 	for(TInt i = 0; i < numOfExtendedInterfaces; i++)
sl@0: 		{
sl@0: 		aExtendedInterfaces.AppendL(TUid::Uid(readStream.ReadInt32L()));
sl@0: 		}
sl@0: 	
sl@0: 	CleanupStack::Pop(&aExtendedInterfaces);
sl@0: 	CleanupStack::Pop(&aMatchStr);
sl@0: 	CleanupStack::PopAndDestroy(&readStream);
sl@0: 	CleanupStack::PopAndDestroy(&matchStrExtInfBuf); 
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // Note that this method for returning the arbitrary sized data set 
sl@0: // will not work IF the session is shared so...
sl@0: // DO NOT SHARE SERVER SIDE SESSIONS BETWEEN CLIENTS
sl@0: void CEComServerSession::DoListImplementationsL(const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	// Unpack the client supplied parameters
sl@0: 	// Firstly get the uids
sl@0: 	TUidType uids;
sl@0: 	TPckg<TUidType> uidsPkg(uids);	
sl@0: 	aMessage.ReadL(KIPCParameterUids, uidsPkg);
sl@0: 	
sl@0: 	if(uids[KInterfaceUidIndex] == KNullUid)
sl@0: 		{
sl@0: 		User::Leave(KEComErrMissingParameter);
sl@0: 		}
sl@0: 
sl@0: 	//now get the TListImplParam parameters
sl@0:   	TListImplParam listParam;
sl@0:   	TPckg<TListImplParam> listParamPkg(listParam);
sl@0:   	aMessage.ReadL(2,listParamPkg);
sl@0: 	
sl@0: 	// Now rebuild the TEComResolverParams
sl@0: 	TEComResolverParams resolverParameters;
sl@0: 	resolverParameters.SetGenericMatch(listParam.iMatchType);
sl@0: 	
sl@0: 	//now get the matchString and extendedInterfaces
sl@0: 	RBuf8 matchStr;
sl@0: 	RExtendedInterfacesArray extendedInterfaces;
sl@0: 	UnpackMatchStrAndExtendedInterfacesFromClientL(aMessage,extendedInterfaces,matchStr);
sl@0: 	matchStr.CleanupClosePushL();
sl@0: 	CleanupClosePushL(extendedInterfaces);
sl@0: 	
sl@0: 	if(matchStr.Length()>0)
sl@0: 		{	
sl@0: 		resolverParameters.SetDataType(matchStr);
sl@0: 		}
sl@0: 	// Else the client's resolver params are default constructed i.e. invalid
sl@0: 	// data type descriptor or its length is zero, so use empty RBuf8 above.
sl@0: 	
sl@0: 		
sl@0: 	// Pass to the server
sl@0: 	iListContext = aMessage.Function();
sl@0: 	switch(iListContext)
sl@0: 		{
sl@0: 		case EListImplementations:
sl@0: 			iList = Server().ListImplementationsL( uids[KInterfaceUidIndex], extendedInterfaces, aMessage );
sl@0: 			break;
sl@0: 		case EListResolvedImplementations:
sl@0: 			if(matchStr.Length() == 0)
sl@0: 				{
sl@0: 				User::Leave(KEComErrMissingParameter);
sl@0: 				}
sl@0: 			iList = Server().ListImplementationsL( uids[KInterfaceUidIndex], resolverParameters, extendedInterfaces, aMessage);
sl@0: 			break;
sl@0: 		case EListCustomResolvedImplementations:
sl@0: 			if(uids[KResolverUidIndex] == KNullUid)
sl@0: 				{
sl@0: 				User::Leave(KEComErrMissingParameter);
sl@0: 				}
sl@0: 			iList = Server().ListImplementationsL( uids[KInterfaceUidIndex], resolverParameters, uids[KResolverUidIndex], extendedInterfaces, aMessage);
sl@0: 			break;
sl@0: 		default:
sl@0: 			break;
sl@0: 		}
sl@0: 	//Now cleanup the extended interface
sl@0: 	CleanupStack::PopAndDestroy(&extendedInterfaces);
sl@0: 	CleanupStack::PopAndDestroy(&matchStr);
sl@0: 
sl@0: 	TInt bufferSizeRequired=0;
sl@0: 	// Package the array for return
sl@0: 	if(iList)
sl@0: 		{
sl@0: 		if(iList->Count()>0)
sl@0: 			{
sl@0: 			// Allocate a new store and replace the old one first
sl@0: 			CBufFlat* memoryStore = CBufFlat::NewL(KDefaultStoreSize);
sl@0: 			delete iMemoryStore;
sl@0: 			iMemoryStore = memoryStore;
sl@0: 
sl@0: 			// Note : There is no need to push
sl@0: 			// the write stream onto the cleanup stack
sl@0: 			// because it has no internal resources.
sl@0: 			RBufWriteStream writeStream;
sl@0: 			writeStream.Open(*iMemoryStore);
sl@0: 
sl@0: 			// Build the store data then calculate the end size;
sl@0: 			const TInt entryCount = iList->Count();		
sl@0: 			writeStream.WriteInt32L(entryCount);
sl@0: 			
sl@0: 			for(TInt i = 0; i < entryCount; ++i)
sl@0: 				(*iList)[i]->ExternalizeL(ETrue,writeStream);
sl@0: 	
sl@0: 			writeStream.CommitL();
sl@0: 
sl@0: 			// Set to actual size
sl@0: 			bufferSizeRequired=iMemoryStore->Size();
sl@0: 			__ECOM_TRACE1("ECOM ListImplementations request buffer size required=%d",bufferSizeRequired);
sl@0: 			}
sl@0: 			CleanupInternalList();	
sl@0: 		}
sl@0: 	
sl@0: 	//if nothing is returned we should still indicate this to the client side
sl@0: 	if (bufferSizeRequired==0)
sl@0: 		{
sl@0: 		//write back the bufferSize
sl@0: 		listParam.iBufferSize=0;
sl@0:   		aMessage.WriteL(2,listParamPkg);
sl@0: 		return;
sl@0: 		}
sl@0: 		
sl@0: 	//if the preallocated size is big enough to hold our entry
sl@0: 	//copy it to the client
sl@0: 	if (listParam.iBufferSize >= bufferSizeRequired)
sl@0: 		{
sl@0: 		if (iMemoryStore)
sl@0: 			{
sl@0: 			//write back the bufferSize
sl@0: 			listParam.iBufferSize=bufferSizeRequired;
sl@0:   			aMessage.WriteL(2,listParamPkg);
sl@0: 			TPtr8 data=iMemoryStore->Ptr(0);
sl@0: 			aMessage.WriteL(3,data);
sl@0: 			delete iMemoryStore;
sl@0: 			iMemoryStore=NULL;
sl@0: 			}
sl@0: 		}
sl@0: 	//if not rewrite back to the client the size that is required
sl@0: 	//and signal with KErrOverFlow to the client
sl@0: 	else
sl@0: 		{
sl@0: 		//write back the bufferSize
sl@0: 		listParam.iBufferSize=bufferSizeRequired;
sl@0:   		aMessage.WriteL(2,listParamPkg);
sl@0: 		User::Leave(KErrOverflow);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: TBool CEComServerSession::DoCollectListL(const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	TBool success = EFalse;
sl@0: 	if(iMemoryStore)
sl@0: 		{
sl@0: 		TPtr8 data=iMemoryStore->Ptr(0);
sl@0: 		aMessage.WriteL(0, data);
sl@0: 		delete iMemoryStore;
sl@0: 		iMemoryStore = NULL;
sl@0: 		success = ETrue;
sl@0: 		}
sl@0: 	return success;
sl@0: 	}
sl@0: 
sl@0: void CEComServerSession::DoGetResolvedImplementationL(const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	// Unpack the client supplied parameters
sl@0: 	// Firstly get the uids
sl@0: 	TUidType uids;
sl@0: 	TPckg<TUidType> uidsPkg(uids);
sl@0: 	aMessage.ReadL(KIPCParameterUids, uidsPkg);
sl@0: 
sl@0: 	// Now rebuild the TEComResolverParams
sl@0: 	TEComResolverParams resolverParameters;
sl@0: 	resolverParameters.SetGenericMatch(KIPCParameterResolverParamsTypePtr);	
sl@0: 	
sl@0: 	//now get the matchString and extendedInterfaces
sl@0: 	RBuf8 matchStr;
sl@0: 	matchStr.CleanupClosePushL();
sl@0: 	RExtendedInterfacesArray extendedInterfaces;
sl@0: 	CleanupClosePushL(extendedInterfaces);
sl@0: 	UnpackMatchStrAndExtendedInterfacesFromClientL(aMessage,extendedInterfaces,matchStr);
sl@0:     if(matchStr.Length()>0)
sl@0: 		{	
sl@0: 		resolverParameters.SetDataType(matchStr);
sl@0: 		}
sl@0: 	// Else the client's resolver params are default constructed i.e. invalid
sl@0: 	// data type descriptor or its length is zero, so use empty HBufC8 above.
sl@0: 	// Set up for the return value
sl@0: 	TUid dtorIdKey(KNullUid);
sl@0: 	TEntry loadInfo;
sl@0: 	
sl@0: 	switch(aMessage.Function())
sl@0: 		{
sl@0: 		case EGetImplementationCreationMethod:
sl@0: 			Server().GetResolvedDllInfoL(uids[KInterfaceUidIndex], 
sl@0: 										 loadInfo, 
sl@0: 										 dtorIdKey,
sl@0: 										 aMessage);
sl@0: 			break;
sl@0: 		case EGetResolvedCreationMethod:
sl@0: 			Server().GetResolvedDllInfoL(uids[KInterfaceUidIndex], 
sl@0: 										 resolverParameters, 
sl@0: 										 extendedInterfaces,
sl@0: 										 loadInfo, 
sl@0: 										 dtorIdKey,
sl@0: 										 aMessage);
sl@0: 			break;
sl@0: 		case EGetCustomResolvedCreationMethod:
sl@0: 			Server().GetResolvedDllInfoL(uids[KInterfaceUidIndex], 
sl@0: 										 resolverParameters, 
sl@0: 										 uids[KResolverUidIndex], 
sl@0: 										 extendedInterfaces,
sl@0: 										 loadInfo, 
sl@0: 										 dtorIdKey,
sl@0: 										 aMessage);
sl@0: 			break;
sl@0: 		default:
sl@0: 			break;
sl@0: 		}
sl@0: 	CleanupStack::PopAndDestroy(&extendedInterfaces);
sl@0: 	CleanupStack::PopAndDestroy(&matchStr);
sl@0: 	
sl@0: // ??? Compile time assert that sizeof(TProxyNewLPtr) == sizeof(TAny*)?
sl@0: // Currently I'm not arranging for the client-side of the session to
sl@0: // convert from TAny* to TProxyNewLPtr, and using this to avoid the
sl@0: // full agony of following through with conversion...
sl@0: 
sl@0: 	// Then re-package the results for return
sl@0: 	// Firstly the Interface Implementation creation method pointer
sl@0: 	TPckg<TEntry> result(loadInfo);
sl@0: 	
sl@0: 	aMessage.WriteL(KIPCReturnParameterCreationMethodPtr, result);
sl@0: 	// Next the destruction identification uid
sl@0: 	TUidType type(KNullUid,dtorIdKey,KNullUid);
sl@0: 	TPckg<TUidType> dtorIdKeyPkg(type);
sl@0: 	
sl@0: 	aMessage.WriteL(KIPCReturnParameterUidsPtr, dtorIdKeyPkg);
sl@0: 	}
sl@0: 
sl@0: // Return the list of interfaces to the client. If not enough space
sl@0: // has been allocated by the client, KErrOverflow will be returned.
sl@0: //
sl@0: void CEComServerSession::DoListExtendedInterfacesL(const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	// Unpack the client supplied parameters
sl@0: 	TInt bufferSize = 0;
sl@0: 	TUid implementationUid(KNullUid);
sl@0: 	TPckg<TUid> implementationUidDes(implementationUid);
sl@0: 	TPckg<TInt> bufferSizeDes(bufferSize);
sl@0: 	aMessage.ReadL(KIPCParameterImplementationUid,implementationUidDes);
sl@0: 	aMessage.ReadL(KIPCParameterBufferSize,bufferSizeDes);
sl@0: 		
sl@0: 	// Get the implementation information for this implementation UID.
sl@0: 	CImplementationInformation* implInfo = NULL;
sl@0: 	Server().GetImplementationInformationL(implementationUid,implInfo,aMessage);
sl@0: 	
sl@0: 	TInt numExtendedInterfaces = 0; // Number of extended interfaces to return to client.
sl@0: 
sl@0: 	if(implInfo)
sl@0: 		{
sl@0: 		TInt bufferSizeRequired = 0; // Buffer required to send extended interface data back to client
sl@0: 		
sl@0: 		// Fetch the list of extended interfaces
sl@0: 		RExtendedInterfacesArray* extendedInterfaceList = implInfo->GetExtendedInterfaceList();
sl@0: 		if (extendedInterfaceList != NULL)
sl@0: 			{
sl@0: 			numExtendedInterfaces = extendedInterfaceList->Count();
sl@0: 			}
sl@0: 		if (numExtendedInterfaces > 0)
sl@0: 			{
sl@0: 			bufferSizeRequired = numExtendedInterfaces * sizeof(TUid);
sl@0: 			__ECOM_TRACE1("ECOM ListInterfaces request buffer size required=%d",bufferSizeRequired);
sl@0: 			
sl@0: 			//if the preallocated size is big enough to hold our entry
sl@0: 			//copy it to the client
sl@0: 			if (bufferSize >= bufferSizeRequired)
sl@0: 				{
sl@0: 				RBuf8 buf;
sl@0: 				CleanupClosePushL(buf);
sl@0: 				buf.CreateL(bufferSizeRequired);   // Create the RBuf.
sl@0: 				
sl@0: 				// Note : There is no need to push the write stream onto the cleanup stack
sl@0: 				// because it has no internal resources.
sl@0: 				RDesWriteStream writeStream;
sl@0: 				writeStream.Open(buf);
sl@0: 
sl@0: 				// Build the data of extendedInterfaces;
sl@0: 				for(TInt i = 0; i < numExtendedInterfaces; ++i)
sl@0: 					{
sl@0: 					writeStream.WriteInt32L((*extendedInterfaceList)[i].iUid);
sl@0: 					}
sl@0: 
sl@0: 				writeStream.CommitL();
sl@0: 				
sl@0: 				// Copy the data to the client.
sl@0: 				bufferSize=bufferSizeRequired;
sl@0: 				aMessage.WriteL(KIPCParameterBufferSize,bufferSizeDes);
sl@0: 				aMessage.WriteL(KIPCParameterInterfaceData,buf);
sl@0: 				
sl@0: 				CleanupStack::PopAndDestroy(&buf);
sl@0: 				}
sl@0: 			//if not rewrite back to the client the size that is required
sl@0: 			//and signal with KErrOverFlow to the client
sl@0: 			else
sl@0: 				{
sl@0: 				bufferSize=bufferSizeRequired;
sl@0: 				aMessage.WriteL(KIPCParameterBufferSize,bufferSizeDes);
sl@0: 				User::Leave(KErrOverflow);
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 		
sl@0: 	//if nothing is returned we should still indicate this to the client side
sl@0: 	if (numExtendedInterfaces == 0)
sl@0: 		{
sl@0: 		bufferSize=0;
sl@0: 		aMessage.WriteL(KIPCParameterBufferSize,bufferSizeDes);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: #if defined(__ECOM_SERVER_TESTABILITY__) || defined(__ECOM_SERVER_PERFORMANCE__)
sl@0: /**
sl@0: This method is provided for testability. It allows the user to 
sl@0: send and receive any parameters. 
sl@0: @param aMessage IPC message between server and client
sl@0: */
sl@0: void CEComServerSession::DoSetGetParametersL(const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	TInt parameterType = aMessage.Int0();
sl@0: 	
sl@0: 	switch(parameterType)
sl@0: 		{
sl@0: #ifdef __ECOM_SERVER_TESTABILITY__
sl@0: 		case EChangeStartupState:
sl@0: 			Server().ChangeStartupStateL(aMessage.Int1());
sl@0: 			break;
sl@0: 		case EProcessStartupState:
sl@0: 			Server().ProcessCurrentStartupStateL();
sl@0: 			break;
sl@0: 		case EGetStartupState:
sl@0: 			{
sl@0: 			TInt state = Server().GetCurrentStartupState();
sl@0: 			TPckg<TInt> pckgState(state);
sl@0: 		    aMessage.Write(1, pckgState);
sl@0: 			break;
sl@0: 			}
sl@0: #endif
sl@0: #ifdef __ECOM_SERVER_PERFORMANCE__
sl@0: 		case EGetStartupStateTimerResult:
sl@0: 			{
sl@0: 			TStartupStateTimerEntry timerEntry;
sl@0: 			
sl@0: 			TInt ret = EComPerformance::GetStartupStateTimerResult(aMessage.Int1(), timerEntry.iTimerResult, timerEntry.iState);
sl@0: 			
sl@0: 			TPckg<TInt> pckgRetValue(ret);
sl@0: 			aMessage.Write(2, pckgRetValue);
sl@0: 			TPckg<TStartupStateTimerEntry> pckgTimerEntry(timerEntry);
sl@0: 			aMessage.Write(3, pckgTimerEntry);
sl@0: 			break;
sl@0: 			}
sl@0: 
sl@0: 		case EGetAccumulatedClientRequestsTimerResult:
sl@0: 			{
sl@0: 			TClientRequestTimerEntry timerEntry;
sl@0: 			TInt ret = EComPerformance::GetAccumulatedClientRequestTimerResult(aMessage.Int1(), timerEntry);
sl@0: 			TPckg<TInt> pckgRetValue(ret);
sl@0: 			aMessage.Write(2, pckgRetValue);
sl@0: 			TPckg<TClientRequestTimerEntry> pckgTimerEntry(timerEntry);
sl@0: 			aMessage.Write(3, pckgTimerEntry);
sl@0: 			break;
sl@0: 			}
sl@0: 		case EGetRegistryCounts:
sl@0: 			{
sl@0: 			RegistryCounts::TRegistryCounts counts;
sl@0: 			Server().GetRegistryCountsL(aMessage.Int1(), counts);
sl@0: 			TPckg<RegistryCounts::TRegistryCounts> pckgRegistryCounts(counts);
sl@0: 			aMessage.Write(2, pckgRegistryCounts);
sl@0: 			break;
sl@0: 			}
sl@0: 		case EResetStartupStateTimerCounts:
sl@0: 			{
sl@0: 			EComPerformance::ResetStartupStateTimerResult();
sl@0: 			break;
sl@0: 			}
sl@0: 		case EGetEComPerfTimeRecord:
sl@0: 			{
sl@0: 			TEComPerfTimeRecordEntry timerEntry;
sl@0: 			TInt ret = EComPerformance::GetEComPerfTimeRecord(aMessage.Int1(), timerEntry);
sl@0: 			TPckg<TInt> pckgRetValue(ret);
sl@0: 			aMessage.Write(2, pckgRetValue);
sl@0: 			TPckg<TEComPerfTimeRecordEntry> pckgTimerEntry(timerEntry);
sl@0: 			aMessage.Write(3, pckgTimerEntry);
sl@0: 			break;
sl@0: 			}
sl@0: 		case EResetEComPerfTimeRecords:
sl@0: 			{
sl@0: 			EComPerformance::ResetEComPerfTimeRecords();
sl@0: 			}
sl@0: 		case EGetEComServerHeapResult:
sl@0: 			{
sl@0: 			TEComPerfHeapUsage heapEntry;
sl@0: 			TInt ret= EComPerformance::GetEComHeapSize(aMessage.Int1(),heapEntry);
sl@0: 			TPckg<TInt> pckgRetValue(ret);
sl@0: 			aMessage.Write(2, pckgRetValue);
sl@0: 			TPckg<TEComPerfHeapUsage> pckgHeapEntry(heapEntry);
sl@0: 			aMessage.Write(3, pckgHeapEntry);
sl@0: 			break;			
sl@0: 			}
sl@0: #endif
sl@0: 		default:
sl@0: 			break;
sl@0: 		}
sl@0: 	}
sl@0: #endif
sl@0: 
sl@0: void CEComServerSession::CleanupInternalList()
sl@0: 	{
sl@0: 	if (iList != NULL)
sl@0: 		{
sl@0: 		iList->Reset();
sl@0: 		delete iList;
sl@0: 		iList = NULL;
sl@0: 		}
sl@0: 	}
sl@0: