aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authordiogo464 <[email protected]>2025-10-14 18:24:56 +0100
committerdiogo464 <[email protected]>2025-10-14 18:24:56 +0100
commit44baa8b7ceb05b35d40f259a71c4b340b5563222 (patch)
treea459aa3c9081c0c11bee8ae8e271c576de0bae16 /src
parent7cbc2df01d042a1192d10cf64ba831afbf691236 (diff)
added extra debug logging when reading/parsing latency matrix
Diffstat (limited to 'src')
-rw-r--r--src/main.rs8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/main.rs b/src/main.rs
index 3bd5497..8f2cec4 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -245,11 +245,19 @@ async fn context_from_common(common: &Common) -> Result<Context> {
245 245
246async fn cmd_net_up(args: NetUpArgs) -> Result<()> { 246async fn cmd_net_up(args: NetUpArgs) -> Result<()> {
247 let context = context_from_common(&args.common).await?; 247 let context = context_from_common(&args.common).await?;
248
249 tracing::debug!(
250 "reading latency matrix at {}",
251 args.latency_matrix.display()
252 );
248 let matrix_content = tokio::fs::read_to_string(&args.latency_matrix) 253 let matrix_content = tokio::fs::read_to_string(&args.latency_matrix)
249 .await 254 .await
250 .context("reading latecy matrix")?; 255 .context("reading latecy matrix")?;
256
257 tracing::debug!("parsing latency matrix");
251 let matrix = LatencyMatrix::parse(&matrix_content, latency_matrix::TimeUnit::Milliseconds) 258 let matrix = LatencyMatrix::parse(&matrix_content, latency_matrix::TimeUnit::Milliseconds)
252 .context("parsing latency matrix")?; 259 .context("parsing latency matrix")?;
260
253 let machines = oar::job_list_machines(&context).await?; 261 let machines = oar::job_list_machines(&context).await?;
254 let configs = machine_generate_configs(&matrix, args.matrix_wrap, &machines, &args.addresses)?; 262 let configs = machine_generate_configs(&matrix, args.matrix_wrap, &machines, &args.addresses)?;
255 machines_containers_clean(&context, &machines).await?; 263 machines_containers_clean(&context, &machines).await?;