scchannel test close without write

Author: sporksmith

src/lib/vasi-sync/tests/scchannel-tests.rs

@@ -86,7 +86,7 @@ mod scchannel_tests {
     }
 
     #[test]
-    fn test_writer_close_watchdog() {
+    fn test_writer_close_watchdog_with_write() {
         sync::model(|| {
             let channel = sync::Arc::new(SelfContainedChannel::<u32>::new());
             let writer = {
@@ -112,6 +112,23 @@ mod scchannel_tests {
         })
     }
 
+    #[test]
+    fn test_writer_close_watchdog_without_write() {
+        sync::model(|| {
+            let channel = sync::Arc::new(SelfContainedChannel::<u32>::new());
+            let reader = {
+                let channel = channel.clone();
+                sync::thread::spawn(move || unsafe { channel.receive() })
+            };
+            // Parallel with channel.receive()
+            channel.close_writer();
+            let res = reader.join().unwrap();
+            // We should either get the written value, or an error, depending on
+            // the execution order.
+            assert_eq!(res, Err(SelfContainedChannelError::WriterIsClosed));
+        })
+    }
+
     #[test]
     fn test_channel_reuse() {
         // Test reusing channels, using another channel to synchronize.