diff --git a/src/runtime2/inbox.rs b/src/runtime2/inbox.rs index 6e5854c85dd7b27d7967b48bc2baa1f472bc0aeb..1260a183ef590ff04c7fd96b068a795795d9565d 100644 --- a/src/runtime2/inbox.rs +++ b/src/runtime2/inbox.rs @@ -2,7 +2,7 @@ use std::sync::Mutex; use std::collections::VecDeque; use crate::protocol::eval::ValueGroup; -use crate::runtime2::consensus::SolutionCombiner; +use crate::runtime2::consensus::{ComponentPresence, SolutionCombiner}; use crate::runtime2::port::ChannelId; use super::ConnectorId; @@ -76,7 +76,7 @@ pub(crate) enum SyncCompContent { GlobalFailure, // broadcasting to everyone AckFailure, // acknowledgement of failure to leader Notification, // just a notification (so purpose of message is to send the SyncHeader) - Presence(ConnectorId, Vec), // notifying leader of component presence (needed to ensure failing a round involves all components in a sync round) + Presence(ComponentPresence), // notifying leader of component presence (needed to ensure failing a round involves all components in a sync round) } /// A sync message is a message that is intended only for the consensus