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

Changeset - 9ff4792ea5d6

Parent rev.

Child rev.

[Not reviewed]

0 2 0

MH - 4 years ago 2021-11-29 11:31:09
contact@maxhenger.nl

Remove message hack

2 files changed with 0 insertions and 22 deletions:

src/runtime2/connector.rs

src/runtime2/scheduler.rs

0 comments (0 inline, 0 general)

src/runtime2/connector.rs

➞

Show inline comments

@@ @@ -517,15 +517,6 @@ impl ConnectorPDL { @@
             RoundConclusion::Failure => None,
         };
         // TODO: Hack
         ctx.remove_messages(|m| match m {
             Message::Data(_) | Message::SyncPort(_) | Message::SyncControl(_) | Message::Control(_) => false,
             Message::SyncComp(m) => match m.content {
                 SyncCompContent::Notification | SyncCompContent::Presence(_) => true,
                 _ => false,
+            }
         });
         if let Some(solution_branch_id) = final_branch_id {
             let mut fake_vec = Vec::new();
             self.tree.end_sync(solution_branch_id);

src/runtime2/scheduler.rs

➞

Show inline comments

@@ @@ -545,19 +545,6 @@ impl ComponentCtx { @@
         return Ok(());
+    }
     /// Removes messages in the outbox using a match
     pub(crate) fn remove_messages<F: Fn(&Message) -> bool>(&mut self, remove_if_fn: F) {
         let mut idx = 0;
         while idx < self.outbox.len() {
             let should_remove = remove_if_fn(&self.outbox[idx]);
             if should_remove {
                 self.outbox.remove(idx);
             } else {
                 idx += 1;
+            }
+        }
+    }
     /// Notify that component just finished a sync block. Like
     /// `notify_sync_start`: drop out of the `Component::Run` function.
     pub(crate) fn notify_sync_end(&mut self, changed_ports: &[ComponentPortChange]) {

0 comments (0 inline, 0 general)