MCPcopy Index your code
hub / github.com/RustPython/RustPython / debug_assert_all_non_requester_suspended

Method debug_assert_all_non_requester_suspended

crates/vm/src/vm/mod.rs:492–506  ·  view source on GitHub ↗
(&self, vm: &VirtualMachine)

Source from the content-addressed store, hash-verified

490
491 #[cfg(debug_assertions)]
492 fn debug_assert_all_non_requester_suspended(&self, vm: &VirtualMachine) {
493 use thread::THREAD_SUSPENDED;
494 let requester = self.requester.load(Ordering::Relaxed);
495 let registry = vm.state.thread_frames.lock();
496 for (&id, slot) in registry.iter() {
497 if id == requester {
498 continue;
499 }
500 let state = slot.state.load(Ordering::Relaxed);
501 debug_assert!(
502 state == THREAD_SUSPENDED,
503 "non-requester thread not suspended during stop-the-world: id={id} state={state}"
504 );
505 }
506 }
507
508 #[cfg(debug_assertions)]
509 fn debug_assert_all_non_requester_detached(&self, vm: &VirtualMachine) {

Callers 1

stop_the_worldMethod · 0.80

Calls 3

loadMethod · 0.45
lockMethod · 0.45
iterMethod · 0.45

Tested by

no test coverage detected