diff --git a/src/runtime2/inbox2.rs b/src/runtime2/inbox2.rs index ff2d65a34b542ca74445a72bbbb3499091ce8011..fdffe317a062dc1a0b20e61b0d22d2ae197fea79 100644 --- a/src/runtime2/inbox2.rs +++ b/src/runtime2/inbox2.rs @@ -29,7 +29,7 @@ pub(crate) struct DataHeader { } /// A data message is a message that is intended for the receiver's PDL code, -/// but will also be handled by the consensus algrorithm +/// but will also be handled by the consensus algorithm #[derive(Debug, Clone)] pub(crate) struct DataMessageFancy { pub sync_header: SyncHeader, @@ -39,7 +39,8 @@ pub(crate) struct DataMessageFancy { #[derive(Debug)] pub(crate) enum SyncContent { - + LocalSolution(), // sending a local solution to the leader + Notification, // just a notification (so message is about sending the SyncHeader) } /// A sync message is a message that is intended only for the consensus @@ -47,6 +48,7 @@ pub(crate) enum SyncContent { #[derive(Debug)] pub(crate) struct SyncMessageFancy { pub sync_header: SyncHeader, + pub target_component_id: ConnectorId, pub content: SyncContent, }