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

 //

 #include "srvPerf.h"

 #ifdef __CENTREP_SERVER_PERFTEST__

 #include "srvreqs.h"

 #include "srvsubsess.h"

 // SessionClose

 // Decrement reference count. If no more active sessions

 // then advance iLastCompleteAccess

 void TCentRepPerfTest::SessionClose()

 	{

 	iActiveSessionCount--;

 	// There are clients who never close their sessions. Hence

 	// cannot use iActiveSessionCount == 0 as indication to copy

 	// iCount to iLastCompleteAccess.

 	if (!IsFinished())

 		{

 		iLastCompleteAccess = iCount;

 		}

 	}

 // Append

 // Add the integer if iEntries array is not full yet.

 TInt TCentRepPerfTest::Append(TUint32 aEntry)

 	{

 	if (iCount < KCentRepPerfTestArraySize)

 		{

 		iEntries[iCount++] = aEntry;

 		return KErrNone;

 		}

 	return KErrOverflow;

 	}

 // Function EncodeEventAndData

 // Put event Id in upper 8 bit and data in lower 24 bit.

 inline

 TUint32 EncodeEventAndData(TUint aEventId, TUint32 aData)

 	{

 	return ((aEventId & KEventIdMask) << KEventIdShiftBits) |

 		   (aData & KDataMask);

 	}

 // Save initial values of timer

 void TCentRepPerfTest::DoEventStart(CServerSubSession* aSubSession, const TClientRequest& /*aMessage*/)

 	{

 	if(IsFinished())

 		{

 		return;

 		}

 	//set the uid of the repository that this operation will be 

 	//performed on as the current repository

 	if(aSubSession) //aSubSession would be NULL in the case of EInitialise and EClose operations

 		{

 		SetCurrentRepositoryUid(aSubSession->RepositoryUid().iUid);

 		}

 	iStartTick = User::FastCounter();

 	}

 // Save initial values of timer

 void TCentRepPerfTest::DoServerStart()

 	{

 	iStartTick = User::FastCounter();

 	}	

 // store time of event, etc. in performance array

 void TCentRepPerfTest::DoServerEnd()

 	{

 	TUint32 endTick = User::FastCounter();

 	TServerRequest fn = EInitialiseServer;

 	TUint32 entry = EncodeEventAndData(fn, endTick - iStartTick);

 	Append(entry);

 	}

 // store time of event, etc. in performance array

 void TCentRepPerfTest::DoEventEnd(CServerSubSession* /*aSubSession*/, const TClientRequest& aMessage)

 	{

 	TUint32 endTick = User::FastCounter();

 	if (IsFinished())

 		{

 		return;

 		}

 	TServerRequest fn = static_cast<TServerRequest>(aMessage.Function());

 	// Performance data has 3 parts. First: time spent to

 	// service the request. 2nd if event is open/close/evict

 	// time of the event. 3rd, if open/close/evict repository UID

 	// First part: event ID and CPU time spent servicing the request

 	TUint32 entry = EncodeEventAndData(fn, endTick - iStartTick);

 	Append(entry);

 	if (fn == EInitialise)

 		{

 		SessionOpen();

 		//store the repository UID in the subsession so that we can refer to it later

 		SetCurrentRepositoryUid(aMessage.Int0());

 		}

 	//get the uid of the repository that this operation is being performed on

 	TUint32 currentRepositoryUid = CurrentRepositoryUid();

 	TBool repOpenCloseEvict = fn == EInitialise || fn == EClose || fn == EEvict;

 	// Third part: repository UID if event is open/close/evict.

 	if (repOpenCloseEvict)

 		{

 		Append(iStartTick);

 		Append(currentRepositoryUid);  // Append will check if array IsFull.

 		}

 	// One last thing to do: check if all concurrent sessions close.

 	if (fn == EClose)

 		{

 		SessionClose();

 		// This is a temporary solution to detect end-of-boot until SS code is 

 		// modified to return end-of-boot state and Centrep becomes SSA 

 		if (currentRepositoryUid == 0xCCCCCC00)

 			{

 			IncEndOfBoot();

 			}

 		}

 	}

 #endif //__CENTREP_SERVER_PERFTEST__