chore: trace log from every task wakeup

Author: dpc

crates/rostra-client/src/task/followee_checker.rs

@@ -65,6 +65,7 @@ impl FolloweeChecker {
 
                 }
             }
+            trace!(target: LOG_TARGET, "Woke up");
 
             // Query only new followees
             for (followee_id, _persona_id) in &self_followees {

crates/rostra-client/src/task/followee_head_checker.rs

@@ -12,7 +12,7 @@ use rostra_util_error::{BoxedErrorResult, FmtCompact, WhateverResult};
 use rostra_util_fmt::AsFmtOption as _;
 use snafu::ResultExt as _;
 use tokio::sync::watch;
-use tracing::{debug, info, instrument};
+use tracing::{debug, info, instrument, trace};
 
 use crate::client::Client;
 use crate::ClientRef;
@@ -64,6 +64,7 @@ impl FolloweeHeadChecker {
                     }
                 }
             }
+            trace!(target: LOG_TARGET, "Woke up");
 
             let Ok(storage) = self.client.db() else {
                 break;

crates/rostra-client/src/task/head_merger.rs

@@ -5,7 +5,7 @@ use rostra_core::event::{EventKind, VerifiedEvent};
 use rostra_core::id::{RostraId, RostraIdSecretKey};
 use rostra_core::{Event, ShortEventId};
 use tokio::sync::watch;
-use tracing::{debug, instrument};
+use tracing::{debug, instrument, trace};
 
 use crate::client::Client;
 const LOG_TARGET: &str = "rostra::head_merger";
@@ -33,6 +33,7 @@ impl HeadMerger {
     pub async fn run(self) {
         let mut head_rx = self.self_head_rx.clone();
         while let Ok(_head) = head_rx.changed().await {
+            trace!(target: LOG_TARGET, "Woke up" );
             // To avoid two active nodes merging heads together at the same time, producing
             // more heads, that require more merging, etc., we just sleep a random period of
             // time here, which should be enough to propagate and eventually desynchronize.

crates/rostra-client/src/task/head_update_broadcaster.rs

@@ -9,7 +9,7 @@ use rostra_p2p::connection::{Connection, FeedEventRequest};
 use rostra_util_error::{FmtCompact, WhateverResult};
 use snafu::ResultExt as _;
 use tokio::sync::watch;
-use tracing::{debug, instrument, warn};
+use tracing::{debug, instrument, trace, warn};
 
 use crate::client::Client;
 use crate::ClientRef;
@@ -54,6 +54,7 @@ impl HeadUpdateBroadcaster {
                     }
                 }
             }
+            trace!(target: LOG_TARGET, "Woke up");
 
             let Some(head) = *self_head_rx.borrow() else {
                 warn!(target: LOG_TARGET, "Empty head!?");

crates/rostra-client/src/task/missing_event_fetcher.rs

@@ -6,7 +6,7 @@ use rostra_core::ShortEventId;
 use rostra_p2p::Connection;
 use rostra_util_error::{BoxedErrorResult, FmtCompact, WhateverResult};
 use snafu::ResultExt as _;
-use tracing::{debug, instrument, warn};
+use tracing::{debug, instrument, trace, warn};
 
 use crate::client::Client;
 use crate::{ClientHandle, LOG_TARGET};
@@ -43,6 +43,7 @@ impl MissingEventFetcher {
                     continue;
                 }
             };
+            trace!(target: LOG_TARGET, "Woke up");
 
             let Ok(db) = self.client.db() else {
                 break;

crates/rostra-client/src/task/pkarr_id_publisher.rs

@@ -97,6 +97,7 @@ impl PkarrIdPublisher {
                     }
                 }
             }
+            trace!(target: LOG_TARGET, "Woke up");
 
             self.wait_for_your_turn().await;
             debug!(target: LOG_TARGET, "Detect no other peer alive, assuming the role of Pkarr ID publisher");

crates/rostra-client/src/task/request_handler.rs

@@ -97,6 +97,7 @@ impl RequestHandler {
                 return;
             };
 
+            trace!(target: LOG_TARGET, "New connection" );
             tokio::spawn(self.clone().handle_incoming(incoming));
         }
     }