diff options
Diffstat (limited to 'jni/ruby/test/io/nonblock/test_flush.rb')
-rw-r--r-- | jni/ruby/test/io/nonblock/test_flush.rb | 52 |
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) |