diff options
| -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?; |
