hg/stx-libbasic: comparison ProcessorScheduler.st

equal deleted inserted replaced

-:7391258a73e8
+:6a3ce5694cc9
 "/  this safes a bit of memory allocation in the scheduler)
 dispatchAction := [self dispatch].
 handlerAction := [:ex |
-('Processor [info]: ignored signal (', ex signal printString, ')') infoPrintCR.
+			('Processor [info]: ignored signal (', ex signal printString, ')') infoPrintCR.
-ex return
+			ex return
-].
+		     ].
 ignoredSignals := SignalSet
-with:TerminateProcessRequest
+			with:TerminateProcessRequest
-with:AbortSignal.
+			with:AbortSignal.
 "/
 "/ I made this an extra call to dispatch; this allows recompilation
 "/  of the dispatch-handling code in the running system.
 "/
 [dispatching] whileTrue:[
-ignoredSignals handle:handlerAction do:dispatchAction
+	ignoredSignals handle:handlerAction do:dispatchAction
 ].
 "/ we arrive here in standalone Apps,
 "/ when the last process at or above UserSchedulingPriority process died.
 "/ regular ST/X stays in above loop forever
 |nPrios "{ Class: SmallInteger }"
 p l|
 KnownProcesses isNil ifTrue:[
-KnownProcesses := WeakArray new:30.
+	KnownProcesses := WeakArray new:30.
-KnownProcesses addDependent:self class.
+	KnownProcesses addDependent:self class.
-KnownProcessIds := OrderedCollection new.
+	KnownProcessIds := OrderedCollection new.
 ].
 "
 create a collection with process lists; accessed using the priority as key
 "
 timeoutProcessArray := Array new:5.
 anyTimeouts := false.
 dispatching := false.
 exitWhenNoMoreUserProcesses isNil ifTrue:[
-exitWhenNoMoreUserProcesses := false. "/ mhmh - how about true ?
+	exitWhenNoMoreUserProcesses := false. "/ mhmh - how about true ?
 ].
 useIOInterrupts := OperatingSystem supportsIOInterrupts.
 gotIOInterrupt := false.
 osChildExitActions := Dictionary new.
 gotChildSignalInterrupt := false.
 This is only used with win32's native threads."
 |index pri aProcess l|
 OperatingSystem interruptsBlocked ifFalse:[
-MiniDebugger
+	MiniDebugger
-enterWithMessage:'resumeImmediateInterrupt with no interruptsBlocked'
+	    enterWithMessage:'resumeImmediateInterrupt with no interruptsBlocked'
-mayProceed:true.
+	    mayProceed:true.
 ].
 index := KnownProcessIds identityIndexOf:id.
 index ~~ 0 ifTrue:[
-aProcess := KnownProcesses at:index.
+	aProcess := KnownProcesses at:index.
-"/
+	"/
-"/ CG: the situation below may happen, if the wrapCall
+	"/ CG: the situation below may happen, if the wrapCall
-"/ finishes before the process was layed to sleep
+	"/ finishes before the process was layed to sleep
-"/ (i.e. schedulerIRQ arrives before the threadSwitch
+	"/ (i.e. schedulerIRQ arrives before the threadSwitch
-"/ was finished.
+	"/ was finished.
-"/ In that case, simply resume it and everything is OK.
+	"/ In that case, simply resume it and everything is OK.
-"/
+	"/
 "/        aProcess state ~~ #wrapWait ifTrue:[
 "/            'ProcSched [info]: oops - resumeImmIRQ for non wrapWait process' infoPrintCR.
 "/            ^ self
 "/        ].
-pri := aProcess priority.
+	pri := aProcess priority.
-l := quiescentProcessLists at:pri.
+	l := quiescentProcessLists at:pri.
-"if already running, ignore"
+	"if already running, ignore"
-l notNil ifTrue:[
+	l notNil ifTrue:[
-(l identityIndexOf:aProcess) ~~ 0 ifTrue:[
+	    (l identityIndexOf:aProcess) ~~ 0 ifTrue:[
-'ProcSched [info]: oops - resumeIRQ for already running process' infoPrintCR.
+		'ProcSched [info]: oops - resumeIRQ for already running process' infoPrintCR.
-^ self
+		^ self
-]
+	    ]
-] ifFalse:[
+	] ifFalse:[
-l := LinkedList new.
+	    l := LinkedList new.
-quiescentProcessLists at:pri put:l.
+	    quiescentProcessLists at:pri put:l.
-].
+	].
-l addLast:aProcess.
+	l addLast:aProcess.
-aProcess state:#run.
+	aProcess state:#run.
 ] ifFalse:[
-'ProcSched [info]: oops - resumeIRQ for unknown process: ' infoPrint.
+	'ProcSched [info]: oops - resumeIRQ for unknown process: ' infoPrint.
-id infoPrintCR.
+	id infoPrintCR.
 ]
 "Modified: / 28.9.1998 / 11:36:53 / cg"
 ! !
 The method returns the value from aBlockReturningPid (i.e a pid or nil)."
 |pid blocked osProcessStatus|
 OperatingSystem supportsChildInterrupts ifTrue:[
-"/ SIGCHLD is supported,
+	"/ SIGCHLD is supported,
-"/ aBlock will be evaluated, as soon as a SIGCHLD interrupt for pid has been received.
+	"/ aBlock will be evaluated, as soon as a SIGCHLD interrupt for pid has been received.
-OperatingSystem enableChildSignalInterrupts.
+	OperatingSystem enableChildSignalInterrupts.
-blocked := OperatingSystem blockInterrupts.
+	blocked := OperatingSystem blockInterrupts.
-pid := aBlockReturningPid value.
+	pid := aBlockReturningPid value.
-pid notNil ifTrue:[
+	pid notNil ifTrue:[
-osChildExitActions at:pid put:actionBlock.
+	    osChildExitActions at:pid put:actionBlock.
-].
+	].
-blocked ifFalse:[
+	blocked ifFalse:[
-OperatingSystem unblockInterrupts.
+	    OperatingSystem unblockInterrupts.
-].
+	].
 ] ifFalse:[
-"/ SIGCHLD is not supported, fork a high prio process
+	"/ SIGCHLD is not supported, fork a high prio process
-"/ to poll for for the exit of pid.
+	"/ to poll for for the exit of pid.
-blocked := OperatingSystem blockInterrupts.
+	blocked := OperatingSystem blockInterrupts.
-pid := aBlockReturningPid value.
+	pid := aBlockReturningPid value.
-pid notNil ifTrue:[
+	pid notNil ifTrue:[
-osChildExitActions at:pid put:actionBlock.
+	    osChildExitActions at:pid put:actionBlock.
-].
+	].
-blocked ifFalse:[
+	blocked ifFalse:[
-OperatingSystem unblockInterrupts.
+	    OperatingSystem unblockInterrupts.
-].
+	].
-pid notNil ifTrue:[
+	pid notNil ifTrue:[
-[
+	    [
-[
+		[
-|polling myDelay t|
+		  |polling myDelay t|
-polling := true.
+		  polling := true.
-myDelay := Delay forMilliseconds:(t := EventPollingInterval).
+		  myDelay := Delay forMilliseconds:(t := EventPollingInterval).
-[polling] whileTrue:[
+		  [polling] whileTrue:[
-t ~~ EventPollingInterval ifTrue:[
+		      t ~~ EventPollingInterval ifTrue:[
-"/ interval changed -> need a new delay
+			  "/ interval changed -> need a new delay
-myDelay delay:(t := EventPollingInterval).
+			  myDelay delay:(t := EventPollingInterval).
-].
+		      ].
-myDelay wait.
+		      myDelay wait.
-(osChildExitActions includesKey:pid) ifFalse:[
+		      (osChildExitActions includesKey:pid) ifFalse:[
-polling := false.
+			  polling := false.
-] ifTrue:[
+		      ] ifTrue:[
-osProcessStatus := OperatingSystem childProcessWait:false pid:pid.
+			  osProcessStatus := OperatingSystem childProcessWait:false pid:pid.
-osProcessStatus notNil ifTrue:[
+			  osProcessStatus notNil ifTrue:[
-(osProcessStatus pid = pid) ifTrue:[
+			      (osProcessStatus pid = pid) ifTrue:[
-osChildExitActions removeKey:pid ifAbsent:nil.
+				  osChildExitActions removeKey:pid ifAbsent:nil.
-actionBlock value:osProcessStatus.
+				  actionBlock value:osProcessStatus.
-polling := false.
+				  polling := false.
-] ifFalse:[
+			      ] ifFalse:[
-osProcessStatus stillAlive
+				  osProcessStatus stillAlive
-]
+			      ]
-]
+			  ]
-].
+		      ].
-]
+		  ]
-] valueOnUnwindDo:[
+	      ] valueOnUnwindDo:[
-osChildExitActions removeKey:pid ifAbsent:nil
+		  osChildExitActions removeKey:pid ifAbsent:nil
-]
+	      ]
-] forkAt:TimingPriority.
+	    ] forkAt:TimingPriority.
-].
+	].
 ].
 ^ pid
 "Created: / 25.3.1997 / 10:54:56 / stefan"
 "Modified: / 25.3.1997 / 11:21:05 / stefan"
 activeProcess := oldProcess.
 activeProcessId := oldId.
 currentPriority := oldProcess priority.
 ok == true ifFalse:[
-"
+	"
-switch failed for some reason -
+	 switch failed for some reason -
-destroy (hard-terminate) the bad process.
+	 destroy (hard-terminate) the bad process.
-This happens when:
+	 This happens when:
-- the stack went above the absolute limit
+	 - the stack went above the absolute limit
-(VM switches back to scheduler)
+	   (VM switches back to scheduler)
-- a halted process cannot execute its interrupt
+	 - a halted process cannot execute its interrupt
-actions (win32 only)
+	   actions (win32 only)
-"
+	"
-(id := p id) ~~ 0 ifTrue:[
+	(id := p id) ~~ 0 ifTrue:[
-id notNil ifTrue:[
+	    id notNil ifTrue:[
-'Processor [warning]: problem with process ' errorPrint.
+		'Processor [warning]: problem with process ' errorPrint.
-id errorPrint.
+		id errorPrint.
-(nm := p name) notNil ifTrue:[
+		(nm := p name) notNil ifTrue:[
-' (' errorPrint. nm errorPrint. ')' errorPrint.
+		    ' (' errorPrint. nm errorPrint. ')' errorPrint.
-].
+		].
-ok == #halted ifTrue:[
+		ok == #halted ifTrue:[
-"/ that process was halted (win32 only)
+		    "/ that process was halted (win32 only)
-p state:#halted.
+		    p state:#halted.
-'; stopped it.' errorPrintCR.
+		   '; stopped it.' errorPrintCR.
-self suspend:p.
+		   self suspend:p.
-] ifFalse:[
+		] ifFalse:[
-'; hard-terminate it.' errorPrintCR.
+		   '; hard-terminate it.' errorPrintCR.
-'Processor [info]: cleanup may take a while if stack is huge' infoPrintCR.
+		   'Processor [info]: cleanup may take a while if stack is huge' infoPrintCR.
-p state:#cleanup.
+		   p state:#cleanup.
-self terminateNoSignal:p.
+		   self terminateNoSignal:p.
-]
+		]
-]
+	    ]
-]
+	]
 ].
 zombie notNil ifTrue:[
-self class threadDestroy:zombie.
+	self class threadDestroy:zombie.
-zombie := nil
+	zombie := nil
 ].
 wasBlocked ifFalse:[OperatingSystem unblockInterrupts].
 !
 threadSwitchFrom:oldProcess to:aProcess id:id singleStep:singleStep
 %{
 extern OBJ ___threadSwitch();
 OBJ ok;
 if (__isSmallInteger(id)) {
-ok = ___threadSwitch(__context, __intVal(id), (singleStep == true) ? 1 : 0);
+	ok = ___threadSwitch(__context, __intVal(id), (singleStep == true) ? 1 : 0, 0);
 } else {
-ok = false;
+	ok = false;
 }
 RETURN (ok)
 %}
 ! !
 ].
 "/ the returned value here has a subtle effect:
 "/ if false, the interrupt is assumed to be not taken,
 "/ and will be redelivered.
 ^ activeProcess interruptedIn:s
 "Modified: 20.10.1996 / 17:06:48 / cg"
 !
 |pri id l wasBlocked|
 aProcess isNil ifTrue:[^ self].
 aProcess == scheduler ifTrue:[
-InvalidProcessSignal raiseWith:aProcess errorString:'PROCESSOR: I will not terminate scheduler'.
+	InvalidProcessSignal raiseWith:aProcess errorString:'PROCESSOR: I will not terminate scheduler'.
-^ self
+	^ self
 ].
 id := aProcess id.
 id isNil ifTrue:[^ self].   "already dead"
 "remove the process from the runnable list"
 pri := aProcess priority.
 l := quiescentProcessLists at:pri.
 l notNil ifTrue:[
-(l remove:aProcess ifAbsent:nil) notNil ifTrue:[
+	(l remove:aProcess ifAbsent:nil) notNil ifTrue:[
-l isEmpty ifTrue:[
+	    l isEmpty ifTrue:[
-quiescentProcessLists at:pri put:nil
+		quiescentProcessLists at:pri put:nil
-]
+	    ]
-].
+	].
 ].
 wasBlocked ifFalse:[OperatingSystem unblockInterrupts].
 aProcess == activeProcess ifTrue:[
-"
+	"
-hard case - its the currently running process
+	 hard case - its the currently running process
-we must have the next active process destroy this one
+	 we must have the next active process destroy this one
-(we cannot destroy the chair we are sitting on ... :-)
+	 (we cannot destroy the chair we are sitting on ... :-)
-"
+	"
-zombie := id.
+	zombie := id.
-self unRemember:aProcess.
+	self unRemember:aProcess.
-self threadSwitch:scheduler.
+	self threadSwitch:scheduler.
-"not reached"
+	"not reached"
-^ self
+	^ self
 ].
 self class threadDestroy:id.
 self unRemember:aProcess.
 ^ self
 "arrange for a semaphore to be triggered when input on aStream arrives.
 This will do a select, if the OS supports selecting on that filedescriptor,
 otherwise, it will be polled every few milliseconds (MSDOS)."
 aStream canBeSelected ifTrue:[
-"/ can this stream be selected on ?
+	"/ can this stream be selected on ?
-self signal:aSemaphore onInput:aStream fileDescriptor orCheck:nil
+	self signal:aSemaphore onInput:aStream fileDescriptor orCheck:nil
 ] ifFalse:[
-"/ nope - must poll ...
+	"/ nope - must poll ...
-self signal:aSemaphore onInput:nil orCheck:[aStream canReadWithoutBlocking]
+	self signal:aSemaphore onInput:nil orCheck:[aStream canReadWithoutBlocking]
 ]
 "Modified: / 14.12.1999 / 23:58:50 / cg"
 !
 "arrange for a semaphore to be triggered when output on aStream is possible.
 This will do a select, if the OS supports selecting on that filedescriptor,
 otherwise, it will be polled every few milliseconds (MSDOS)."
 aStream canBeSelected ifTrue:[
-"/ can this stream be selected on ?
+	"/ can this stream be selected on ?
-self signal:aSemaphore onOutput:aStream fileDescriptor orCheck:nil
+	self signal:aSemaphore onOutput:aStream fileDescriptor orCheck:nil
 ] ifFalse:[
-"/ nope - must poll ...
+	"/ nope - must poll ...
-self signal:aSemaphore onOutput:nil orCheck:[aStream canWriteWithoutBlocking]
+	self signal:aSemaphore onOutput:nil orCheck:[aStream canWriteWithoutBlocking]
 ]
 "Modified: / 14.12.1999 / 23:59:19 / cg"
 ! !
 If enabled, arrangements are made for data-availability to trigger an
 interrupt.
 Using IO interrupts reduces the idle CPU usage of ST/X by some percent
 (typically 2-7%).
 Notice:
-some systems do not support IO-interrupts (or have a broken stdio-lib),
+	some systems do not support IO-interrupts (or have a broken stdio-lib),
-and this feature is always disabled;
+	and this feature is always disabled;
 Also notice:
-we found that in some Xlib-implementations, interrupted reads are not
+	we found that in some Xlib-implementations, interrupted reads are not
-handled correctly (especially in multi-headed applications), and this
+	handled correctly (especially in multi-headed applications), and this
-feature should be disabled to avoid a blocking XPending.
+	feature should be disabled to avoid a blocking XPending.
 If this method is used to disable IO interrupts in multi-headed apps,
 it should be invoked BEFORE the display event dispatcher processes are started."
 OperatingSystem supportsIOInterrupts ifTrue:[
-useIOInterrupts := aBoolean
+	useIOInterrupts := aBoolean
 ].
 "Created: / 15.7.1998 / 13:32:29 / cg"
 ! !
 "/ must enable interrupts, to be able to get out of a
 "/ long wait (especially, to handle sigChild in the meantime)
 (wasBlocked := OperatingSystem interruptsBlocked) ifTrue:[
-OperatingSystem unblockInterrupts.
+	OperatingSystem unblockInterrupts.
 ].
 fd := OperatingSystem
-selectOnAnyReadable:readFdArray
+	      selectOnAnyReadable:readFdArray
-writable:writeFdArray
+			 writable:writeFdArray
-exception:nil
+			exception:nil
-withTimeOut:millis.
+		      withTimeOut:millis.
 wasBlocked ifTrue:[
-OperatingSystem blockInterrupts.
+	OperatingSystem blockInterrupts.
 ].
 fd isNil ifTrue:[
-"/ either still nothing to do,
+	"/ either still nothing to do,
-"/ or error (which should not happen)
+	"/ or error (which should not happen)
-(err := OperatingSystem lastErrorSymbol) notNil ifTrue:[
+	(err := OperatingSystem lastErrorSymbol) notNil ifTrue:[
-err == #EBADF ifTrue:[
+	    err == #EBADF ifTrue:[
-"/ mhmh - one of the fd's given to me is corrupt.
+		"/ mhmh - one of the fd's given to me is corrupt.
-"/ find out which one .... and remove it
+		"/ find out which one .... and remove it
-'Processor [info]: obsolete FD in select - clearing' infoPrintCR.
+		'Processor [info]: obsolete FD in select - clearing' infoPrintCR.
-OperatingSystem clearLastErrorNumber.
+		OperatingSystem clearLastErrorNumber.
-self removeCorruptedFds
+		self removeCorruptedFds
-] ifFalse:[
+	    ] ifFalse:[
-err == #ENOENT ifTrue:[
+		err == #ENOENT ifTrue:[
-'Processor [warning]: ENOENT in select; rd=' infoPrint.
+		    'Processor [warning]: ENOENT in select; rd=' infoPrint.
-readFdArray infoPrint.
+		    readFdArray infoPrint.
-' wr=' infoPrint.
+		    ' wr=' infoPrint.
-writeFdArray infoPrintCR.
+		    writeFdArray infoPrintCR.
-] ifFalse:[
+		] ifFalse:[
-'Processor [warning]: error in select: ' infoPrint. err infoPrintCR.
+		    'Processor [warning]: error in select: ' infoPrint. err infoPrintCR.
-]
+		]
-].
+	    ].
-]
+	]
 ] ifFalse:[
-index := readFdArray identityIndexOf:fd.
+	index := readFdArray identityIndexOf:fd.
-index ~~ 0 ifTrue:[
+	index ~~ 0 ifTrue:[
-sema := readSemaphoreArray at:index.
+	    sema := readSemaphoreArray at:index.
-sema notNil ifTrue:[
+	    sema notNil ifTrue:[
-sema signalOnce.
+		sema signalOnce.
-^ true
+		^ true
-].
+	    ].
-action := readCheckArray at:index.
+	    action := readCheckArray at:index.
-action notNil ifTrue:[
+	    action notNil ifTrue:[
-action value.
+		action value.
-^ true
+		 ^ true
-]
+	    ]
-].
+	].
-index := writeFdArray identityIndexOf:fd.
+	index := writeFdArray identityIndexOf:fd.
-index ~~ 0 ifTrue:[
+	index ~~ 0 ifTrue:[
-sema := writeSemaphoreArray at:index.
+	    sema := writeSemaphoreArray at:index.
-sema notNil ifTrue:[
+	    sema notNil ifTrue:[
-sema signalOnce.
+		sema signalOnce.
-^ true
+		 ^ true
-].
+	    ].
-action := writeCheckArray at:index.
+	    action := writeCheckArray at:index.
-action notNil ifTrue:[
+	    action notNil ifTrue:[
-action value.
+		action value.
-^ true
+		 ^ true
-]
+	    ]
-]
+	]
 ].
 ^ false
 "Modified: / 12.4.1996 / 09:31:22 / stefan"
 "Modified: / 14.6.1998 / 17:31:51 / cg"
 |millis doingGC anySema dT|
 doingGC := true.
 [doingGC] whileTrue:[
-anyTimeouts ifTrue:[
+	anyTimeouts ifTrue:[
-millis := self timeToNextTimeout.
+	    millis := self timeToNextTimeout.
-(millis notNil and:[millis <= 0]) ifTrue:[
+	    (millis notNil and:[millis <= 0]) ifTrue:[
-^ self    "oops - hurry up checking"
+		^ self    "oops - hurry up checking"
-].
+	    ].
-].
+	].
-"
+	"
-if its worth doing, collect a bit of garbage;
+	 if its worth doing, collect a bit of garbage;
-but not, if a backgroundCollector is active
+	 but not, if a backgroundCollector is active
-"
+	"
-ObjectMemory backgroundCollectorRunning ifTrue:[
+	ObjectMemory backgroundCollectorRunning ifTrue:[
-doingGC := false
+	    doingGC := false
-] ifFalse:[
+	] ifFalse:[
-doingGC := ObjectMemory gcStepIfUseful.
+	    doingGC := ObjectMemory gcStepIfUseful.
-].
+	].
-"then do idle actions"
+	"then do idle actions"
-(idleActions notNil and:[idleActions size ~~ 0]) ifTrue:[
+	(idleActions notNil and:[idleActions size ~~ 0]) ifTrue:[
-idleActions do:[:aBlock |
+	    idleActions do:[:aBlock |
-aBlock value.
+		aBlock value.
-].
+	    ].
-^ self   "go back checking"
+	    ^ self   "go back checking"
-].
+	].
-doingGC ifTrue:[
+	doingGC ifTrue:[
-(self checkForInputWithTimeout:0) ifTrue:[
+	    (self checkForInputWithTimeout:0) ifTrue:[
-^ self  "go back checking"
+		^ self  "go back checking"
-]
+	    ]
-]
+	]
 ].
 exitWhenNoMoreUserProcesses ifTrue:[
-"/ check if there are any processes at all
+	"/ check if there are any processes at all
-"/ stop dispatching if there is none
+	"/ stop dispatching if there is none
-"/ (and millis is nil, which means that no timeout blocks are present)
+	"/ (and millis is nil, which means that no timeout blocks are present)
-"/ and no readSemaphores are present (which means that noone is waiting for input)
+	"/ and no readSemaphores are present (which means that noone is waiting for input)
-"/ and no writeSemaphores are present
+	"/ and no writeSemaphores are present
-anySema := false.
+	anySema := false.
-anySema := (readSemaphoreArray findFirst:[:sema | sema notNil]) ~~ 0.
+	anySema := (readSemaphoreArray findFirst:[:sema | sema notNil]) ~~ 0.
-anySema ifFalse:[
+	anySema ifFalse:[
-anySema := (writeSemaphoreArray findFirst:[:sema | sema notNil]) ~~ 0.
+	    anySema := (writeSemaphoreArray findFirst:[:sema | sema notNil]) ~~ 0.
-].
+	].
-anySema ifFalse:[
+	anySema ifFalse:[
-self anyUserProcessAtAll ifFalse:[
+	    self anyUserProcessAtAll ifFalse:[
-dispatching := false.
+		dispatching := false.
-^ self
+		^ self
-]
+	    ]
-].
+	].
 ].
 "/
 "/ absolutely nothing to do - simply wait
 "/
 OperatingSystem supportsSelect ifFalse:[
-"SCO instant ShitStation has a bug here,
+	"SCO instant ShitStation has a bug here,
-waiting always 1 sec in the select - therefore we delay a bit and
+	 waiting always 1 sec in the select - therefore we delay a bit and
-return - effectively polling in 50ms cycles
+	 return - effectively polling in 50ms cycles
-"
+	"
-(self checkForInputWithTimeout:0) ifTrue:[
+	(self checkForInputWithTimeout:0) ifTrue:[
-^ self  "go back checking"
+	    ^ self  "go back checking"
-].
+	].
-OperatingSystem millisecondDelay:EventPollingInterval.
+	OperatingSystem millisecondDelay:EventPollingInterval.
-^ self
+	^ self
 ].
 useIOInterrupts ifTrue:[
-dT := 999999
+	dT := 999999
 ] ifFalse:[
-dT := EventPollingInterval
+	dT := EventPollingInterval
 ].
 millis isNil ifTrue:[
-millis := dT.
+	millis := dT.
 ] ifFalse:[
-millis := millis rounded min:dT.
+	millis := millis rounded min:dT.
 ].
 self checkForInputWithTimeout:millis
 "Modified: 14.12.1995 / 13:37:46 / stefan"
 "Modified: 18.7.1996 / 20:42:17 / cg"
 ! !
 !ProcessorScheduler class methodsFor:'documentation'!
 version
-^ '$Header: /cvs/stx/stx/libbasic/ProcessorScheduler.st,v 1.195 2001-12-06 08:52:25 cg Exp $'
+^ '$Header: /cvs/stx/stx/libbasic/ProcessorScheduler.st,v 1.196 2002-02-04 14:31:14 cg Exp $'
 ! !
 ProcessorScheduler initialize!

changeset 6376	6a3ce5694cc9
parent 6260	cafdfa333832
child 6421	58dca33cf0fc