diff --git a/src/runtime2/component/consensus.rs b/src/runtime2/component/consensus.rs
index 72e7c475fc94b9f82e2f4de4da0d1cc4cc6cafb8..f9f3ab3f1df69fe514ced318d8eb388adec96ea9 100644
--- a/src/runtime2/component/consensus.rs
+++ b/src/runtime2/component/consensus.rs
@@ -378,7 +378,10 @@ impl Consensus {
     /// Handles the arrival of a new data message (needs to be called for every
     /// new data message, even though it might not end up being received). This
     /// is used to determine peers of `get`ter ports.
-    pub(crate) fn handle_new_data_message(&mut self, comp_ctx: &CompCtx, message: &DataMessage) {
+    // TODO: The use of this function is rather ugly. Find a more robust
+    //  scheme about owners of `get`ter ports not knowing about their peers.
+    //  (also, figure out why this was written again, I forgot).
+    pub(crate) fn handle_incoming_data_message(&mut self, comp_ctx: &CompCtx, message: &DataMessage) {
         let target_handle = comp_ctx.get_port_handle(message.data_header.target_port);
         let target_index = comp_ctx.get_port_index(target_handle);
         let annotation = &mut self.ports[target_index];