From 38a48562420def5bc56b1bb9d9561ca008b89c13 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Sat, 12 Nov 2022 15:30:16 +0100 Subject: [PATCH] ws load test: use log crate instead of eprintln --- aquatic_ws_load_test/src/config.rs | 2 +- aquatic_ws_load_test/src/network.rs | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/aquatic_ws_load_test/src/config.rs b/aquatic_ws_load_test/src/config.rs index eff0ae5..42282d2 100644 --- a/aquatic_ws_load_test/src/config.rs +++ b/aquatic_ws_load_test/src/config.rs @@ -29,7 +29,7 @@ impl Default for Config { fn default() -> Self { Self { server_address: "127.0.0.1:3000".parse().unwrap(), - log_level: LogLevel::Error, + log_level: LogLevel::Warn, num_workers: 1, num_connections_per_worker: 16, connection_creation_interval_ms: 10, diff --git a/aquatic_ws_load_test/src/network.rs b/aquatic_ws_load_test/src/network.rs index 62c847d..b537eab 100644 --- a/aquatic_ws_load_test/src/network.rs +++ b/aquatic_ws_load_test/src/network.rs @@ -51,7 +51,7 @@ async fn periodically_open_connections( if let Err(err) = Connection::run(config, tls_config, load_test_state, num_active_connections).await { - eprintln!("connection creation error: {:?}", err); + ::log::info!("connection creation error: {:#}", err); } }) .detach(); @@ -105,7 +105,7 @@ impl Connection { *num_active_connections.borrow_mut() += 1; if let Err(err) = connection.run_connection_loop().await { - eprintln!("connection error: {}", err); + ::log::info!("connection error: {:#}", err); } *num_active_connections.borrow_mut() -= 1; @@ -169,7 +169,7 @@ impl Connection { message } message => { - eprintln!( + ::log::warn!( "Received WebSocket message of unexpected type: {:?}", message ); @@ -219,12 +219,12 @@ impl Connection { .responses_error .fetch_add(1, Ordering::SeqCst); - eprintln!("received error response: {:?}", response.failure_reason); + ::log::warn!("received error response: {:?}", response.failure_reason); self.can_send = true; } Err(err) => { - eprintln!("error deserializing message: {:?}", err); + ::log::error!("error deserializing message: {:#}", err); } }