// Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the License "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:

// e32\nkern\sched.cpp

// 

//

// TDfc member data

#define __INCLUDE_TDFC_DEFINES__

#define __INCLUDE_NTHREADBASE_DEFINES__

#include "nk_priv.h"

void ResumeDelayedThreads(TAny*)

	{

	TScheduler& s=TheScheduler;

	while (!s.iDelayedQ.IsEmpty())

		{

		NThreadBase& t = *(NThreadBase*)s.iDelayedQ.First()->Deque();

		t.i_ThrdAttr &= ~KThreadAttDelayed;

		if (t.iSuspendCount==0)

			t.DoReady();

		else

			t.iNState=NThreadBase::ESuspended;

		}

	}

// Don't need to zero initialise anything here since

// TheScheduler resides in .bss

TScheduler::TScheduler()

	:	TPriListBase(KNumPriorities), iKernCSLocked(1), iDelayDfc(ResumeDelayedThreads, NULL)

	{

	}

/** Return a pointer to the scheduler

	Intended for use by the crash debugger, not for general device driver use.

	@return	Pointer to the scheduler object

	@internalTechnology

 */

EXPORT_C TScheduler* TScheduler::Ptr()

	{

	return &TheScheduler;

	}

#ifndef __MSTIM_MACHINE_CODED__

// Enter and leave with interrupts off

void TScheduler::TimesliceTick()

	{

	NThreadBase* pC=iCurrentThread;

	if (pC->iTime>0 && --pC->iTime==0)

		RescheduleNeeded();

	}

#endif

#ifndef __SCHEDULER_MACHINE_CODED__

void TScheduler::Remove(NThreadBase* aThread)

	{

	__NK_ASSERT_DEBUG(!aThread->iHeldFastMutex);	// can't block while holding fast mutex

	aThread->iTime=aThread->iTimeslice;		// thread has blocked so it gets a fresh timeslice for next time

	TPriListBase::Remove(aThread);

	}

#endif

void TScheduler::RotateReadyList(TInt p)

//

// rotate the ready list for priority p

//

	{

	__NK_ASSERT_DEBUG(p>=0 && p<KNumPriorities);

	SDblQueLink* pQ=iQueue[p];

	if (pQ)

		{

		SDblQueLink* pN=pQ->iNext;

		if (pN!=pQ)

			{

			NThread* pT=(NThread*)pQ;

			pT->iTime=pT->iTimeslice;

			iQueue[p]=pN;

			if (pQ==iCurrentThread)

				RescheduleNeeded();

			}

		}

	}

/**	Converts a time interval in microseconds to thread timeslice ticks

	@param aMicroseconds time interval in microseconds.

	@return Number of thread timeslice ticks.  Non-integral results are rounded up.

 	@pre aMicroseconds should be nonnegative

	@pre any context

 */

EXPORT_C TInt NKern::TimesliceTicks(TUint32 aMicroseconds)

	{

	TUint32 msp = TheTimerQ.iTickPeriod;

	TUint32 ticks = (TUint32(aMicroseconds) + msp - 1) / msp;

	return ticks;

	}

/** Return the total CPU time so far used by the specified thread.

	@return The total CPU time in units of 1/NKern::CpuTimeMeasFreq().

*/

EXPORT_C TUint64 NKern::ThreadCpuTime(NThread* aThread)

	{

#ifdef MONITOR_THREAD_CPU_TIME

	NKern::Lock();

	TUint64 t = aThread->iTotalCpuTime;

	if (aThread == TheScheduler.iCurrentThread)

		t += TUint64(NKern::FastCounter() - aThread->iLastStartTime);

	NKern::Unlock();

	return t;

#else

	return 0;

#endif

	}