Packages October 2023

packages@lists.squeakfoundation.org

1 participants
116 discussions

The Treated Inbox: Tests-jar.466.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of Tests to project The Treated Inbox: http://source.squeak.org/treated/Tests-jar.466.mcz ==================== Summary ==================== Name: Tests-jar.466 Author: jar Time: 31 May 2021, 11:29:34.089017 pm UUID: 3f2953a1-9d10-a044-88af-c9019346c388 Ancestors: Tests-jar.463 Add a set of tests for nested unwind semantics during termination. Complement latest #terminate in the Inbox. Supersede Tests-jar.465 - add a small improvement - terminate from a helper process =============== Diff against Tests-jar.463 =============== Item was added: + TestCase subclass: #ProcessTerminateUnwindTests + instanceVariableNames: '' + classVariableNames: '' + poolDictionaries: '' + category: 'Tests-Exceptions'! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminateEnsureAsTopContext (in category 'tests') ----- + testTerminateEnsureAsTopContext + "Test #ensure unwind block is executed even when #ensure context is on stack's top." + + | p1 p2 p3 x1 x2 x3 | + x1 := x2 := x3 := false. + + "p1 is at the beginning of the ensure block and the unwind block hasn't run yet" + p1 := Process + forBlock: [[] ensure: [x1 := x1 not]] + runUntil: [:ctx | ctx isUnwindContext and: [(ctx tempAt: 2) isNil]]. + + "p2 has already set complete to true (tempAt: 2) but the unwind block hasn't run yet" + p2 := Process + forBlock: [[] ensure: [x2 := x2 not]] + runUntil: [:ctx | ctx isUnwindContext and: [(ctx tempAt: 2) notNil]]. + + "p3 has already set complete to true AND the unwind block has run already run; + we have to verify the unwind block is not executed again during termination" + p3 := Process + forBlock: [[] ensure: [x3 := x3 not]] + runUntil: [:ctx | ctx isUnwindContext and: [ctx willReturn]]. + + "make sure all processes are running and only the p3's unwind block has finished" + self deny: p1 isTerminated | p2 isTerminated | p3 isTerminated. + self deny: x1 | x2. + self assert: x3. "p3 has already run its unwind block; we test it won't run it again" + "terminate all processes and verify all unwind blocks have finished correctly" + p1 terminate. p2 terminate. p3 terminate. + self assert: p1 isTerminated & p2 isTerminated & p3 isTerminated. + self assert: x1 & x2 & x3! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind1 (in category 'tests') ----- + testTerminationDuringNestedUnwind1 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind2 (in category 'tests') ----- + testTerminationDuringNestedUnwind2 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind3 (in category 'tests') ----- + testTerminationDuringNestedUnwind3 + "Terminate runnable process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [Processor yield] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is runnable and none of the unwind blocks has finished yet" + self assert: p isRunnable. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind4 (in category 'tests') ----- + testTerminationDuringNestedUnwind4 + "Terminate runnable process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + Processor yield. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isRunnable. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind5 (in category 'tests') ----- + testTerminationDuringNestedUnwind5 + "Terminate active process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [Processor activeProcess terminate] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p suspended itself and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now let the termination continue and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind6 (in category 'tests') ----- + testTerminationDuringNestedUnwind6 + "Terminate active process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + Processor activeProcess terminate. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p suspended itself and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now let the termination continue and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind7 (in category 'tests') ----- + testTerminationDuringNestedUnwind7 + "Terminate blocked process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 semaphore | + x1 := x2 := x3 := x4 := false. + semaphore := Semaphore new. + p := + [ + [ + [ ] ensure: [ + [semaphore wait] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is runnable and none of the unwind blocks has finished yet" + self assert: p isBlocked. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwind8 (in category 'tests') ----- + testTerminationDuringNestedUnwind8 + "Terminate blocked process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 semaphore | + x1 := x2 := x3 := x4 := false. + semaphore := Semaphore new. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + semaphore wait. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is runnable and none of the unwind blocks has finished yet" + self assert: p isBlocked. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn1 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn1 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true. return value]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x3. + self deny: x2 & x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn2 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn2 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true. return value]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x3. + self deny: x2 & x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn3 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn3 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true. return value] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn4 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn4 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true. return value] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn5 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn5 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true. return value]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn6 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn6 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true. return value]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn7 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn7 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. return value. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: ProcessTerminateUnwindTests>>testTerminationDuringNestedUnwindWithReturn8 (in category 'tests') ----- + testTerminationDuringNestedUnwindWithReturn8 + "Terminate suspended process. + Test all nested unwind blocks are correctly unwound; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. return value. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + [p terminate] forkAt: Processor activePriority + 1. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.!

1 0

The Treated Inbox: KernelTests-jar.432.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Treated Inbox: http://source.squeak.org/treated/KernelTests-jar.432.mcz ==================== Summary ==================== Name: KernelTests-jar.432 Author: jar Time: 6 June 2022, 11:57:50.959098 pm UUID: 7ac20a02-7d4d-fb48-9586-14ab9844b799 Ancestors: KernelTests-jar.431 Three more Process tests: non-local returns and another test case for terminating a process that has already started unwinding. Hope this is all. =============== Diff against KernelTests-jar.431 =============== Item was added: + ----- Method: ProcessTest>>testTerminateTerminatingProcessInUnwindTo (in category 'tests') ----- + testTerminateTerminatingProcessInUnwindTo + "Terminating a terminatee process after the terminator process restarted the terminatee + process should unwind the terminatee process and let the terminator process terminate." + + | terminator terminatee unwound | + unwound := false. + terminatee := [[Semaphore new wait] ensure: [unwound := true]] fork. + Processor yield. + terminator := [terminatee terminate] newProcess. + self assert: terminatee isBlocked. + self assert: terminator isSuspended. + terminator runUntil: [:ctx | ctx selectorToSendOrSelf = #resume]. + "terminator steps until terminatee's unwind context is set" + terminator suspendedContext nextInstruction. "skip terminatee resume instruction" + terminator resume. "and run until parked at wait" + terminatee runUntil: [:ctx | ctx selectorToSendOrSelf = #unwindTo:]. + "terminatee steps until at #unwindTo:" + self assert: terminatee isSuspended. + terminatee terminate. + self assert: terminatee isTerminated. + self assert: unwound. + self assert: terminator isTerminated! Item was added: + ----- Method: ProcessUnwindTest>>testTerminateNestedEnsureWithReturn1 (in category 'tests') ----- + testTerminateNestedEnsureWithReturn1 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + "While testTerminateInNestedEnsureWithReturn1 to 8 start unwinding + from inside a halfways through unwind block, this test (and the next) start + the unwind from outside any ensure argument (aka unwind) block, testing + the second half of the #unwindTo:safely: method." + + | p x1 x2 x3 x4 x5 | + x1 := x2 := x3 := x4 := x5 := false. + p := + [ + [:return | + [ Processor activeProcess suspend. + [ ] ensure: [ + [ ] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + return value. + x3 := true]. + x4 := true. + ] valueWithExit. + x5 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4 | x5. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self deny: x1 & x2 & x3 & x4 & x5! Item was added: + ----- Method: ProcessUnwindTest>>testTerminateNestedEnsureWithReturn2 (in category 'tests') ----- + testTerminateNestedEnsureWithReturn2 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 x5 | + x1 := x2 := x3 := x4 := x5 := false. + p := + [ + [:return | + [ + [Processor activeProcess suspend] ensure: [ + [ ] ensure: [ + x1 := true]. + return value. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit. + x5 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4 | x5. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self deny: x1 & x2 & x3 & x4 & x5!

1 0

The Treated Inbox: KernelTests-jar.431.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Treated Inbox: http://source.squeak.org/treated/KernelTests-jar.431.mcz ==================== Summary ==================== Name: KernelTests-jar.431 Author: jar Time: 6 June 2022, 4:26:06.000182 pm UUID: 1c79cb69-dd24-6440-917f-0d3142fd4a17 Ancestors: KernelTests-jar.430 One more Process test; this verifies that if a terminating process gets stopped and terminated again, all unwinds execute correctly and the original terminator process terminates as well. Such a situation may occur e.g. when a terminating process encounters an error and opens a debugger (or calls another recovery machinery). In such case it's legitimate to terminate the terminating process again (by closing the debugger or as a termination by another recovery tool). Note: it's a different situation than in 'testTerminateTerminatingProcess' where the second termination is invoked "too early" and may cause unpredictable outcome - that test is still WIP. Add testTerminateWithDelayInUnwind to the expectedFailures for the moment. Adopting #teminate for that scenario is WIP. =============== Diff against KernelTests-jar.430 =============== Item was changed: ----- Method: ProcessTest>>expectedFailures (in category 'failures') ----- expectedFailures + ^ #(testTerminateTerminatingProcess testResumeTerminatingProcess testTerminateWithDelayInUnwind)! - ^ #(testTerminateTerminatingProcess testResumeTerminatingProcess)! Item was added: + ----- Method: ProcessTest>>testTerminateTerminatingProcessAfterUnwindStarted (in category 'tests') ----- + testTerminateTerminatingProcessAfterUnwindStarted + "Terminating a terminatee process after the terminator process restarted the terminatee + process should unwind the terminatee process and let the terminator process terminate." + + "Such a situation may occur e.g. when a terminating process encounters an error and + opens a debugger (or calls another recovery machinery). In such case it's legitimate + to terminate the terminating process again (by closing the debugger or as a termination + by another recovery tool). + + Note: this is a different situation than in 'testTerminateTerminatingProcess' where + the second termination is invoked 'too early' and may cause unpredictable outcome." + + | terminator terminatee unwound unwindBlock | + unwound := false. + unwindBlock := [Processor activeProcess suspend. unwound := true]. + terminatee := [[Semaphore new wait] ensure: unwindBlock] fork. + Processor yield. + terminator := [terminatee terminate] newProcess. + self assert: terminatee isBlocked. + self assert: terminator isSuspended. + terminator resume. + Processor yield. + "terminator starts terminatee's unwind" + Processor yield. + "terminatee resumes and stops at unwindBlock's #suspend" + self assert: terminatee isSuspended. + terminatee terminate. + self assert: terminatee isTerminated. + self assert: unwound. + self assert: terminator isTerminated!

1 0

The Treated Inbox: KernelTests-jar.430.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Treated Inbox: http://source.squeak.org/treated/KernelTests-jar.430.mcz ==================== Summary ==================== Name: KernelTests-jar.430 Author: jar Time: 5 June 2022, 11:11:12.187824 pm UUID: 209031e0-7bc5-984a-94dd-b3c3a24216c3 Ancestors: KernelTests-jar.429 Oops, fix comment in previous test KernelTests-jar.429... Sorry for the noise. =============== Diff against KernelTests-jar.429 =============== Item was changed: ----- Method: ProcessTest>>testTerminateHandlingUnwindError (in category 'tests') ----- testTerminateHandlingUnwindError "Test an error inside an unwind block is handled correctly." "Workspace example: [ [[Processor activeProcess terminate] ensure: [1/0]] on: ZeroDivide do: [] ] fork ZeroDivide error should get caught by the handler without opening the Debugger. To model this example as a test case we have to keep in mind that an error signal in one thread cannot be caught in a different thread: if process 'p' signals an error it won't be searching for a handler in the thread that sent 'p terminate' message. So we can't do something like: + p := [ [ [Semaphore new wait] ensure: [1/0] ] on: ZeroDivide do: [] ] fork. - p := [ [ [Semaphore new wait] ensure: unwindBlock ] on: ZeroDivide do: [] ] fork. Processor yield. self shouldnt: [p terminate] raise: Error Instead, in order to catch the situation the ZeroDivide error is not caught within 'p', we try to catch the UnhandledError raised in 'p' indicating the ZeroDivide has been missed. " | p error unwindBlock | unwindBlock := [[1/0] on: UnhandledError do: [error := true]]. p := [ [ [Semaphore new wait] ensure: unwindBlock ] on: ZeroDivide do: [] ] fork. Processor yield. self assert: p isBlocked. error := false. p terminate. self deny: error. self assert: p isTerminated!

1 0

The Treated Inbox: KernelTests-jar.429.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Treated Inbox: http://source.squeak.org/treated/KernelTests-jar.429.mcz ==================== Summary ==================== Name: KernelTests-jar.429 Author: jar Time: 5 June 2022, 7:16:44.422705 pm UUID: 39150694-f022-7643-83f7-b548fb60b03a Ancestors: KernelTests-jar.428 One more process test to check correct handling of unwind error (errors signaled inside unwind blocks during termination). =============== Diff against KernelTests-jar.428 =============== Item was added: + ----- Method: ProcessTest>>testTerminateHandlingUnwindError (in category 'tests') ----- + testTerminateHandlingUnwindError + "Test an error inside an unwind block is handled correctly." + + "Workspace example: + [ [[Processor activeProcess terminate] ensure: [1/0]] on: ZeroDivide do: [] ] fork + + ZeroDivide error should get caught by the handler without opening the Debugger. + + To model this example as a test case we have to keep in mind that an error signal + in one thread cannot be caught in a different thread: if process 'p' signals an error + it won't be searching for a handler in the thread that sent 'p terminate' message. + So we can't do something like: + p := [ [ [Semaphore new wait] ensure: unwindBlock ] on: ZeroDivide do: [] ] fork. + Processor yield. + self shouldnt: [p terminate] raise: Error + Instead, in order to catch the situation the ZeroDivide error is not caught within 'p', + we try to catch the UnhandledError raised in 'p' indicating the ZeroDivide has been + missed. " + + | p error unwindBlock | + unwindBlock := [[1/0] on: UnhandledError do: [error := true]]. + p := [ [ [Semaphore new wait] ensure: unwindBlock ] on: ZeroDivide do: [] ] fork. + Processor yield. + self assert: p isBlocked. + error := false. + p terminate. + self deny: error. + self assert: p isTerminated!

1 0

The Treated Inbox: KernelTests-jar.428.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Treated Inbox: http://source.squeak.org/treated/KernelTests-jar.428.mcz ==================== Summary ==================== Name: KernelTests-jar.428 Author: jar Time: 4 June 2022, 9:41:34.150893 pm UUID: d1cbb552-07ab-1b41-a4e1-058eccf13b97 Ancestors: KernelTests-jar.427 More Process and Semaphore tests. These explore boundary scenarios like termination of process with suspendedContext = nil, or with just a single ensure context, or with two ensure contexts directly on top of each other, or a process running at the highest priority etc. These scenarios bit me when working on #terminate so let's share them. One of the tests: 'testTerminateWithDelayInUnwind' will require a small update of #terminate I'll be sending later today. A process that invokes termination of another process is expected to wait until the terminating process finishes unwinding itself. A delay or yield inside unwind blocks may cause control be handed over to the original process which may be assuming the termination has finished. This scenario will have been fixed in the above mentioned #terminate update. =============== Diff against KernelTests-jar.427 =============== Item was added: + ----- Method: ProcessTest>>testTerminateByHighestPriorityProcess (in category 'tests') ----- + testTerminateByHighestPriorityProcess + "Test temination by a highest priority process." + + "Note: #terminate elevates the priority of the terminating process + and has to make sure it doesn't exceed the highest priority. + Workspace example: + q := [Semaphore new wait] fork. + p := [q terminate] forkAt: Processor highestPriority. + q isTerminated + + We have to catch the 'Invalid priority' error via the 'error' variable + because #shouldnt:raise: doesn't work between two processes." + + | p q error | + p := [Semaphore new wait] fork. + Processor yield. + self assert: p isBlocked. + error := false. + q := [[p terminate] on: Error do: [error := true]] newProcess. + q priority: Processor highestPriority. + q resume. + self deny: error. + self assert: p isTerminated. + self assert: q isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateEnsureOnTopOfEnsure (in category 'tests') ----- + testTerminateEnsureOnTopOfEnsure + "Test two ensure contexts on top of each other unwind correctly, + that both their unwind blocks get executed." + + | beenHere beenHereToo bottom p top | + beenHere := beenHereToo := false. + bottom := Context contextEnsure: [beenHereToo := true]. + top := Context contextEnsure: [Processor activeProcess suspend. beenHere := true]. + top privSender: bottom. + p := Process forContext: top priority: Processor activeProcess priority. + p resume. + Processor yield. + self assert: p isSuspended. + p terminate. + self assert: beenHere & beenHereToo. + self assert: p isTerminated + + ! Item was added: + ----- Method: ProcessTest>>testTerminateHighestPriorityProcess (in category 'tests') ----- + testTerminateHighestPriorityProcess + "Test termination of a highest priority process." + + | p | + p := [Semaphore new wait] forkAt: Processor highestPriority. + Processor yield. + self assert: p isBlocked. + p terminate. + self assert: p isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateNiledSuspendedContextProcess (in category 'tests') ----- + testTerminateNiledSuspendedContextProcess + "Test a process with niled suspendedContext terminates correctly." + + | p | + p := [] newProcess. + self assert: p isSuspended. + p suspendedContext: nil. + p terminate. + self assert: p isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateSingleEnsure (in category 'tests') ----- + testTerminateSingleEnsure + "Test a stack consisting of a single ensure context unwinds correctly." + + | beenHere p singleton | + beenHere := false. + singleton := Context contextEnsure: [beenHere := true]. + p := Process forContext: singleton priority: Processor activeProcess priority. + self assert: p isSuspended. + self assert: p suspendedContext sender isNil. + p terminate. + self assert: beenHere. + self assert: p isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateWithDelayInUnwind (in category 'tests') ----- + testTerminateWithDelayInUnwind + "Test the process that invoked the termination of another process waits + for the other process to finish unwinding." + + "Insert delay into the unwind block to force rescheduling; alternatively, + 'Processor yield' could be used instead of 'delay wait'." + + | delay p | + delay := Delay forMilliseconds: 10. + p := [[Processor activeProcess suspend] ensure: [delay wait]] fork. + Processor yield. + self assert: p isSuspended. + p terminate. + self assert: p isTerminated! Item was added: + ----- Method: SemaphoreTest>>testSemaAfterCriticalWaitSuspended (in category 'tests') ----- + testSemaAfterCriticalWaitSuspended "self run: #testSemaAfterCriticalWaitSuspended" + "This tests whether a semaphore that has just left the wait in Semaphore>>critical: but + has been suspended before termination, leaves it with signaling the associated semaphore." + | s p | + s := Semaphore new. + p := [s critical:[]] forkAt: Processor activePriority-1. + "wait until p entered the critical section" + [p suspendingList == s] whileFalse:[(Delay forMilliseconds: 10) wait]. + "Now that p entered it, signal the semaphore. p now 'owns' the semaphore + but since we are running at higher priority than p it will not get to do + anything." + s signal. + self assert: p suspendingList class == LinkedList. + p suspend. + self assert: p suspendingList == nil. + p terminate. + self assert: 1 equals: s excessSignals!

1 0

The Treated Inbox: KernelTests-jar.427.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Treated Inbox: http://source.squeak.org/treated/KernelTests-jar.427.mcz ==================== Summary ==================== Name: KernelTests-jar.427 Author: jar Time: 3 June 2022, 9:16:06.853526 pm UUID: d09440fa-7ddf-4144-be3f-0cf1bb61e512 Ancestors: KernelTests-jar.426 Improve comment for KernelTests-jar.426 =============== Diff against KernelTests-jar.426 =============== Item was changed: ----- Method: ProcessTest>>testPrioritySetBeforeSuspendedContext (in category 'tests') ----- testPrioritySetBeforeSuspendedContext "Test whether priority is set before suspendedContext during process creation." "Setting priority after causes an endless stream of error windows when debugging e.g. [] newProcess when Process Browser is open with auto-update on. Once the suspendedContext is set, the new process is no longer considered terminated and Process Browser will try to place it in its list of processes but encounters a nil error when reading its priority because it has not been set yet." | p inside | inside := false. p := [inside := true. [] newProcess] newProcess. p runUntil: [:ctx | inside]. p runUntil: [:ctx | ctx selectorToSendOrSelf = #suspendedContext:]. + "Now p is before assigning suspendedContext in Process class >> forContext:priority: + tempAt: 3 is the local variable 'newProcess' representing the newly created process; + verify whether the new process's priority has already been set." self assert: (p suspendedContext tempAt: 3) priority notNil!

1 0

The Treated Inbox: KernelTests-jar.426.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Treated Inbox: http://source.squeak.org/treated/KernelTests-jar.426.mcz ==================== Summary ==================== Name: KernelTests-jar.426 Author: jar Time: 3 June 2022, 7:13:06.751641 pm UUID: 60821aa1-f749-134e-922d-e9588194888c Ancestors: KernelTests-mt.425 Test whether priority is set before suspendedContext during process creation. Complements Kernel-jar.1473 Setting priority after causes an endless stream of error windows when debugging e.g. [] newProcess when Process Browser is open with auto-update on. Once the suspendedContext is set, the new process is no longer considered terminated and Process Browser will try to place it in its list of processes but encounters a nil error when reading its priority because it has not been set yet." =============== Diff against KernelTests-mt.425 =============== Item was added: + ----- Method: ProcessTest>>testPrioritySetBeforeSuspendedContext (in category 'tests') ----- + testPrioritySetBeforeSuspendedContext + "Test whether priority is set before suspendedContext during process creation." + + "Setting priority after causes an endless stream of error windows when debugging e.g. + [] newProcess + when Process Browser is open with auto-update on. + + Once the suspendedContext is set, the new process is no longer considered terminated + and Process Browser will try to place it in its list of processes but encounters a nil error + when reading its priority because it has not been set yet." + + | p inside | + inside := false. + p := [inside := true. [] newProcess] newProcess. + p runUntil: [:ctx | inside]. + p runUntil: [:ctx | ctx selectorToSendOrSelf = #suspendedContext:]. + self assert: (p suspendedContext tempAt: 3) priority notNil!

1 0

The Trunk: KernelTests-jar.423.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Trunk: http://source.squeak.org/trunk/KernelTests-jar.423.mcz ==================== Summary ==================== Name: KernelTests-jar.423 Author: jar Time: 29 May 2022, 4:27:14.426063 pm UUID: 20a7b2ce-4161-674d-abd4-e80376bf00f3 Ancestors: KernelTests-nice.422 Update a battery of tests to complement Kernel-jar.1468 and Kernel-jar.1469 (revised suspend and terminate semantics and termination fixes). The update adjusts some tests for the revised suspend, plus adds some more. A few tests will be parked as expected failures as a reminder :) Supersede KernelTests-jar.421; please remove it from the Inbox. =============== Diff against KernelTests-nice.422 =============== Item was added: + ----- Method: MutexTest>>expectedFailures (in category 'failures') ----- + expectedFailures + + ^ #(testUnwindMutexBlockedInCritical)! Item was added: + ----- Method: MutexTest>>testMutexInCriticalEnsureArgument (in category 'tests') ----- + testMutexInCriticalEnsureArgument "self run: #testMutexInCriticalEnsureArgument" + "This tests whether a process that is in the ensure argument block in critical: but has yet to evaluate the primitiveExitCriticalSection + leaves it with the mutex unlocked." + + | terminatee mutex | + mutex := Mutex new. + terminatee := [mutex critical: []] newProcess. + self assert: terminatee isSuspended. + terminatee runUntil: [:ctx | ctx selectorToSendOrSelf = #primitiveExitCriticalSection]. + self assert: terminatee isSuspended. + terminatee terminate. + self deny: mutex isOwned. + self assert: mutex isEmpty! Item was added: + ----- Method: MutexTest>>testUnwindMutexBlockedInCritical (in category 'tests') ----- + testUnwindMutexBlockedInCritical "self run: #testMutexBlockedInCritical" + "This tests whether a mutex that is inside the primitiveEnterCriticalSection in Mutex>>critical: + leaves it unchanged." + | lock sock proc wait | + lock := Mutex new. + sock := Semaphore new. + proc := [lock critical: [sock wait]] fork. + wait := [[] ensure: [lock critical: []]] fork. + Processor yield. + self assert: proc suspendingList == sock. + self assert: wait suspendingList == lock. + self deny: lock isEmpty. + self assert: lock isOwned. + wait terminate. + Processor yield. + self assert: wait isTerminated. + self assert: proc suspendingList == sock. + self assert: wait suspendingList == nil. + self assert: lock isEmpty. + self assert: lock isOwned + ! Item was changed: ----- Method: Process>>suspendPrimitivelyOrFail (in category '*KernelTests-Processes') ----- suspendPrimitivelyOrFail + "Test support. Execute primitive 578, or fail." - "Test support. Execute primitive 88, or fail." + <primitive: 578> - <primitive: 88> ^self primitiveFailed! Item was added: + ----- Method: ProcessTest>>expectedFailures (in category 'failures') ----- + expectedFailures + + ^ #(testTerminateTerminatingProcess testResumeTerminatingProcess)! Item was changed: ----- Method: ProcessTest>>testAtomicSuspend (in category 'tests') ----- testAtomicSuspend + "Test atomic suspend of foreign processes. + Note: this test will fail when run with older VMs without primitive suspend 578." - "Test atomic suspend of foreign processes" | list p | p := [semaphore wait] fork. Processor yield. list := p suspendPrimitivelyOrFail. + self assert: list == nil. - self assert: list == semaphore. ! Item was added: + ----- Method: ProcessTest>>testResumeTerminatingProcess (in category 'tests') ----- + testResumeTerminatingProcess + "An attempt to resume a terminating process should probably raise an error; + leave this test as an expected failure for the moment." + + | terminatee terminator resumed semaphore | + semaphore := Semaphore new. + terminatee := [semaphore critical:[]. resumed := true] fork. + Processor yield. + terminator := [terminatee terminate] newProcess. + self assert: terminatee suspendingList == semaphore. + self assert: terminator isSuspended. + "run terminator and stop inside #terminate" + terminator runUntil: [:ctx | ctx selectorToSendOrSelf = #priority:]. + self assert: terminator isSuspended. + "resume the terminatee process and and check if the VM raises an error; + an error is expected because terminatee's suspendedContext equals nil" + self should: [terminatee resume] raise: Error. + "now let the terminator finish terminating the terminatee process" + terminator resume. + Processor yield. + self assert: resumed isNil. + self assert: terminatee isTerminated. + self assert: terminator isTerminated! Item was added: + ----- Method: ProcessTest>>testRevisedSuspendExpectations (in category 'tests') ----- + testRevisedSuspendExpectations + "Test revised suspend expectations vs. pre-2022 VM's suspend" + + | s p list | + s := Semaphore new. + p := [s critical:[]] forkAt: Processor activePriority + 1. + list := p suspend. + + Smalltalk processSuspensionUnblocks + ifFalse: [ + self assert: p suspendingList equals: nil. + self assert: list equals: nil. + self deny: p suspendedContext selectorJustSentOrSelf equals: #wait + ] + ifTrue: [ + self assert: p suspendingList equals: nil. + self assert: list equals: s. + self assert: p suspendedContext selectorJustSentOrSelf equals: #wait + ]! Item was added: + ----- Method: ProcessTest>>testTerminateEnsureAsStackTop (in category 'tests') ----- + testTerminateEnsureAsStackTop + "Test #ensure unwind block is executed even when #ensure context is on stack's top." + + | p1 p2 p3 x1 x2 x3 | + x1 := x2 := x3 := false. + + "p1 is at the beginning of the ensure block and the unwind block hasn't run yet" + p1 := Process + forBlock: [[] ensure: [x1 := x1 not]] + runUntil: [:ctx | ctx isUnwindContext and: [(ctx tempAt: 2) isNil]]. + p1 step. p1 step. "move the pc behind the send: valueNoContextSwitch instruction" + + "p2 has already set complete to true (tempAt: 2) but the unwind block hasn't run yet" + p2 := Process + forBlock: [[] ensure: [x2 := x2 not]] + runUntil: [:ctx | ctx isUnwindContext and: [(ctx tempAt: 2) notNil]]. + + "p3 has already set complete to true AND the unwind block has already run; + we have to verify the unwind block is not executed again during termination" + p3 := Process + forBlock: [[] ensure: [x3 := x3 not]] + runUntil: [:ctx | ctx isUnwindContext and: [ctx willReturn]]. + + "make sure all processes are running and only the p3's unwind block has finished" + self deny: p1 isTerminated | p2 isTerminated | p3 isTerminated. + self deny: x1 | x2. + self assert: x3. "p3 has already run its unwind block; we test it won't run it again" + "terminate all processes and verify all unwind blocks have finished correctly" + p1 terminate. p2 terminate. p3 terminate. + self assert: p1 isTerminated & p2 isTerminated & p3 isTerminated. + self assert: x1 & x2 & x3! Item was added: + ----- Method: ProcessTest>>testTerminateInTerminate (in category 'tests') ----- + testTerminateInTerminate + "Terminating a terminator process should unwind both the terminator and its terminatee process" + + | terminator terminatee unwound | + unwound := false. + terminatee := [[Processor activeProcess suspend] ensure: [unwound := true]] fork. + Processor yield. + terminator := [terminatee terminate] newProcess. + self assert: terminatee isSuspended. + self assert: terminator isSuspended. + "run terminator and stop inside #terminate" + terminator runUntil: [:ctx | ctx selectorToSendOrSelf = #priority:]. + self assert: terminator isSuspended. + terminator terminate. + self assert: terminator isTerminated. + self assert: unwound! Item was added: + ----- Method: ProcessTest>>testTerminateTerminatingProcess (in category 'tests') ----- + testTerminateTerminatingProcess + "An attempt to terminate a terminating process should probably raise an error; + leave this test as an expected failure for the moment." + + | terminatee terminator resumed semaphore | + semaphore := Semaphore new. + terminatee := [semaphore critical:[]. resumed := true] fork. + Processor yield. + terminator := [terminatee terminate] newProcess. + self assert: terminatee suspendingList == semaphore. + self assert: terminator isSuspended. + "run terminator and stop inside #terminate" + terminator runUntil: [:ctx | ctx selectorToSendOrSelf = #priority:]. + self assert: terminator isSuspended. + "terminate the terminatee process again and let the termination finish; + an error is expected because #terminate detected multiple termination" + self should: [terminatee terminate] raise: Error. + "now let the terminator finish terminating the terminatee process" + terminator resume. + Processor yield. + self assert: resumed isNil. + self assert: terminatee isTerminated. + self assert: terminator isTerminated! Item was added: + ----- Method: SemaphoreTest>>expectedFailures (in category 'failures') ----- + expectedFailures + + ^ #(testUnwindSemaInCriticalWait)! Item was added: + ----- Method: SemaphoreTest>>testSemaInCriticalEnsureArgument (in category 'tests') ----- + testSemaInCriticalEnsureArgument "self run: #testSemaInCriticalEnsureArgument" + "This tests whether a process that is in ensure argument block but has yet to evaluate the signal + leaves it with signaling the associated semaphore." + + | terminatee sema | + sema := Semaphore forMutualExclusion. + terminatee := [sema critical: []] newProcess. + self assert: terminatee isSuspended. + terminatee runUntil: [:ctx | ctx selectorToSendOrSelf = #signal]. + self assert: terminatee isSuspended. + terminatee terminate. + self assert: terminatee isTerminated. + self assert: sema excessSignals = 1 ! Item was added: + ----- Method: SemaphoreTest>>testUnwindSemaInCriticalWait (in category 'tests') ----- + testUnwindSemaInCriticalWait "self run: #testSemaInCriticalWait" + "This tests whether a semaphore that has entered the wait in Semaphore>>critical: + leaves it without signaling the associated semaphore." + | s p | + s := Semaphore new. + p := [[] ensure: [s critical:[]]] fork. + Processor yield. + self assert:(p suspendingList == s). + p terminate. + self assert: 0 equals: s excessSignals! Item was added: + ProcessTest subclass: #UnwindTest + instanceVariableNames: '' + classVariableNames: '' + poolDictionaries: '' + category: 'KernelTests-Processes'! Item was added: + ----- Method: UnwindTest>>testTerminateActiveInNestedEnsure1 (in category 'tests') ----- + testTerminateActiveInNestedEnsure1 + "Terminate active process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [Processor activeProcess terminate] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateActiveInNestedEnsure2 (in category 'tests') ----- + testTerminateActiveInNestedEnsure2 + "Terminate active process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + Processor activeProcess terminate. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateBlockedInNestedEnsure1 (in category 'tests') ----- + testTerminateBlockedInNestedEnsure1 + "Terminate blocked process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [semaphore wait] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is blocked and none of the unwind blocks has finished yet" + self assert: p isBlocked. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateBlockedInNestedEnsure2 (in category 'tests') ----- + testTerminateBlockedInNestedEnsure2 + "Terminate blocked process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + semaphore wait. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is blocked and none of the unwind blocks has finished yet" + self assert: p isBlocked. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn1 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn1 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true. return value]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x3. + self deny: x2 & x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn2 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn2 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true. return value]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x3. + self deny: x2 & x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn3 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn3 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true. return value] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn4 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn4 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true. return value] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn5 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn5 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true. return value]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn6 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn6 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true. return value]. + x4 := true. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn7 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn7 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. return value. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateInNestedEnsureWithReturn8 (in category 'tests') ----- + testTerminateInNestedEnsureWithReturn8 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [:return | + [ + [ ] ensure: [ + [] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. return value. + ] valueWithExit + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateRunnableInNestedEnsure1 (in category 'tests') ----- + testTerminateRunnableInNestedEnsure1 + "Terminate runnable process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [Processor yield] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is runnable and none of the unwind blocks has finished yet" + self assert: p isRunnable. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateRunnableInNestedEnsure2 (in category 'tests') ----- + testTerminateRunnableInNestedEnsure2 + "Terminate runnable process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + Processor yield. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is runnable and none of the unwind blocks has finished yet" + self assert: p isRunnable. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateSuspendedInNestedEnsure1 (in category 'tests') ----- + testTerminateSuspendedInNestedEnsure1 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [Processor activeProcess suspend] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.! Item was added: + ----- Method: UnwindTest>>testTerminateSuspendedInNestedEnsure2 (in category 'tests') ----- + testTerminateSuspendedInNestedEnsure2 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 | + x1 := x2 := x3 := x4 := false. + p := + [ + [ + [ ] ensure: [ + [ ] ensure: [ + Processor activeProcess suspend. + x1 := true]. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self assert: x1 & x2 & x3. + self deny: x4.!

1 0

The Trunk: KernelTests-jar.433.mcz
by commits＠source.squeak.org 11 Oct '23

11 Oct '23

Marcel Taeumel uploaded a new version of KernelTests to project The Trunk: http://source.squeak.org/trunk/KernelTests-jar.433.mcz ==================== Summary ==================== Name: KernelTests-jar.433 Author: jar Time: 7 June 2022, 6:24:58.053964 pm UUID: b2a35851-6470-a643-9f6f-e939501100b6 Ancestors: KernelTests-mt.425 Bundle together all new Process and Semaphore tests from: KernelTests-jar.431, 432 (multiple termination and NLR) KernelTests-jar.429, 430 (unwind errors test) KernelTests-jar.428 (more tests) KernelTests-jar.426, 427 (priority before suspendedContext) Complements Kernel-jar.1476 (updated terminate with sync) and Kernel-jar.1473 (priority set before suspendedContext). Please remove the individual changesets from the Inbox. =============== Diff against KernelTests-mt.425 =============== Item was added: + ----- Method: ProcessTest>>testPrioritySetBeforeSuspendedContext (in category 'tests') ----- + testPrioritySetBeforeSuspendedContext + "Test whether priority is set before suspendedContext during process creation." + + "Setting priority after causes an endless stream of error windows when debugging e.g. + [] newProcess + when Process Browser is open with auto-update on. + + Once the suspendedContext is set, the new process is no longer considered terminated + and Process Browser will try to place it in its list of processes but encounters a nil error + when reading its priority because it has not been set yet." + + | p inside | + inside := false. + p := [inside := true. [] newProcess] newProcess. + p runUntil: [:ctx | inside]. + p runUntil: [:ctx | ctx selectorToSendOrSelf = #suspendedContext:]. + "Now p is before assigning suspendedContext in Process class >> forContext:priority: + tempAt: 3 is the local variable 'newProcess' representing the newly created process; + verify whether the new process's priority has already been set." + self assert: (p suspendedContext tempAt: 3) priority notNil! Item was added: + ----- Method: ProcessTest>>testTerminateByHighestPriorityProcess (in category 'tests') ----- + testTerminateByHighestPriorityProcess + "Test temination by a highest priority process." + + "Note: in case #terminate elevates the priority of the terminating + process it has to make sure it doesn't exceed the highest priority. + Workspace example: + q := [Semaphore new wait] fork. + p := [q terminate] forkAt: Processor highestPriority. + q isTerminated + + We have to catch the 'Invalid priority' error via the 'error' variable + because #shouldnt:raise: doesn't work between two processes." + + | p q error | + p := [Semaphore new wait] fork. + Processor yield. + self assert: p isBlocked. + error := false. + q := [[p terminate] on: Error do: [error := true]] newProcess. + q priority: Processor highestPriority. + q resume. + self deny: error. + self assert: p isTerminated. + self assert: q isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateEnsureOnTopOfEnsure (in category 'tests') ----- + testTerminateEnsureOnTopOfEnsure + "Test two ensure contexts on top of each other unwind correctly, + that both their unwind blocks get executed." + + | beenHere beenHereToo bottom p top | + beenHere := beenHereToo := false. + bottom := Context contextEnsure: [beenHereToo := true]. + top := Context contextEnsure: [Processor activeProcess suspend. beenHere := true]. + top privSender: bottom. + p := Process forContext: top priority: Processor activeProcess priority. + p resume. + Processor yield. + self assert: p isSuspended. + p terminate. + self assert: beenHere & beenHereToo. + self assert: p isTerminated + + ! Item was added: + ----- Method: ProcessTest>>testTerminateHandlingUnwindError (in category 'tests') ----- + testTerminateHandlingUnwindError + "Test an error inside an unwind block is handled correctly." + + "Workspace example: + [ [[Processor activeProcess terminate] ensure: [1/0]] on: ZeroDivide do: [] ] fork + + ZeroDivide error should get caught by the handler without opening the Debugger. + + To model this example as a test case we have to keep in mind that an error signal + in one thread cannot be caught in a different thread: if process 'p' signals an error + it won't be searching for a handler in the thread that sent 'p terminate' message. + So we can't do something like: + p := [ [ [Semaphore new wait] ensure: [1/0] ] on: ZeroDivide do: [] ] fork. + Processor yield. + self shouldnt: [p terminate] raise: Error + Instead, in order to catch the situation the ZeroDivide error is not caught within 'p', + we try to catch the UnhandledError raised in 'p' indicating the ZeroDivide has been + missed. " + + | p error unwindBlock | + unwindBlock := [[1/0] on: UnhandledError do: [error := true]]. + p := [ [ [Semaphore new wait] ensure: unwindBlock ] on: ZeroDivide do: [] ] fork. + Processor yield. + self assert: p isBlocked. + error := false. + p terminate. + self deny: error. + self assert: p isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateHighestPriorityProcess (in category 'tests') ----- + testTerminateHighestPriorityProcess + "Test termination of a highest priority process." + + | p | + p := [Semaphore new wait] forkAt: Processor highestPriority. + Processor yield. + self assert: p isBlocked. + p terminate. + self assert: p isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateNiledSuspendedContextProcess (in category 'tests') ----- + testTerminateNiledSuspendedContextProcess + "Test a process with niled suspendedContext terminates correctly." + + | p | + p := [] newProcess. + self assert: p isSuspended. + p suspendedContext: nil. + p terminate. + self assert: p isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateSingleEnsure (in category 'tests') ----- + testTerminateSingleEnsure + "Test a stack consisting of a single ensure context unwinds correctly." + + | beenHere p singleton | + beenHere := false. + singleton := Context contextEnsure: [beenHere := true]. + p := Process forContext: singleton priority: Processor activeProcess priority. + self assert: p isSuspended. + self assert: p suspendedContext sender isNil. + p terminate. + self assert: beenHere. + self assert: p isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateTerminatingProcessAfterUnwindStarted (in category 'tests') ----- + testTerminateTerminatingProcessAfterUnwindStarted + "Terminating a terminatee process after the terminator process restarted the terminatee + process should unwind the terminatee process and let the terminator process terminate." + + "Such a situation may occur e.g. when a terminating process encounters an error and + opens a debugger (or calls another recovery machinery). In such case it's legitimate + to terminate the terminating process again (by closing the debugger or as a termination + by another recovery tool). + + Note: this is a different situation than in 'testTerminateTerminatingProcess' where + the second termination is invoked 'too early' and may cause unpredictable outcome." + + | terminator terminatee unwound unwindBlock | + unwound := false. + unwindBlock := [Processor activeProcess suspend. unwound := true]. + terminatee := [[Semaphore new wait] ensure: unwindBlock] fork. + Processor yield. + terminator := [terminatee terminate] newProcess. + self assert: terminatee isBlocked. + self assert: terminator isSuspended. + terminator resume. + Processor yield. + "terminator starts terminatee's unwind" + Processor yield. + "terminatee resumes and stops at unwindBlock's #suspend" + self assert: terminatee isSuspended. + terminatee terminate. + self assert: terminatee isTerminated. + self assert: unwound. + Processor yield. + self assert: terminator isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateTerminatingProcessInUnwindTo (in category 'tests') ----- + testTerminateTerminatingProcessInUnwindTo + "Terminating a terminatee process after the terminator process restarted the terminatee + process should unwind the terminatee process and let the terminator process terminate." + + | terminator terminatee unwound | + unwound := false. + terminatee := [[Semaphore new wait] ensure: [unwound := true]] fork. + Processor yield. + terminator := [terminatee terminate] newProcess. + self assert: terminatee isBlocked. + self assert: terminator isSuspended. + terminator runUntil: [:ctx | ctx selectorToSendOrSelf = #resume]. + "terminator steps until terminatee's unwind context is set" + terminator suspendedContext nextInstruction. "skip terminatee resume instruction" + terminator resume. "and run until parked at wait" + terminatee runUntil: [:ctx | ctx selectorToSendOrSelf = #unwindTo:]. + "terminatee steps until at #unwindTo:" + self assert: terminatee isSuspended. + terminatee terminate. + self assert: terminatee isTerminated. + self assert: unwound. + Processor yield. + self assert: terminator isTerminated! Item was added: + ----- Method: ProcessTest>>testTerminateWithDelayInUnwind (in category 'tests') ----- + testTerminateWithDelayInUnwind + "Test the process that invoked the termination of another process waits + for the other process to finish unwinding." + + "Insert delay into the unwind block to force rescheduling; alternatively, + 'Processor yield' could be used instead of 'delay wait'." + + | delay p | + delay := Delay forMilliseconds: 10. + p := [[Processor activeProcess suspend] ensure: [delay wait]] fork. + Processor yield. + self assert: p isSuspended. + p terminate. + self assert: p isTerminated! Item was added: + ----- Method: ProcessUnwindTest>>testTerminateNestedEnsureWithReturn1 (in category 'tests') ----- + testTerminateNestedEnsureWithReturn1 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + "While testTerminateInNestedEnsureWithReturn1 to 8 start unwinding + from inside a halfways through unwind block, this test (and the next) start + the unwind from outside any ensure argument (aka unwind) block, testing + the second half of the #unwindTo:safely: method." + + | p x1 x2 x3 x4 x5 | + x1 := x2 := x3 := x4 := x5 := false. + p := + [ + [:return | + [ Processor activeProcess suspend. + [ ] ensure: [ + [ ] ensure: [ + x1 := true]. + x2 := true] + ] ensure: [ + return value. + x3 := true]. + x4 := true. + ] valueWithExit. + x5 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4 | x5. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self deny: x1 & x2 & x3 & x4 & x5! Item was added: + ----- Method: ProcessUnwindTest>>testTerminateNestedEnsureWithReturn2 (in category 'tests') ----- + testTerminateNestedEnsureWithReturn2 + "Terminate suspended process. + Test all nested unwind blocks are correctly executed; + all unwind blocks halfway through their execution should be completed." + + | p x1 x2 x3 x4 x5 | + x1 := x2 := x3 := x4 := x5 := false. + p := + [ + [:return | + [ + [Processor activeProcess suspend] ensure: [ + [ ] ensure: [ + x1 := true]. + return value. + x2 := true] + ] ensure: [ + x3 := true]. + x4 := true. + ] valueWithExit. + x5 := true. + ] newProcess. + p resume. + Processor yield. + "make sure p is suspended and none of the unwind blocks has finished yet" + self assert: p isSuspended. + self deny: x1 | x2 | x3 | x4 | x5. + "now terminate the process and make sure all unwind blocks have finished" + p terminate. + self assert: p isTerminated. + self deny: x1 & x2 & x3 & x4 & x5! Item was added: + ----- Method: SemaphoreTest>>testSemaAfterCriticalWaitSuspended (in category 'tests') ----- + testSemaAfterCriticalWaitSuspended "self run: #testSemaAfterCriticalWaitSuspended" + "This tests whether a semaphore that has just left the wait in Semaphore>>critical: but + has been suspended before termination, leaves it with signaling the associated semaphore." + | s p | + s := Semaphore new. + p := [s critical:[]] forkAt: Processor activePriority-1. + "wait until p entered the critical section" + [p suspendingList == s] whileFalse:[(Delay forMilliseconds: 10) wait]. + "Now that p entered it, signal the semaphore. p now 'owns' the semaphore + but since we are running at higher priority than p it will not get to do + anything." + s signal. + self assert: p suspendingList class == LinkedList. + p suspend. + self assert: p suspendingList == nil. + p terminate. + self assert: 1 equals: s excessSignals!

1 0

← Newer
1
2
3
4
5
6
7
8
9
...
12
Older →

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

Packages October 2023