diff --git a/src/runtime2/consensus.rs b/src/runtime2/consensus.rs index d15b6edfdaf3699bb4e01ca26bd67e073551fd28..58a284304eeecb4e9aae5ea0c74a4d2a391a0be5 100644 --- a/src/runtime2/consensus.rs +++ b/src/runtime2/consensus.rs @@ -88,7 +88,7 @@ pub(crate) enum Consistency { Inconsistent, } -#[derive(PartialEq, Eq)] +#[derive(Debug, PartialEq, Eq)] pub(crate) enum MessageOrigin { Past, Present, @@ -307,6 +307,7 @@ impl Consensus { let branch = &self.branch_annotations[branch_id.index as usize]; // Clear out internal storage to defaults + println!("DEBUG: ***** Incrementing sync round stuff"); self.highest_connector_id = ConnectorId::new_invalid(); self.branch_annotations.clear(); self.branch_markers.clear(); @@ -593,6 +594,7 @@ impl Consensus { fn handle_received_sync_header(&mut self, sync_header: SyncHeader, ctx: &mut ComponentCtx) -> MessageOrigin { debug_assert!(sync_header.sending_component_id != ctx.id); // not sending to ourselves let origin = self.handle_peer(&sync_header); + println!(" ********************** GOT {:?}", origin); if origin != MessageOrigin::Present { // We do not have to handle it now return origin;