Add miri test

Signed-off-by: Moritz Hoffmann <[email protected]>

Author: antiguru

.github/workflows/miri.yml

@@ -0,0 +1,18 @@
+name: "Test Suite (miri)"
+on:
+  push:
+    branches:
+      - master
+  pull_request:
+
+jobs:
+  test:
+    name: cargo miri test on ubuntu, rust nightly
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions-rust-lang/setup-rust-toolchain@v1
+        with:
+          toolchain: nightly
+      - name: Cargo test
+        run: cargo miri test

timely/src/dataflow/operators/core/capture/capture.rs

@@ -76,6 +76,7 @@ pub trait Capture<T: Timestamp, C: Container + Data> {
     /// let (send0, recv0) = ::std::sync::mpsc::channel();
     /// let send0 = Arc::new(Mutex::new(send0));
     ///
+    /// # #[cfg_attr(miri, ignore)]
     /// timely::execute(timely::Config::thread(), move |worker| {
     ///
     ///     // this is only to validate the output.

timely/src/dataflow/operators/core/capture/event.rs

@@ -116,9 +116,13 @@ pub mod link {
 
     #[test]
     fn avoid_stack_overflow_in_drop() {
+        #[cfg(miri)]
+        let limit = 1_000;
+        #[cfg(not(miri))]
+        let limit = 1_000_000;
         let mut event1 = Rc::new(EventLink::<(),()>::new());
         let _event2 = event1.clone();
-        for _ in 0 .. 1_000_000 {
+        for _ in 0 .. limit {
             event1.push(Event::Progress(vec![]));
         }
     }

timely/src/dataflow/operators/core/capture/mod.rs

@@ -24,6 +24,7 @@
 //! use timely::dataflow::operators::{Capture, ToStream, Inspect};
 //! use timely::dataflow::operators::capture::{EventLink, Replay};
 //!
+//! # #[cfg_attr(miri, ignore)]
 //! timely::execute(timely::Config::thread(), |worker| {
 //!     let handle1 = Rc::new(EventLink::new());
 //!     let handle2 = Some(handle1.clone());

timely/tests/shape_scaling.rs

@@ -6,9 +6,9 @@ use timely::Config;
 #[test] fn operator_scaling_1() { operator_scaling(1); }
 #[test] fn operator_scaling_10() { operator_scaling(10); }
 #[test] fn operator_scaling_100() { operator_scaling(100); }
-#[test] fn operator_scaling_1000() { operator_scaling(1000); }
-#[test] fn operator_scaling_10000() { operator_scaling(10000); }
-#[test] fn operator_scaling_100000() { operator_scaling(100000); }
+#[test] #[cfg_attr(miri, ignore)] fn operator_scaling_1000() { operator_scaling(1000); }
+#[test] #[cfg_attr(miri, ignore)] fn operator_scaling_10000() { operator_scaling(10000); }
+#[test] #[cfg_attr(miri, ignore)] fn operator_scaling_100000() { operator_scaling(100000); }
 
 fn operator_scaling(scale: u64) {
     timely::execute(Config::thread(), move |worker| {
@@ -54,9 +54,9 @@ fn operator_scaling(scale: u64) {
 #[test] fn subgraph_scaling_1() { subgraph_scaling(1); }
 #[test] fn subgraph_scaling_10() { subgraph_scaling(10); }
 #[test] fn subgraph_scaling_100() { subgraph_scaling(100); }
-#[test] fn subgraph_scaling_1000() { subgraph_scaling(1000); }
-#[test] fn subgraph_scaling_10000() { subgraph_scaling(10000); }
-#[test] fn subgraph_scaling_100000() { subgraph_scaling(100000); }
+#[test] #[cfg_attr(miri, ignore)] fn subgraph_scaling_1000() { subgraph_scaling(1000); }
+#[test] #[cfg_attr(miri, ignore)] fn subgraph_scaling_10000() { subgraph_scaling(10000); }
+#[test] #[cfg_attr(miri, ignore)] fn subgraph_scaling_100000() { subgraph_scaling(100000); }
 
 fn subgraph_scaling(scale: u64) {
     timely::execute(Config::thread(), move |worker| {