bootstraptest/test_io.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

assert_finish 5, %q{
  r, w = IO.pipe
  t1 = Thread.new { r.sysread(1) }
  t2 = Thread.new { r.sysread(1) }
  sleep 0.1
  w.write "a"
  sleep 0.1
  w.write "a"
}, '[ruby-dev:31866]'

assert_finish 10, %q{
  require "io/nonblock"
  r, w = IO.pipe
  w.nonblock = true
  w.write_nonblock("a" * 100000)
  w.nonblock = false
  t1 = Thread.new { w.write("b" * 4096) }
  t2 = Thread.new { w.write("c" * 4096) }
  sleep 0.5
  r.sysread(4096).length
  sleep 0.5
  r.sysread(4096).length
  t1.join
  t2.join
}, '[ruby-dev:32566]'