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

Changeset - d65eb4f44f1a

Parent rev.

Child rev.

[Not reviewed]

0 2 0

MH - 3 years ago 2022-05-13 23:50:41
contact@maxhenger.nl

Fix fake tcp test

2 files changed with 5 insertions and 2 deletions:

src/runtime2/component/component.rs

src/runtime2/tests/internet.rs

0 comments (0 inline, 0 general)

src/runtime2/component/component.rs

➞

Show inline comments

@@ @@ -978,13 +978,13 @@ pub(crate) fn perform_create_component( @@
         // Transferring the messages and removing the port from the
         // instantiator component
         let instantiator_port_index = instantiator_ctx.get_port_index(pair.instantiator_handle);
         instantiator_ctx.change_port_peer(sched_ctx, pair.instantiator_handle, None);
         instantiator_ctx.remove_port(pair.instantiator_handle);
-        if let Some(mut message) = inbox_main[instantiator_port_index].take() {
+        if let Some(mut message) = inbox_main.remove(instantiator_port_index) {
             message.data_header.target_port = pair.created_id;
             created_component.adopt_message(created_ctx, message);
+        }
         let mut message_index = 0;
         while message_index < inbox_backup.len() {

src/runtime2/tests/internet.rs

➞

Show inline comments

@@ @@ -25,12 +25,13 @@ fn test_stdlib_file() { @@
             auto keep_going = true;
             sync {
                 while (keep_going) {
                     auto cmd = get(cmds);
                     if (let inet::Cmd::Send(data) = cmd) {
                         to_send = data;
                         keep_going = false;
                     } else if (let inet::Cmd::Receive = cmd) {
                         put(tx, to_send);
                     } else if (let inet::Cmd::Finish = cmd) {
                         keep_going = false;
                     } else if (let inet::Cmd::Shutdown = cmd) {
                         keep_going = false;
@@ @@ -43,13 +44,15 @@ fn test_stdlib_file() { @@
     comp fake_client(inet::TcpConnection conn) {
         sync put(conn.tx, inet::Cmd::Send({1, 3, 3, 7}));
         sync {
             put(conn.tx, inet::Cmd::Receive);
             auto val = get(conn.rx);
             while (val[0] != 1 || val[1] != 3 || val[2] != 3 || val[3] != 7) {}
             while (val[0] != 1 || val[1] != 3 || val[2] != 3 || val[3] != 7) {
                 print(\"this is going very wrong\");
+            }
             put(conn.tx, inet::Cmd::Finish);
+        }
         sync put(conn.tx, inet::Cmd::Shutdown);
+    }
     comp constructor() {

0 comments (0 inline, 0 general)