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

Changeset - 9936bb801409

Parent rev.

Child rev.

[Not reviewed]

0 2 0

mh - 3 years ago 2022-04-26 10:54:48
contact@maxhenger.nl

Add multithreading testing

2 files changed with 44 insertions and 1 deletions:

src/runtime2/tests/error_handling.rs

src/runtime2/tests/mod.rs

0 comments (0 inline, 0 general)

src/runtime2/tests/error_handling.rs

➞

Show inline comments

@@ @@ -17,15 +17,21 @@ fn test_connected_uncommunicating_component_error() { @@
         auto value = array[1337];
+    }
     primitive sitting_idly_waiting(in<u32> never_providing) {
         sync auto a = get(never_providing);
+    }
     composite constructor() {
         // Test one way
         channel a -> b;
         new sitting_idly_waiting(b);
         new crashing_and_burning(a);
         // And the other way around
         channel c -> d;
         new crashing_and_burning(c);
         new sitting_idly_waiting(d);
     }", "constructor", no_args())
+}
 #[test]
 fn test_connected_communicating_component_error() {
     compile_and_create_component("
@@ @@ -40,9 +46,46 @@ fn test_connected_communicating_component_error() { @@
         sync auto a = get(rx);
+    }
     composite constructor() {
         channel a -> b;
         new send_and_fail(a);
         new receive_once(b);
         channel c -> d;
         new receive_once(d);
         new send_and_fail(c);
+    }
     ", "constructor", no_args())
+}
 #[test]
 fn test_failing_after_successful_sync() {
     compile_and_create_component("
     primitive put_and_fail(out<u8> tx) { sync put(tx, 1); u8 a = {}[0]; }
     primitive get_and_fail(in<u8> rx) { sync auto a = get(rx); u8 a = {}[0]; }
     primitive put_and_exit(out<u8> tx) { sync put(tx, 2); }
     primitive get_and_exit(in<u8> rx) { sync auto a = get(rx); }
     composite constructor() {
+        {
             channel a -> b;
             new put_and_fail(a);
             new get_and_exit(b);
+        }
+        {
             channel a -> b;
             new get_and_exit(b);
             new put_and_fail(a);
+        }
+        {
             channel a -> b;
             new put_and_exit(a);
             new get_and_fail(b);
+        }
+        {
             channel a -> b;
             new get_and_fail(b);
             new put_and_exit(a);
+        }
+    }
     ", "constructor", no_args());
+}
@@ \ No newline at end of file @@

src/runtime2/tests/mod.rs

➞

Show inline comments

@@ @@ -2,13 +2,13 @@ use crate::protocol::*; @@
 use crate::protocol::eval::*;
 use crate::runtime2::runtime::*;
 use crate::runtime2::component::{CompCtx, CompPDL};
 mod error_handling;
-const NUM_THREADS: u32 = 1;
+const NUM_THREADS: u32 = 4;
 const DEBUG_LOGGING: bool = true;
 pub(crate) fn compile_and_create_component(source: &str, routine_name: &str, args: ValueGroup) {
     let protocol = ProtocolDescription::parse(source.as_bytes())
         .expect("successful compilation");
     let runtime = Runtime::new(NUM_THREADS, DEBUG_LOGGING, protocol)

0 comments (0 inline, 0 general)