diff options
| author | diogo464 <[email protected]> | 2025-10-14 18:24:56 +0100 |
|---|---|---|
| committer | diogo464 <[email protected]> | 2025-10-14 18:24:56 +0100 |
| commit | 44baa8b7ceb05b35d40f259a71c4b340b5563222 (patch) | |
| tree | a459aa3c9081c0c11bee8ae8e271c576de0bae16 | |
| parent | 7cbc2df01d042a1192d10cf64ba831afbf691236 (diff) | |
added extra debug logging when reading/parsing latency matrix
| -rw-r--r-- | src/main.rs | 8 |
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 | ||
| 246 | async fn cmd_net_up(args: NetUpArgs) -> Result<()> { | 246 | async 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?; |
