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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
require 'test/unit'
class TestOldThreadSelect < Test::Unit::TestCase
require '-test-/old_thread_select/old_thread_select'
ANCIENT_LINUX = RUBY_PLATFORM =~ /linux/ && `uname -r`.chomp < '2.6.32'
def with_pipe
r, w = IO.pipe
begin
yield r, w
ensure
r.close unless r.closed?
w.close unless w.closed?
end
end
def test_old_select_read_timeout
with_pipe do |r, w|
t0 = Time.now
rc = IO.old_thread_select([r.fileno], nil, nil, 0.001)
diff = Time.now - t0
assert_equal 0, rc
assert_operator diff, :>=, 0.001, "returned too early: diff=#{diff}"
end
end unless ANCIENT_LINUX
def test_old_select_error_timeout
bug5299 = '[ruby-core:39380]'
with_pipe do |r, w|
t0 = Time.now
rc = IO.old_thread_select(nil, nil, [r.fileno], 0.001)
diff = Time.now - t0
assert_equal 0, rc, bug5299
assert_operator diff, :>=, 0.001, "returned too early: diff=#{diff}"
end
end unless ANCIENT_LINUX
def test_old_select_false_positive
bug5306 = '[ruby-core:39435]'
with_pipe do |r2, w2|
with_pipe do |r, w|
t0 = Time.now
w.syswrite '.'
rfds = [ r.fileno, r2.fileno ]
rc = IO.old_thread_select(rfds, nil, nil, nil)
assert_equal [ r.fileno ], rfds, bug5306
assert_equal 1, rc, bug5306
end
end
end
def test_old_select_read_write_check
with_pipe do |r, w|
w.syswrite('.')
rc = IO.old_thread_select([r.fileno], nil, nil, nil)
assert_equal 1, rc
rc = IO.old_thread_select([r.fileno], [w.fileno], nil, nil)
assert_equal 2, rc
assert_equal '.', r.read(1)
rc = IO.old_thread_select([r.fileno], [w.fileno], nil, nil)
assert_equal 1, rc
end
end
def test_old_select_signal_safe
return unless Process.respond_to?(:kill)
received = false
trap(:INT) { received = true }
main = Thread.current
thr = Thread.new do
Thread.pass until main.stop?
Process.kill(:INT, $$)
true
end
rc = nil
diff = nil
with_pipe do |r,w|
assert_nothing_raised do
t0 = Time.now
rc = IO.old_thread_select([r.fileno], nil, nil, 1)
diff = Time.now - t0
end
end
unless ANCIENT_LINUX
assert_operator diff, :>=, 1, "interrupted or short wait: diff=#{diff}"
end
assert_equal 0, rc
assert_equal true, thr.value
assert_not_equal false, received, "SIGINT not received"
ensure
trap(:INT, "DEFAULT")
end
end
|
