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