Fresh start

1 files changed, 52 insertions, 0 deletions

diff --git a/jni/ruby/test/io/nonblock/test_flush.rb b/jni/ruby/test/io/nonblock/test_flush.rb
new file mode 100644
index 0000000..ab54205
--- /dev/null
+++ b/jni/ruby/test/io/nonblock/test_flush.rb
@@ -0,0 +1,52 @@
+require 'test/unit'
+require 'timeout'
+begin
+  require 'io/nonblock'
+rescue LoadError
+end
+
+class TestIONonblock < Test::Unit::TestCase
+  def test_flush
+    IO.pipe {|r, w|
+      return if flush_test(r, w)
+    }
+    require 'socket';
+    Socket.pair(:INET, :STREAM) {|s1, s2|
+      return if flush_test(s1, s2)
+    }
+    skip "nonblocking IO did not work"
+  end
+
+  def flush_test(r, w)
+    begin
+      w.nonblock = true
+    rescue Errno::EBADF
+      return false
+    end
+    w.sync = false
+    w << "b"
+    w.flush
+    w << "a" * 4096
+    result = ""
+    timeout(10) {
+      t0 = Thread.new {
+        Thread.pass
+        w.close
+      }
+      t = Thread.new {
+        while (Thread.pass; s = r.read(4096))
+          result << s
+        end
+      }
+      begin
+        w.flush # assert_raise(IOError, "[ruby-dev:24985]") {w.flush}
+      rescue Errno::EBADF, IOError
+        # ignore [ruby-dev:35638]
+      end
+      assert_nothing_raised {t.join}
+      t0.join
+    }
+    assert_equal(4097, result.size)
+    true
+  end
+end if IO.method_defined?(:nonblock)