hg/stx-libbasic: comparison ProcessorScheduler.st

equal deleted inserted replaced

-:f5ff68fffb92
+:6f30be88e314
 	 classVariableNames:'KnownProcesses KnownProcessIds
 			     PureEventDriven
 			     UserSchedulingPriority
 			     UserInterruptPriority
 			     TimingPriority
+			     HighestPriority
 			     SchedulingPriority'
 	 poolDictionaries:''
 	 category:'Kernel-Processes'
 !
 ProcessorScheduler comment:'
 COPYRIGHT (c) 1993 by Claus Gittinger
 	     All Rights Reserved
-$Header: /cvs/stx/stx/libbasic/ProcessorScheduler.st,v 1.27 1995-02-05 21:33:24 claus Exp $
+$Header: /cvs/stx/stx/libbasic/ProcessorScheduler.st,v 1.28 1995-02-08 03:11:03 claus Exp $
 '!
 Smalltalk at:#Processor put:nil!
 !ProcessorScheduler class methodsFor:'documentation'!
 "
 !
 version
 "
-$Header: /cvs/stx/stx/libbasic/ProcessorScheduler.st,v 1.27 1995-02-05 21:33:24 claus Exp $
+$Header: /cvs/stx/stx/libbasic/ProcessorScheduler.st,v 1.28 1995-02-08 03:11:03 claus Exp $
 "
 !
 documentation
 "
 class variables:
 	KnownProcesses          <Collection>    all known processes
 	KnownProcessIds         <Collection>    and their IDs
 	PureEventDriven         <Boolean>       true, if no process support
 						is available
 	UserSchedulingPriority  <Integer>       the priority at which normal
 						user interfaces run
 	UserInterruptPriority                   the priority at which user-
 						interrupts (Cntl-C) processing
 						takes place. Processes with
 						a greater or equal priority are
 						not interruptable.
 	TimingPriority                          the priority used for timing.
 						Processes with a greater or
 						equal priority are not interrupted
 						by timers.
+	HighestPriority                         The highest allowed prio for processes
 	SchedulingPriority                      The priority of the scheduler (must
 						me higher than any other).
 most interresting methods:
 UserSchedulingPriority := 8.
 UserInterruptPriority := 24.
 TimingPriority := 16.
 SchedulingPriority := 31.
+HighestPriority := 30.
 Processor isNil ifTrue:[
 	"create the one and only processor"
 	Processor := self basicNew initialize.
 (dont add any message sends here)
 "
 activeProcess := aProcess.
 currentPriority := pri.
 %{
-extern OBJ __threadSwitch(), __threadSwitchWithSingleStep();
+extern OBJ ___threadSwitch();
-if (singleStep == true)
+ok = ___threadSwitch(__context, _intVal(id), (singleStep == true) ? 1 : 0);
-	ok = __threadSwitchWithSingleStep(__context, _intVal(id));
-else
-	ok = __threadSwitch(__context, _intVal(id));
 %}.
 "time passes spent in some other process ...
 ... here again"
 p := activeProcess.
 "return the highest priority value processes can have"
 "must be below schedulingPriority -
 otherwise scheduler could be blocked ...
 "
-^ SchedulingPriority - 1
+^ HighestPriority
 !
 schedulingPriority
 "return the priority at which the scheduler runs"
 "
 check if the running process is not the only one
 "
 l size ~~ 1 ifTrue:[
-"
+	"
-bring running process to the end
+	 bring running process to the end
-"
+	"
-l removeFirst.
+	l removeFirst.
-l addLast:activeProcess.
+	l addLast:activeProcess.
-"
+	"
-and switch to first in the list
+	 and switch to first in the list
-"
+	"
-self threadSwitch:(l first).
+	self threadSwitch:(l first).
 ].
 wasBlocked ifFalse:[OperatingSystem unblockInterrupts].
 !
 suspend:aProcess
 newPrio := prio.
 newPrio < 1 ifTrue:[
 	newPrio := 1.
 ] ifFalse:[
 	aProcess == scheduler ifTrue:[^ self].
-	newPrio >= SchedulingPriority ifTrue:[
+	newPrio > HighestPriority ifTrue:[
-	    newPrio := SchedulingPriority - 1
+	    newPrio := HighestPriority
 	]
 ].
 wasBlocked := OperatingSystem blockInterrupts.
 !ProcessorScheduler methodsFor:'queries'!
 highestPriorityRunnableProcess
 "return the highest prio runnable process"
-|l p maxPri "{ Class: SmallInteger }" |
+|listArray l p maxPri "{ Class: SmallInteger }" |
-maxPri := self highestPriority.
+maxPri := HighestPriority.
+listArray := quiescentProcessLists.
 maxPri to:1 by:-1 do:[:prio |
-	l := quiescentProcessLists at:prio.
+	l := listArray at:prio.
 	l notNil ifTrue:[
 	    l isEmpty ifTrue:[
 		"
 		 on the fly clear out empty lists
 		"
-		quiescentProcessLists at:prio put:nil
+		listArray at:prio put:nil
 	    ] ifFalse:[
 		p := l first.
 		"
 		 if it got corrupted somehow
 		"
 	]
 ].
 ^ nil
 !
+isSystemProcess:aProcess
+"return true if aProcess is a system process,
+which should not be suspended/terminated etc.."
+(self class isPureEventDriven
+or:[aProcess id == 0
+or:[aProcess nameOrId endsWith:'dispatcher']]) ifTrue:[
+	^ true
+].
+^ false
+"
+Processor activeProcessIsSystemProcess
+"
+!
 activeProcessIsSystemProcess
 "return true if the active process is a system process,
 which should not be suspended."
-|active|
+^ self isSystemProcess:activeProcess
-(self class isPureEventDriven
-or:[(active := self activeProcess) id == 0
-or:[active nameOrId endsWith:'dispatcher']]) ifTrue:[
-	^ true
-].
-^ false
 "
 Processor activeProcessIsSystemProcess
 "
 ! !

changeset 241	6f30be88e314
parent 231	fd0e55e352f8
child 243	1b7ab889a45f