diff --git a/src/runtime/communication.rs b/src/runtime/communication.rs index b16e7a7537fcd8b0fd9498182f9064de078c02fc..b7a263cde8f75c4dc4d45b8bd0d958de39988d13 100644 --- a/src/runtime/communication.rs +++ b/src/runtime/communication.rs @@ -204,6 +204,7 @@ impl Connector { use SyncError as Se; ////////////////////////////////// log!( + @COMM_NB, cu.inner.logger, "~~~ SYNC called with timeout {:?}; starting round {}", &timeout, @@ -254,6 +255,7 @@ impl Connector { } } log!( + @COMM_NB, cu.inner.logger, "All {} proto components are now done with Nonsync phase", branching_proto_components.len(), @@ -284,7 +286,7 @@ impl Connector { getter_buffer: Default::default(), deadline: timeout.map(|to| Instant::now() + to), }; - log!(cu.inner.logger, "Round context structure initialized"); + log!(@COMM_NB, cu.inner.logger, "Round context structure initialized"); // Explore all native branches eagerly. Find solutions, buffer messages, etc. log!( @@ -353,6 +355,7 @@ impl Connector { // restore the invariant: !native_batches.is_empty() comm.native_batches.push(Default::default()); // Call to another big method; keep running this round until a distributed decision is reached + log!(@COMM_NB, cu.inner.logger, "Searching for decision..."); let decision = Self::sync_reach_decision( cu, comm, @@ -360,7 +363,7 @@ impl Connector { &mut branching_proto_components, &mut rctx, )?; - log!(cu.inner.logger, "Committing to decision {:?}!", &decision); + log!(@COMM_NB, cu.inner.logger, "Committing to decision {:?}!", &decision); comm.endpoint_manager.udp_endpoints_round_end(&mut *cu.inner.logger, &decision)?; // propagate the decision to children @@ -402,7 +405,7 @@ impl Connector { Ok(Some(branching_native.collapse_with(&mut *cu.inner.logger, &predicate))) } }; - log!(cu.inner.logger, "Sync round ending! Cleaning up"); + log!(@COMM_NB, cu.inner.logger, "Sync round ending! Cleaning up"); ret }