sl@0: // Copyright (c) 2005-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 "srvPerf.h"
sl@0: 
sl@0: #ifdef __CENTREP_SERVER_PERFTEST__
sl@0: 
sl@0: #include "srvreqs.h"
sl@0: #include "srvsubsess.h"
sl@0: 
sl@0: // SessionClose
sl@0: // Decrement reference count. If no more active sessions
sl@0: // then advance iLastCompleteAccess
sl@0: void TCentRepPerfTest::SessionClose()
sl@0: 	{
sl@0: 	iActiveSessionCount--;
sl@0: 	// There are clients who never close their sessions. Hence
sl@0: 	// cannot use iActiveSessionCount == 0 as indication to copy
sl@0: 	// iCount to iLastCompleteAccess.
sl@0: 
sl@0: 	if (!IsFinished())
sl@0: 		{
sl@0: 		iLastCompleteAccess = iCount;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: // Append
sl@0: // Add the integer if iEntries array is not full yet.
sl@0: TInt TCentRepPerfTest::Append(TUint32 aEntry)
sl@0: 	{
sl@0: 	if (iCount < KCentRepPerfTestArraySize)
sl@0: 		{
sl@0: 		iEntries[iCount++] = aEntry;
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: 	return KErrOverflow;
sl@0: 	}
sl@0: 	
sl@0: // Function EncodeEventAndData
sl@0: // Put event Id in upper 8 bit and data in lower 24 bit.
sl@0: inline
sl@0: TUint32 EncodeEventAndData(TUint aEventId, TUint32 aData)
sl@0: 	{
sl@0: 	return ((aEventId & KEventIdMask) << KEventIdShiftBits) |
sl@0: 		   (aData & KDataMask);
sl@0: 	}
sl@0: 
sl@0: // Save initial values of timer
sl@0: void TCentRepPerfTest::DoEventStart(CServerSubSession* aSubSession, const TClientRequest& /*aMessage*/)
sl@0: 	{
sl@0: 	if(IsFinished())
sl@0: 		{
sl@0: 		return;
sl@0: 		}
sl@0: 	
sl@0: 	//set the uid of the repository that this operation will be 
sl@0: 	//performed on as the current repository
sl@0: 	if(aSubSession) //aSubSession would be NULL in the case of EInitialise and EClose operations
sl@0: 		{
sl@0: 		SetCurrentRepositoryUid(aSubSession->RepositoryUid().iUid);
sl@0: 		}
sl@0: 	
sl@0: 	iStartTick = User::FastCounter();
sl@0: 	}
sl@0: 
sl@0: // Save initial values of timer
sl@0: void TCentRepPerfTest::DoServerStart()
sl@0: 	{
sl@0: 	iStartTick = User::FastCounter();
sl@0: 	}	
sl@0: 	
sl@0: // store time of event, etc. in performance array
sl@0: void TCentRepPerfTest::DoServerEnd()
sl@0: 	{
sl@0: 	TUint32 endTick = User::FastCounter();
sl@0: 
sl@0: 	TServerRequest fn = EInitialiseServer;
sl@0: 	TUint32 entry = EncodeEventAndData(fn, endTick - iStartTick);
sl@0: 	Append(entry);
sl@0: 	}
sl@0: 
sl@0: // store time of event, etc. in performance array
sl@0: void TCentRepPerfTest::DoEventEnd(CServerSubSession* /*aSubSession*/, const TClientRequest& aMessage)
sl@0: 	{
sl@0: 	TUint32 endTick = User::FastCounter();
sl@0: 
sl@0: 	if (IsFinished())
sl@0: 		{
sl@0: 		return;
sl@0: 		}
sl@0: 
sl@0: 	TServerRequest fn = static_cast<TServerRequest>(aMessage.Function());
sl@0: 	// Performance data has 3 parts. First: time spent to
sl@0: 	// service the request. 2nd if event is open/close/evict
sl@0: 	// time of the event. 3rd, if open/close/evict repository UID
sl@0: 
sl@0: 	// First part: event ID and CPU time spent servicing the request
sl@0: 	TUint32 entry = EncodeEventAndData(fn, endTick - iStartTick);
sl@0: 	Append(entry);
sl@0: 
sl@0: 	if (fn == EInitialise)
sl@0: 		{
sl@0: 		SessionOpen();
sl@0: 		
sl@0: 		//store the repository UID in the subsession so that we can refer to it later
sl@0: 		SetCurrentRepositoryUid(aMessage.Int0());
sl@0: 		}
sl@0: 
sl@0: 	//get the uid of the repository that this operation is being performed on
sl@0: 	TUint32 currentRepositoryUid = CurrentRepositoryUid();
sl@0: 	
sl@0: 	TBool repOpenCloseEvict = fn == EInitialise || fn == EClose || fn == EEvict;
sl@0: 
sl@0: 	// Third part: repository UID if event is open/close/evict.
sl@0: 	if (repOpenCloseEvict)
sl@0: 		{
sl@0: 		Append(iStartTick);
sl@0: 		Append(currentRepositoryUid);  // Append will check if array IsFull.
sl@0: 		}
sl@0: 
sl@0: 	// One last thing to do: check if all concurrent sessions close.
sl@0: 	if (fn == EClose)
sl@0: 		{
sl@0: 		SessionClose();
sl@0: 
sl@0: 		// This is a temporary solution to detect end-of-boot until SS code is 
sl@0: 		// modified to return end-of-boot state and Centrep becomes SSA 
sl@0: 		if (currentRepositoryUid == 0xCCCCCC00)
sl@0: 			{
sl@0: 			IncEndOfBoot();
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 	
sl@0: 
sl@0: #endif //__CENTREP_SERVER_PERFTEST__
sl@0: