From 072fb3d7e968e757d5fe2aca1133a5779d9efdd3 Mon Sep 17 00:00:00 2001 From: Arthur Petukhovsky Date: Thu, 9 Mar 2023 14:59:03 +0200 Subject: [PATCH] WIP --- safekeeper/src/sim/client.rs | 2 ++ safekeeper/src/sim/sync.rs | 1 + 2 files changed, 3 insertions(+) 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();