sl@0: // Copyright (c) 2004-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: //
sl@0: 
sl@0: #include "panic.h"
sl@0: #include "srvreqs.h"
sl@0: #include "sessmgr.h"
sl@0: #include "cachemgr.h"
sl@0: #include "srvsubsess.h"
sl@0: #include "srvsess.h"
sl@0: 
sl@0: CServerSession::~CServerSession()
sl@0: 	{
sl@0: 	// Delete the subsession index.
sl@0: 	delete iSubSessionIx;
sl@0: 	
sl@0: 	//Delete the subsession container via the CObjectConIx's remove function  
sl@0: 	((CSessionManager*)Server())->RemoveContainer(iContainer);
sl@0: 	}
sl@0: 
sl@0: //Called by client/server framework after session has been successfully created.
sl@0: //In effect, a second-phase constructor.
sl@0: //Creates the object index and the object container for this session.
sl@0: void CServerSession::CreateL()
sl@0: 	{
sl@0: 	// Create new object index
sl@0: 	iSubSessionIx = CObjectIx::NewL();
sl@0: 	
sl@0: 	// Initialize the object container
sl@0: 	// using the object container index in the server.
sl@0: 	iContainer = ((CSessionManager*)Server())->NewContainerL();
sl@0: 	}
sl@0: 
sl@0: //helper method to resolve and verify subsession using RMessage and subsession handle
sl@0: CServerSubSession* CServerSession::SubSessionFromHandle(const RMessage2& aMessage, TInt aHandle)
sl@0: 	{
sl@0: 	CServerSubSession* subSession = (CServerSubSession*)iSubSessionIx->At(aHandle);
sl@0: 	if (subSession == NULL)
sl@0: 	    {
sl@0: 		PanicClient(EBadSubsessionHandle, aMessage);	    
sl@0: 	    }
sl@0: 	    
sl@0: 	return subSession;
sl@0: 	}
sl@0: 
sl@0: // if ServiceL Leaves, execution resumes in this method.
sl@0: // this allows us to panic clients using bad descriptors, to deal with OOM conditions
sl@0: // and to fail transactions with the correct reason: OOM etc.
sl@0: void CServerSession::ServiceError(const RMessage2 &aMessage, TInt aError)
sl@0: 	{
sl@0: 	TServerRequest fn = static_cast<TServerRequest>(aMessage.Function());
sl@0: 
sl@0: 	// If we have failed during initialisation the subsession is no longer available.
sl@0: 	// Perform additional cleanup by removing the subsession's handle from the server's 
sl@0: 	// subsession index. 
sl@0: 	if (fn == EInitialise)
sl@0: 		{
sl@0: 		// Retrieve handle
sl@0: 		TPckgBuf<TInt> handlePckg;
sl@0: 		TRAPD(res,aMessage.ReadL(3,handlePckg));
sl@0: 		 
sl@0: 		if (res == KErrNone)
sl@0: 		 	{
sl@0: 		 	TInt subSessionHandle = handlePckg();
sl@0: 			iSubSessionIx->Remove(subSessionHandle);
sl@0: 		 	}
sl@0: 		#ifdef _DEBUG
sl@0: 			else
sl@0: 				{
sl@0: 				RDebug::Print(_L("CServerSession::ServiceError - Can't remove subsession handle; aError = %d; res = %d"), aError, res); 
sl@0: 				}   	
sl@0: 		#endif 	 
sl@0: 		}
sl@0: 	
sl@0: 	//under following conditions the subsession handles the error
sl@0: 	if(fn > EInitialise && fn < ELastInTable)
sl@0: 		{
sl@0: 		CServerSubSession* subSession = SubSessionFromHandle(aMessage, aMessage.Int3());
sl@0: 		if(subSession)
sl@0: 			{
sl@0: 			subSession->ServiceError(aError);   
sl@0: 			}
sl@0: 		#ifdef _DEBUG
sl@0: 			else
sl@0: 				{
sl@0: 				RDebug::Print(_L("CServerSession::ServiceError - bad subsession handle. aError = %d"), aError); 
sl@0: 				}   	
sl@0: 		#endif  
sl@0: 		}
sl@0: #ifdef SYMBIAN_CENTREP_SUPPORT_MULTIROFS		
sl@0: 	//for multi ROFS instead of leaving we panic the client instead
sl@0: 	switch (aError)
sl@0: 		{
sl@0: 		case KErrMultiRofsOldCreUsed:
sl@0: 			PanicClient(EMultiRofsPanicOldCre,aMessage);
sl@0: 			return;
sl@0: 		case KErrMultiRofsGlobalOverride:
sl@0: 			PanicClient(EMultiRofsPanicGlobalOverride,aMessage);
sl@0: 			return;
sl@0: 		case KErrMultiRofsTypeOverride:
sl@0: 			PanicClient(EMultiRofsPanicTypeOveride,aMessage);
sl@0: 			return;
sl@0: 		case KErrMultiRofsIllegalRofs:
sl@0: 			PanicClient(EMultiRofsPanicIllegalRofs,aMessage);
sl@0: 			return;				
sl@0: 		}
sl@0: #endif				
sl@0: 		
sl@0: 	CSession2::ServiceError(aMessage, aError);
sl@0: 	}
sl@0: 
sl@0: void CServerSession::ServiceL(const RMessage2& aMessage)
sl@0: 	{
sl@0: 	TServerRequest fn = static_cast<TServerRequest>(aMessage.Function());
sl@0: 	
sl@0: #if defined(__CENTREP_SERVER_PERFTEST__) || defined(__CENTREP_SERVER_MEMTEST__) || defined(__CENTREP_SERVER_CACHETEST__)
sl@0: 	if (fn == EGetSetParameters)
sl@0: 		{
sl@0: 		TInt r = GetSetParameters(aMessage);
sl@0: 		aMessage.Complete(r);
sl@0: 		return;
sl@0: 		}
sl@0: #endif
sl@0: 
sl@0: 	if(fn > ELastInTable)
sl@0: 		{
sl@0: 		PanicClient(EBadMessageNumber, aMessage);
sl@0: 		}
sl@0: 	
sl@0: 	CServerSubSession* subSession = NULL;
sl@0: 
sl@0: #if defined (SYMBIAN_CENTREP_SUPPORT_MULTIROFS) && defined(CENTREP_TRACE)
sl@0: 	TUint32 startTick=0;
sl@0: 	TUid repUid;
sl@0: 	startTick=User::FastCounter();
sl@0: #endif
sl@0: 	PERF_TEST_EVENT_START(subSession, aMessage);
sl@0: 
sl@0: 	if(fn == EInitialise)
sl@0: 		{
sl@0: 		//create subsession
sl@0: 		subSession = NewSubSessionL(aMessage);
sl@0: #if defined (SYMBIAN_CENTREP_SUPPORT_MULTIROFS) && defined(CENTREP_TRACE)		
sl@0: 		repUid=TUid::Uid(aMessage.Int0());
sl@0: 		subSession->iRepositoryUid=repUid;
sl@0: #endif		
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		subSession = SubSessionFromHandle(aMessage, aMessage.Int3());
sl@0: #if defined (SYMBIAN_CENTREP_SUPPORT_MULTIROFS) && defined(CENTREP_TRACE)
sl@0: 		repUid=subSession->iRepositoryUid;
sl@0: #endif		
sl@0: 		}
sl@0: 
sl@0: 	if(subSession)
sl@0: 		{
sl@0: 		
sl@0: 		TInt r = KErrNone;
sl@0: 		
sl@0: 		if(fn == EClose)
sl@0: 			{
sl@0: 			//delete subsession	
sl@0: 			DeleteSubSession(aMessage.Int3());
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			//ask subsession to handle the message
sl@0: 			r = subSession->ServiceL(aMessage);
sl@0: 			}
sl@0: 
sl@0: 		PERF_TEST_EVENT_END(subSession, aMessage);
sl@0: 	
sl@0: #if defined (SYMBIAN_CENTREP_SUPPORT_MULTIROFS) && defined(CENTREP_TRACE)
sl@0: 		TUint32 endTick=User::FastCounter();
sl@0: 		RDebug::Print(_L("[CENTREP],TimeStamp=,%d,Repository=,%x,Function=,%d,TickCount=,%d"),startTick,repUid.iUid,fn,endTick-startTick);
sl@0: #endif
sl@0: 		if (r != CServerSubSession::KDontCompleteMessage)
sl@0: 			{
sl@0: 			aMessage.Complete(r);
sl@0: 			}
sl@0: 		}
sl@0: 	//If (subsession == NULL) we don't need to complete the message, as the message is completed already when the client panicked
sl@0: 	#ifdef _DEBUG   
sl@0: 		else
sl@0: 			{
sl@0: 			RDebug::Print(_L("CServerSession::ServiceL - bad subsession handle. TServerRequest = %d"), fn); 
sl@0: 			}
sl@0: 	#endif
sl@0: 	}
sl@0: 
sl@0: //Creates a new subsession object, and writes its handle to the message.
sl@0: //A subsession object is the server side "partner" to the client side subsession.
sl@0: //On return last parameter of aMessage is filled with the handle of the subsession
sl@0: //and handle is also returned
sl@0: CServerSubSession* CServerSession::NewSubSessionL(const RMessage2& aMessage)
sl@0: 	{
sl@0: 	//create a new subsession
sl@0: 	CServerSubSession* subSession = new (ELeave) CServerSubSession(this);
sl@0: 	CleanupStack::PushL(subSession);
sl@0: 	
sl@0: 	//add the subsession object to this session's object container to generate a unique ID
sl@0: 	iContainer->AddL(subSession);
sl@0: 	CleanupStack::Pop(subSession);
sl@0: 	
sl@0: 	//add the object to the subsessions index, this returns a unique handle so that we can
sl@0: 	//refer to the object later
sl@0: 	TInt handle = iSubSessionIx->AddL(subSession);
sl@0: 	
sl@0: 	//write the handle to the client's message
sl@0: 	TPckgBuf<TInt> handlePckg(handle);
sl@0: 	TRAPD(res,aMessage.WriteL(3,handlePckg));
sl@0: 	if (res!=KErrNone)
sl@0: 		{
sl@0: 		iSubSessionIx->Remove(handle);
sl@0: 		PanicClient(EBadSubsessionHandle, aMessage);
sl@0: 		subSession = NULL;
sl@0: 		}
sl@0: 
sl@0: 	return subSession;
sl@0: 	}
sl@0: 	
sl@0: //Deletes a subsession object through its handle.
sl@0: void CServerSession::DeleteSubSession(TInt aHandle)
sl@0: 	{
sl@0: 	iSubSessionIx->Remove(aHandle);
sl@0: 	}
sl@0: 	
sl@0: inline CSessionManager* CServerSession::Server()
sl@0: 	{
sl@0: 	return static_cast<CSessionManager*>(const_cast<CServer2*>(CSession2::Server()));
sl@0: 	}
sl@0: 
sl@0: #if defined(__CENTREP_SERVER_PERFTEST__) || defined (__CENTREP_SERVER_MEMTEST__) || defined(__CENTREP_SERVER_CACHETEST__)
sl@0: // GetSetParameters
sl@0: // The function code EGetSetParameters is a generic msg reserved
sl@0: // for testing purpose. Int0 specifies the function to perform.
sl@0: TInt CServerSession::GetSetParameters(const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	TServerGetSetParametersSubCmd cmd = static_cast<TServerGetSetParametersSubCmd>(aMessage.Int0());
sl@0: 
sl@0: #ifdef __CENTREP_SERVER_PERFTEST__
sl@0: 	if (cmd == EGetPerfResults)
sl@0: 		{
sl@0: 		TInt desSize = aMessage.GetDesMaxLength(1);
sl@0: 		TInt numVals = desSize / sizeof(TUint32);
sl@0: 		if (numVals < KCentRepPerfTestArraySize)
sl@0: 			{
sl@0: 			return KErrOverflow;
sl@0: 			}
sl@0: 		TPtrC8 p(reinterpret_cast<const TUint8*>(TServerResources::iPerfTestMgr.Entries()),
sl@0: 				   KCentRepPerfTestArraySize * sizeof(TUint32));
sl@0: 		TInt ret = aMessage.Write(1, p);
sl@0: 		if (ret == KErrNone)
sl@0: 			{
sl@0: 			TUint lastCompleteAccess = TServerResources::iPerfTestMgr.LastCompleteAccess();
sl@0: 			TPckg<TUint> p2(lastCompleteAccess);
sl@0: 			ret = aMessage.Write(2, p2);
sl@0: 			}
sl@0: 		return ret;
sl@0: 		}
sl@0: 	else if (cmd == ERestartPerfTests)
sl@0: 		{
sl@0: 		TServerResources::iPerfTestMgr.Reset();
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: 	else if (cmd == EStopPerfTests)
sl@0: 		{
sl@0: 		TServerResources::iPerfTestMgr.Stop();
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: #endif // __CENTREP_SERVER_PERFTEST__
sl@0: 
sl@0: #ifdef __CENTREP_SERVER_MEMTEST__
sl@0: 	if(cmd == ERestartMemTests)
sl@0: 		{
sl@0: 		TServerResources::StartRecordTimerResult();
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: 	else if(cmd == ESingleMemTest)
sl@0: 		{
sl@0: 		RECORD_HEAP_SIZE(EMemLcnOnDemand, aMessage.Int1());
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: 	else if(cmd == EGetMemResults)
sl@0: 		{
sl@0: 		TInt count = TServerResources::iMemTestDataCount;
sl@0: 		TPckg<TInt> pCount(count);
sl@0: 		
sl@0: 		TInt err = aMessage.Write(1, pCount);
sl@0: 		if(err == KErrNone && count > 0)
sl@0: 			{
sl@0: 			TPtrC8 pBuf(reinterpret_cast<TUint8*>(TServerResources::iMemTestData), (TServerResources::iMemTestDataCount)*sizeof(TInt32));
sl@0: 			err = aMessage.Write(2, pBuf);
sl@0: 			}
sl@0: 		// Stop recording results
sl@0: 		TServerResources::StopRecordTimerResult();
sl@0: 		return err;
sl@0: 		}
sl@0: #endif // __CENTREP_SERVER_MEMTEST__
sl@0: 
sl@0: #ifdef __CENTREP_SERVER_CACHETEST__
sl@0: 	if (cmd == EEnableCache)
sl@0: 		{
sl@0: 		// First parameter is Timer Interval, second is cache size
sl@0: 		TServerResources::iCacheManager->EnableCache(aMessage.Int1(), aMessage.Int2());
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: 	else if (cmd == EDisableCache)
sl@0: 		{
sl@0: 		TServerResources::iCacheManager->DisableCache(ETrue);
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: #endif  // __CENTREP_SERVER_CACHETEST__
sl@0: 
sl@0: 	return KErrNotSupported;
sl@0: 	}
sl@0: #endif // __CENTREP_SERVER_PERFTEST__ || __CENTREP_SERVER_MEMTEST__ || __CENTREP_SERVER_CACHETEST__
sl@0: