add tests for Close() behaviour

Author: Matthias Radestock

src/unit/TestSharedQueue.cs

@@ -65,6 +65,9 @@
 
 [TestFixture]
 public class TestSharedQueue {
+
+    public delegate void Thunk();
+
     public class DelayedEnqueuer
     {
         public SharedQueue m_q;
@@ -85,6 +88,13 @@ public static void EnqueueAfter(int delayMs, SharedQueue q, object v) {
         new Thread(new ThreadStart(de.Run)).Start();
     }
 
+    public static void ExpectEof(Thunk thunk) {
+        try {
+            thunk();
+            Assert.Fail("expected System.IO.EndOfStreamException");
+        } catch (System.IO.EndOfStreamException) {}
+    }
+
     public DateTime m_startTime;
 
     public void ResetTimer() {
@@ -248,4 +258,44 @@ public void TestDoublePoll() {
         Assert.IsTrue(r);
         Assert.AreEqual(123, v);
     }
+
+    [Test]
+    public void TestCloseWhenEmpty() {
+        SharedQueue q = new SharedQueue();
+        object v; 
+        q.Close();
+        ExpectEof(delegate () { q.Enqueue(1); });
+        ExpectEof(delegate () { q.Dequeue(); });
+        ExpectEof(delegate () { q.DequeueNoWait(0); });
+        ExpectEof(delegate () { q.Dequeue(1, out v); });
+    }
+
+    [Test]
+    public void TestCloseWhenFull() {
+        SharedQueue q = new SharedQueue();
+        object v; 
+        q.Enqueue(1);
+        q.Enqueue(2);
+        q.Enqueue(3);
+        q.Close();
+        ExpectEof(delegate () { q.Enqueue(4); });
+        Assert.AreEqual(1, q.Dequeue());
+        Assert.AreEqual(2, q.DequeueNoWait(0));
+        bool r = q.Dequeue(1, out v);
+        Assert.IsTrue(r);
+        Assert.AreEqual(3, v);
+        ExpectEof(delegate () { q.Dequeue(); });
+    }
+
+    [Test]
+    public void TestCloseWhenWaiting() {
+        SharedQueue q = new SharedQueue();
+        Thread t = new Thread(delegate() {
+                ExpectEof(delegate () { q.Dequeue(); });
+            });
+        t.Start();
+        Thread.Sleep(10);
+        q.Close();
+        t.Join();
+    }
 }