diff --git a/Cargo.lock b/Cargo.lock index c606bed85c..6e2f149a0b 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -7571,7 +7571,7 @@ dependencies = [ [[package]] name = "nym-network-monitor-agent" -version = "1.0.2" +version = "1.0.3" dependencies = [ "anyhow", "arrayref", @@ -7604,7 +7604,7 @@ dependencies = [ [[package]] name = "nym-network-monitor-orchestrator" -version = "1.0.2" +version = "1.0.3" dependencies = [ "anyhow", "axum", diff --git a/nym-network-monitor-v3/nym-network-monitor-agent/Cargo.toml b/nym-network-monitor-v3/nym-network-monitor-agent/Cargo.toml index 97d0adccef..9500df46f1 100644 --- a/nym-network-monitor-v3/nym-network-monitor-agent/Cargo.toml +++ b/nym-network-monitor-v3/nym-network-monitor-agent/Cargo.toml @@ -1,7 +1,7 @@ [package] name = "nym-network-monitor-agent" description = "Agent used for stress testing Nym mixnodes" -version = "1.0.2" +version = "1.0.3" authors.workspace = true edition.workspace = true license.workspace = true diff --git a/nym-network-monitor-v3/nym-network-monitor-agent/src/listener/mod.rs b/nym-network-monitor-v3/nym-network-monitor-agent/src/listener/mod.rs index 90817f277c..822341d50e 100644 --- a/nym-network-monitor-v3/nym-network-monitor-agent/src/listener/mod.rs +++ b/nym-network-monitor-v3/nym-network-monitor-agent/src/listener/mod.rs @@ -144,7 +144,7 @@ impl MixnetListener { /// Returns `self` so that the caller can inspect fields such as /// [`last_noise_handshake_duration`](Self::last_noise_handshake_duration) after the run. pub(crate) async fn run(mut self, on_start: Arc) -> Self { - on_start.notify_waiters(); + on_start.notify_one(); // only handle a single connection at once // (we don't need more than that) loop { diff --git a/nym-network-monitor-v3/nym-network-monitor-orchestrator/Cargo.toml b/nym-network-monitor-v3/nym-network-monitor-orchestrator/Cargo.toml index a93df645e7..e0b2516158 100644 --- a/nym-network-monitor-v3/nym-network-monitor-orchestrator/Cargo.toml +++ b/nym-network-monitor-v3/nym-network-monitor-orchestrator/Cargo.toml @@ -1,7 +1,7 @@ [package] name = "nym-network-monitor-orchestrator" description = "Orchestrator for performing Nym network stress testing" -version = "1.0.2" +version = "1.0.3" authors.workspace = true edition.workspace = true license.workspace = true diff --git a/nym-network-monitor-v3/nym-network-monitor-orchestrator/src/orchestrator/node_refresher.rs b/nym-network-monitor-v3/nym-network-monitor-orchestrator/src/orchestrator/node_refresher.rs index b11bfbdc4e..9f8e19ad6f 100644 --- a/nym-network-monitor-v3/nym-network-monitor-orchestrator/src/orchestrator/node_refresher.rs +++ b/nym-network-monitor-v3/nym-network-monitor-orchestrator/src/orchestrator/node_refresher.rs @@ -23,7 +23,7 @@ use std::collections::HashMap; use std::net::SocketAddr; use std::time::Duration; use tokio::time::{Instant, interval}; -use tracing::{error, info, warn}; +use tracing::{debug, error, info}; pub(crate) struct NodeRefresher { pub(crate) client: QueryHttpRpcNyxdClient, @@ -142,13 +142,13 @@ impl NodeRefresher { .await { Err(_timeout) => { - warn!( + debug!( "timed out while attempting to retrieve self-described node details for node {node_id}" ); return node_update; } Ok(Err(err)) => { - error!("failed to retrieve self-described node details for node {node_id}: {err}"); + debug!("failed to retrieve self-described node details for node {node_id}: {err}"); return node_update; } Ok(Ok(info)) => info,