diff --git a/safekeeper/src/sim/client.rs b/safekeeper/src/sim/client.rs index bf67df94cc..dede5d4950 100644 --- a/safekeeper/src/sim/client.rs +++ b/safekeeper/src/sim/client.rs @@ -6,7 +6,9 @@ pub fn run_client(os: NodeOs, data: &[u32], dst: NodeId) { let sock = os.open_tcp(dst); for num in data { + println!("start send data from client"); sock.send(AnyMessage::Just32(num.clone())); + println!("finish send data from client"); } println!("sent all data and finished client"); diff --git a/safekeeper/src/sim/sync.rs b/safekeeper/src/sim/sync.rs index 680835c7dc..d49e0d6957 100644 --- a/safekeeper/src/sim/sync.rs +++ b/safekeeper/src/sim/sync.rs @@ -55,6 +55,7 @@ impl Condvar { if let Some(waiter) = state.waiters.pop() { waiter.wake(); } + drop(state); // yield the current thread to the scheduler Park::yield_thread();