diff --git a/crates/vnidrop/src/runtime.rs b/crates/vnidrop/src/runtime.rs index e5b7953..d24b131 100644 --- a/crates/vnidrop/src/runtime.rs +++ b/crates/vnidrop/src/runtime.rs @@ -497,7 +497,11 @@ impl CoreInner { RuntimeStatus { endpoint_id: self.endpoint.id().to_string(), addr: format!("{:?}", self.endpoint.addr()), - active_transfers: self.active_transfers.lock().expect("active_transfers").len() as u64, + active_transfers: self + .active_transfers + .lock() + .expect("active_transfers") + .len() as u64, active_shares: self.active_shares.lock().await.len() as u64, } } diff --git a/crates/vnidrop/tests/output_sink.rs b/crates/vnidrop/tests/output_sink.rs index 79db032..1b01319 100644 --- a/crates/vnidrop/tests/output_sink.rs +++ b/crates/vnidrop/tests/output_sink.rs @@ -83,7 +83,11 @@ fn cancellation_during_export_aborts_open_sink_file() { let sink_for_worker = output_sink.clone(); let ticket = share.ticket.clone(); let worker = std::thread::spawn(move || { - receiver_core.receive_with_output_sink(ticket, sink_for_worker, Some("receiver".to_string())) + receiver_core.receive_with_output_sink( + ticket, + sink_for_worker, + Some("receiver".to_string()), + ) }); let request = wait_for_receiver_request(&sender.core, share.transfer_id);