CSY/reowolf Changeset - ff87427e49f0 · Centrum Wiskunde & Informatica (CWI)

Changeset - ff87427e49f0

Parent rev.

Child rev.

[Not reviewed]

0 2 0

MH - 3 years ago 2022-05-19 22:23:04
contact@maxhenger.nl

Remove unused field from port metadata

2 files changed with 0 insertions and 7 deletions:

src/runtime2/component/component.rs

src/runtime2/component/component_context.rs

0 comments (0 inline, 0 general)

src/runtime2/component/component.rs

➞

Show inline comments

@@ @@ -335,7 +335,6 @@ pub(crate) fn default_handle_incoming_data_message( @@
 ) -> IncomingData {
     let port_handle = comp_ctx.get_port_handle(incoming_message.data_header.target_port);
     let port_index = comp_ctx.get_port_index(port_handle);
     comp_ctx.get_port_mut(port_handle).received_message_for_sync = true;
     let port_value_slot = &mut inbox_main[port_index];
     let target_port_id = incoming_message.data_header.target_port;
@@ @@ -595,7 +594,6 @@ pub(crate) fn default_handle_control_message( @@
                 let port_info = comp_ctx.get_port(port_handle);
                 let last_registered_round = port_info.last_registered_round;
                 let last_instruction = port_info.last_instruction;
                 let port_has_had_message = port_info.received_message_for_sync;
                 default_send_ack(message.id, peer_handle, sched_ctx, comp_ctx);
                 comp_ctx.change_port_peer(sched_ctx, port_handle, None);
@@ @@ -692,7 +690,6 @@ pub(crate) fn default_handle_sync_start( @@
         if let Some(message) = message {
             consensus.handle_incoming_data_message(comp_ctx, message);
             let port_info = comp_ctx.get_port_by_index_mut(port_index);
             port_info.received_message_for_sync = true;
+        }
+    }

src/runtime2/component/component_context.rs

➞

Show inline comments

@@ @@ -131,7 +131,6 @@ pub struct Port { @@
     // State tracking for error detection and error handling
     pub last_registered_round: Option<u32>,
     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);

0 comments (0 inline, 0 general)