Add tests for new blocking code

Signed-off-by: John Nunley <[email protected]>

tests/barrier.rs

@@ -44,3 +44,42 @@ fn smoke() {
         }
     });
 }
+
+#[test]
+fn smoke_blocking() {
+    future::block_on(async move {
+        const N: usize = 10;
+
+        let barrier = Arc::new(Barrier::new(N));
+
+        for _ in 0..10 {
+            let (tx, rx) = async_channel::unbounded();
+
+            for _ in 0..N - 1 {
+                let c = barrier.clone();
+                let tx = tx.clone();
+
+                thread::spawn(move || {
+                    let res = c.wait_blocking();
+                    tx.send_blocking(res.is_leader()).unwrap();
+                });
+            }
+
+            // At this point, all spawned threads should be blocked,
+            // so we shouldn't get anything from the cahnnel.
+            let res = rx.try_recv();
+            assert!(res.is_err());
+
+            let mut leader_found = barrier.wait_blocking().is_leader();
+
+            // Now, the barrier is cleared and we should get data.
+            for _ in 0..N - 1 {
+                if rx.recv().await.unwrap() {
+                    assert!(!leader_found);
+                    leader_found = true;
+                }
+            }
+            assert!(leader_found);
+        }
+    });
+}

tests/mutex.rs

@@ -24,6 +24,13 @@ fn smoke() {
     })
 }
 
+#[test]
+fn smoke_blocking() {
+    let m = Mutex::new(());
+    drop(m.lock_blocking());
+    drop(m.lock_blocking());
+}
+
 #[test]
 fn try_lock() {
     let m = Mutex::new(());

tests/rwlock.rs

@@ -47,6 +47,15 @@ fn smoke() {
     });
 }
 
+#[test]
+fn smoke_blocking() {
+    let lock = RwLock::new(());
+    drop(lock.read_blocking());
+    drop(lock.write_blocking());
+    drop((lock.read_blocking(), lock.read_blocking()));
+    drop(lock.write_blocking());
+}
+
 #[test]
 fn try_write() {
     future::block_on(async {

tests/semaphore.rs

@@ -114,6 +114,16 @@ fn yields_when_contended() {
     check_yields_when_contended(s.try_acquire_arc().unwrap(), s.acquire_arc());
 }
 
+#[test]
+fn smoke_blocking() {
+    let s = Semaphore::new(2);
+    let g1 = s.acquire_blocking();
+    let _g2 = s.acquire_blocking();
+    assert!(s.try_acquire().is_none());
+    drop(g1);
+    assert!(s.try_acquire().is_some());
+}
+
 #[test]
 fn add_permits() {
     static COUNTER: AtomicUsize = AtomicUsize::new(0);