diff --git a/src/runtime2/mod.rs b/src/runtime2/mod.rs index 407fda0c76334eef9db7b1877ea42873d4b00045..3cf1ba4de30ac97d92be9c0353934cb417c6972e 100644 --- a/src/runtime2/mod.rs +++ b/src/runtime2/mod.rs @@ -306,13 +306,11 @@ impl RuntimeInner { #[inline] pub(crate) fn increment_active_interfaces(&self) { let _old_num = self.active_interfaces.fetch_add(1, Ordering::SeqCst); - println!("DEBUG: Incremented active interfaces to {}", _old_num + 1); debug_assert_ne!(_old_num, 0); // once it hits 0, it stays zero } pub(crate) fn decrement_active_interfaces(&self) { let old_num = self.active_interfaces.fetch_sub(1, Ordering::SeqCst); - println!("DEBUG: Decremented active interfaces to {}", old_num - 1); debug_assert!(old_num > 0); if old_num == 1 { // such that active interfaces is now 0 let num_connectors = self.active_connectors.load(Ordering::Acquire); @@ -325,12 +323,10 @@ impl RuntimeInner { #[inline] fn increment_active_components(&self) { let _old_num = self.active_connectors.fetch_add(1, Ordering::SeqCst); - println!("DEBUG: Incremented components to {}", _old_num + 1); } fn decrement_active_components(&self) { let old_num = self.active_connectors.fetch_sub(1, Ordering::SeqCst); - println!("DEBUG: Decremented components to {}", old_num - 1); debug_assert!(old_num > 0); if old_num == 1 { // such that we have no more active connectors (for now!) let num_interfaces = self.active_interfaces.load(Ordering::Acquire); @@ -345,14 +341,12 @@ impl RuntimeInner { debug_assert_eq!(self.active_interfaces.load(Ordering::Acquire), 0); debug_assert_eq!(self.active_connectors.load(Ordering::Acquire), 0); - println!("DEBUG: Signaling for shutdown"); let _lock = self.connector_queue.lock().unwrap(); let should_signal = self.should_exit .compare_exchange(false, true, Ordering::SeqCst, Ordering::Acquire) .is_ok(); if should_signal { - println!("DEBUG: Notifying all waiting schedulers"); self.scheduler_notifier.notify_all(); } }