Skip to content

Commit

Permalink
add logging
Browse files Browse the repository at this point in the history
  • Loading branch information
paulheinr committed Nov 28, 2024
1 parent cde277d commit 0807ea8
Showing 1 changed file with 8 additions and 0 deletions.
8 changes: 8 additions & 0 deletions src/simulation/messaging/communication/message_broker.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
use std::collections::{BinaryHeap, HashMap, HashSet};
use std::rc::Rc;
use tracing::info;

use crate::simulation::messaging::communication::communicators::SimCommunicator;
use crate::simulation::network::global_network::Network;
Expand Down Expand Up @@ -101,6 +102,13 @@ where

pub fn send_recv(&mut self, now: u32) -> Vec<SyncMessage> {
let vehicles = self.prepare_send_recv_vehicles(now);

for (_, m) in &vehicles {
if !m.vehicles.is_empty() {
info!("Rank {}, message {:?}", self.rank(), m);
}
}

let mut result: Vec<SyncMessage> = Vec::new();
let mut expected_vehicle_messages = self.neighbors.clone();

Expand Down

0 comments on commit 0807ea8

Please sign in to comment.