--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kernel/eka/nkern/sched.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,130 @@
+// 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
+	}