Skip to content

Commit a6f9392

Browse files
sberg-rhclaude
andcommitted
style: Fix formatting issues caught by CI
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent 5647af9 commit a6f9392

2 files changed

Lines changed: 26 additions & 15 deletions

File tree

src/standalone_client.rs

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -461,8 +461,7 @@ pub fn run_standalone_client_blocking_concurrent(
461461
// exits before round-trip workers connect.
462462
let sentinel: Option<Box<dyn crate::ipc::BlockingTransport>> =
463463
if config.one_way && config.round_trip {
464-
let mut transport =
465-
BlockingTransportFactory::create(&mechanism, args.shm_direct)?;
464+
let mut transport = BlockingTransportFactory::create(&mechanism, args.shm_direct)?;
466465
connect_blocking_with_retry(&mut transport, &transport_config)?;
467466
debug!("Sentinel connection established to keep server alive across phases");
468467
Some(transport)
@@ -1054,15 +1053,15 @@ pub async fn run_standalone_client_async_concurrent(
10541053

10551054
// When both test phases are enabled, keep a sentinel connection open to prevent
10561055
// the server from exiting between one-way and round-trip phases.
1057-
let sentinel: Option<Box<dyn crate::ipc::IpcTransport>> =
1058-
if config.one_way && config.round_trip {
1059-
let mut transport = crate::ipc::TransportFactory::create(&mechanism)?;
1060-
connect_async_with_retry(&mut transport, &transport_config).await?;
1061-
debug!("Sentinel connection established to keep server alive across phases");
1062-
Some(transport)
1063-
} else {
1064-
None
1065-
};
1056+
let sentinel: Option<Box<dyn crate::ipc::IpcTransport>> = if config.one_way && config.round_trip
1057+
{
1058+
let mut transport = crate::ipc::TransportFactory::create(&mechanism)?;
1059+
connect_async_with_retry(&mut transport, &transport_config).await?;
1060+
debug!("Sentinel connection established to keep server alive across phases");
1061+
Some(transport)
1062+
} else {
1063+
None
1064+
};
10661065

10671066
// One-way test
10681067
let one_way_results: Option<Vec<PerformanceMetrics>> = if config.one_way {

src/standalone_server.rs

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -490,7 +490,10 @@ pub fn run_standalone_server_blocking_multi_accept_tcp(
490490

491491
if let Some(e) = accept_error {
492492
if !had_any_client {
493-
return Err(anyhow::anyhow!("Accept failed before any client connected: {}", e));
493+
return Err(anyhow::anyhow!(
494+
"Accept failed before any client connected: {}",
495+
e
496+
));
494497
}
495498
}
496499

@@ -613,7 +616,10 @@ pub fn run_standalone_server_blocking_multi_accept_uds(
613616

614617
if let Some(e) = accept_error {
615618
if !had_any_client {
616-
return Err(anyhow::anyhow!("Accept failed before any client connected: {}", e));
619+
return Err(anyhow::anyhow!(
620+
"Accept failed before any client connected: {}",
621+
e
622+
));
617623
}
618624
}
619625

@@ -892,7 +898,10 @@ pub async fn run_standalone_server_async_multi_accept_tcp(
892898

893899
if let Some(e) = accept_error {
894900
if !had_any_client {
895-
return Err(anyhow::anyhow!("Accept failed before any client connected: {}", e));
901+
return Err(anyhow::anyhow!(
902+
"Accept failed before any client connected: {}",
903+
e
904+
));
896905
}
897906
}
898907

@@ -1015,7 +1024,10 @@ pub async fn run_standalone_server_async_multi_accept_uds(
10151024

10161025
if let Some(e) = accept_error {
10171026
if !had_any_client {
1018-
return Err(anyhow::anyhow!("Accept failed before any client connected: {}", e));
1027+
return Err(anyhow::anyhow!(
1028+
"Accept failed before any client connected: {}",
1029+
e
1030+
));
10191031
}
10201032
}
10211033

0 commit comments

Comments
 (0)