From fbb684bf2887d1a38611567dc2e74127a3b2d482 Mon Sep 17 00:00:00 2001 From: Kyler Chin <7539174+kylerchin@users.noreply.github.com> Date: Tue, 23 Apr 2024 21:31:38 -0700 Subject: [PATCH] Print more detailed info about leader thread --- src/aspen/leader_thread.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/aspen/leader_thread.rs b/src/aspen/leader_thread.rs index 951c3164..07b5d9c0 100644 --- a/src/aspen/leader_thread.rs +++ b/src/aspen/leader_thread.rs @@ -97,6 +97,7 @@ pub async fn aspen_leader_thread( let leader_id: String = bincode::deserialize(&leader_str_bytes).unwrap(); if leader_id == *this_worker_id { + println!("This is the leader thread!"); //leader tasks let mut workers_nodes_lock = workers_nodes.lock().await; let mut chateau_list_lock = feeds_list.lock().await; @@ -252,6 +253,8 @@ pub async fn aspen_leader_thread( } std::thread::sleep(std::time::Duration::from_secs(10)); + } else { + println!("Leader entry contains no data"); } } }