diff --git a/src/runtime2/component/component_context.rs b/src/runtime2/component/component_context.rs index 8bf9189d82ed212972b3acfc4bf5aeecf3352fbe..49699c17ab73e742f3c3872b2ef131cb7db7885c 100644 --- a/src/runtime2/component/component_context.rs +++ b/src/runtime2/component/component_context.rs @@ -131,7 +131,6 @@ pub struct Port { // State tracking for error detection and error handling pub last_registered_round: Option, pub last_instruction: PortInstruction, // used during sync round to detect port-closed-during-sync errors - pub received_message_for_sync: bool, // used during sync round to detect port-closed-before-sync errors pub close_at_sync_end: bool, // set during sync round when receiving a port-closed-after-sync message pub(crate) associated_with_peer: bool, } @@ -185,7 +184,6 @@ impl CompCtx { last_registered_round: None, last_instruction: PortInstruction::None, close_at_sync_end: false, - received_message_for_sync: false, associated_with_peer: false, }); self.ports.push(Port{ @@ -197,7 +195,6 @@ impl CompCtx { last_registered_round: None, last_instruction: PortInstruction::None, close_at_sync_end: false, - received_message_for_sync: false, associated_with_peer: false, }); @@ -212,7 +209,6 @@ impl CompCtx { last_registered_round: None, last_instruction: PortInstruction::None, close_at_sync_end: false, - received_message_for_sync: false, associated_with_peer: false, }); return LocalPortHandle(self_id);