diff --git a/common/wireguard/src/peer_handle.rs b/common/wireguard/src/peer_handle.rs index c7c8709bbc..c21ff10e55 100644 --- a/common/wireguard/src/peer_handle.rs +++ b/common/wireguard/src/peer_handle.rs @@ -43,7 +43,7 @@ impl PeerHandle { let timeout_check_interval = tokio_stream::wrappers::IntervalStream::new( tokio::time::interval(DEFAULT_PEER_TIMEOUT_CHECK), ); - let mut task_client = task_client.fork(format!("peer-{public_key}")); + let mut task_client = task_client.fork(format!("peer_{public_key}")); task_client.disarm(); PeerHandle { public_key, diff --git a/gateway/src/node/client_handling/websocket/listener.rs b/gateway/src/node/client_handling/websocket/listener.rs index faa659f0fa..b5eebc3cab 100644 --- a/gateway/src/node/client_handling/websocket/listener.rs +++ b/gateway/src/node/client_handling/websocket/listener.rs @@ -50,7 +50,7 @@ impl Listener { connection = tcp_listener.accept() => { match connection { Ok((socket, remote_addr)) => { - let shutdown = self.shutdown.fork(format!("websocket-handler-{remote_addr}")); + let shutdown = self.shutdown.fork(format!("websocket_handler_{remote_addr}")); trace!("received a socket connection from {remote_addr}"); // TODO: I think we *REALLY* need a mechanism for having a maximum number of connected // clients or spawned tokio tasks -> perhaps a worker system? diff --git a/gateway/src/node/mod.rs b/gateway/src/node/mod.rs index 29c0d31e7b..1dd6f2c217 100644 --- a/gateway/src/node/mod.rs +++ b/gateway/src/node/mod.rs @@ -225,7 +225,7 @@ impl GatewayTasksBuilder { handler_config, nyxd_client, self.identity_keypair.public_key().to_bytes(), - self.shutdown.fork("ecash-manager"), + self.shutdown.fork("ecash_manager"), self.storage.clone(), ) .await?, @@ -279,13 +279,13 @@ impl GatewayTasksBuilder { let mut message_router_builder = SpMessageRouterBuilder::new( *self.identity_keypair.public_key(), self.mix_packet_sender.clone(), - self.shutdown.fork("network-requester-message-router"), + self.shutdown.fork("network_requester_message_router"), ); let transceiver = message_router_builder.gateway_transceiver(); let (on_start_tx, on_start_rx) = oneshot::channel(); let mut nr_builder = NRServiceProviderBuilder::new(nr_opts.config.clone()) - .with_shutdown(self.shutdown.fork("network-requester-sp")) + .with_shutdown(self.shutdown.fork("network_requester_sp")) .with_custom_gateway_transceiver(transceiver) .with_wait_for_gateway(true) .with_minimum_gateway_performance(0) @@ -314,13 +314,13 @@ impl GatewayTasksBuilder { let mut message_router_builder = SpMessageRouterBuilder::new( *self.identity_keypair.public_key(), self.mix_packet_sender.clone(), - self.shutdown.fork("ipr-message-router"), + self.shutdown.fork("ipr_message_router"), ); let transceiver = message_router_builder.gateway_transceiver(); let (on_start_tx, on_start_rx) = oneshot::channel(); let mut ip_packet_router = IpPacketRouter::new(ip_opts.config.clone()) - .with_shutdown(self.shutdown.fork("ipr-sp")) + .with_shutdown(self.shutdown.fork("ipr_sp")) .with_custom_gateway_transceiver(Box::new(transceiver)) .with_wait_for_gateway(true) .with_minimum_gateway_performance(0) @@ -418,7 +418,7 @@ impl GatewayTasksBuilder { let mut message_router_builder = SpMessageRouterBuilder::new( *self.identity_keypair.public_key(), self.mix_packet_sender.clone(), - self.shutdown.fork("authenticator-message-router"), + self.shutdown.fork("authenticator_message_router"), ); let transceiver = message_router_builder.gateway_transceiver(); @@ -431,7 +431,7 @@ impl GatewayTasksBuilder { ) .with_ecash_verifier(ecash_manager) .with_custom_gateway_transceiver(transceiver) - .with_shutdown(self.shutdown.fork("authenticator-sp")) + .with_shutdown(self.shutdown.fork("authenticator_sp")) .with_wait_for_gateway(true) .with_minimum_gateway_performance(0) .with_custom_topology_provider(topology_provider) @@ -451,7 +451,7 @@ impl GatewayTasksBuilder { pub fn build_stale_messages_cleaner(&self) -> StaleMessagesCleaner { StaleMessagesCleaner::new( &self.storage, - self.shutdown.fork("stale-messages-cleaner"), + self.shutdown.fork("stale_messages_cleaner"), self.config.debug.stale_messages_max_age, self.config.debug.stale_messages_cleaner_run_interval, ) diff --git a/nym-api/src/network_monitor/monitor/sender.rs b/nym-api/src/network_monitor/monitor/sender.rs index 4fe84aa125..ca2743b97f 100644 --- a/nym-api/src/network_monitor/monitor/sender.rs +++ b/nym-api/src/network_monitor/monitor/sender.rs @@ -167,7 +167,7 @@ impl PacketSender { let gateway_packet_router = PacketRouter::new( ack_sender, message_sender, - task_client.fork("packet-router"), + task_client.fork("packet_router"), ); let shared_keys = fresh_gateway_client_data @@ -186,7 +186,7 @@ impl PacketSender { Some(fresh_gateway_client_data.bandwidth_controller.clone()), nym_statistics_common::clients::ClientStatsSender::new( None, - task_client.fork("client-stats-sender"), + task_client.fork("client_stats_sender"), ), #[cfg(unix)] None, diff --git a/service-providers/authenticator/src/cli/run.rs b/service-providers/authenticator/src/cli/run.rs index b190556269..67dc226523 100644 --- a/service-providers/authenticator/src/cli/run.rs +++ b/service-providers/authenticator/src/cli/run.rs @@ -41,7 +41,7 @@ pub(crate) async fn execute(args: &Run) -> Result<(), AuthenticatorError> { Arc::new(KeyPair::new(&mut OsRng)), ); let task_handler = TaskHandle::default(); - let handler = DummyHandler::new(peer_rx, task_handler.fork("peer-handler")); + let handler = DummyHandler::new(peer_rx, task_handler.fork("peer_handler")); tokio::spawn(async move { handler.run().await; });