bugfix: NMv3 race condition (#6837)

* fixed race condition in mixnet listener creation notification

* reduced log severity for retrieving self-described node information

* chore: bump up version number

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

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<Notify>) -> Self {
-        on_start.notify_waiters();
+        on_start.notify_one();
         // only handle a single connection at once
         // (we don't need more than that)
         loop {

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

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,