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
100
101
102
103
104
105
106
107
108
109
110
111
112
|
require File.expand_path('../../../spec_helper', __FILE__)
require File.expand_path('../../../fixtures/thread_runner', __FILE__)
describe "IO.select" do
before :each do
@rd, @wr = IO.pipe
end
after :each do
@rd.close unless @rd.closed?
@wr.close unless @wr.closed?
end
it "blocks for duration of timeout if there are no objects ready for I/O" do
timeout = 0.5
start = Time.now
IO.select [@rd], nil, nil, timeout
(Time.now - start).should be_close(timeout, 2.0)
end
it "returns immediately all objects that are ready for I/O when timeout is 0" do
@wr.write("be ready")
result = IO.select [@rd], [@wr], nil, 0
result.should == [[@rd], [@wr], []]
end
it "returns nil after timeout if there are no objects ready for I/O" do
result = IO.select [@rd], nil, nil, 0
result.should == nil
end
it "returns supplied objects when they are ready for I/O" do
t = Thread.new { sleep 0.5; @wr.write "be ready" }
t.abort_on_exception = true
result = IO.select [@rd], nil, nil, nil
result.should == [[@rd], [], []]
t.join
end
it "leaves out IO objects for which there is no I/O ready" do
@wr.write "be ready"
# Order matters here. We want to see that @wr doesn't expand the size
# of the returned array, so it must be 1st.
result = IO.select [@wr, @rd], nil, nil, nil
result.should == [[@rd], [], []]
end
it "returns supplied objects correctly even when monitoring the same object in different arrays" do
filename = tmp("IO_select_pipe_file") + $$.to_s
io = File.open(filename, 'w+')
result = IO.select [io], [io], nil, 0
result.should == [[io], [io], []]
io.close
rm_r filename
end
it "invokes to_io on supplied objects that are not IO and returns the supplied objects" do
# make some data available
@wr.write("foobar")
obj = mock("read_io")
obj.should_receive(:to_io).at_least(1).and_return(@rd)
IO.select([obj]).should == [[obj], [], []]
obj = mock("write_io")
obj.should_receive(:to_io).at_least(1).and_return(@wr)
IO.select(nil, [obj]).should == [[], [obj], []]
end
it "raises TypeError if supplied objects are not IO" do
lambda { IO.select([Object.new]) }.should raise_error(TypeError)
lambda { IO.select(nil, [Object.new]) }.should raise_error(TypeError)
obj = mock("io")
obj.should_receive(:to_io).any_number_of_times.and_return(nil)
lambda { IO.select([obj]) }.should raise_error(TypeError)
lambda { IO.select(nil, [obj]) }.should raise_error(TypeError)
end
it "raises a TypeError if the specified timeout value is not Numeric" do
lambda { IO.select([@rd], nil, nil, Object.new) }.should raise_error(TypeError)
end
it "raises TypeError if the first three arguments are not Arrays" do
lambda { IO.select(Object.new)}.should raise_error(TypeError)
lambda { IO.select(nil, Object.new)}.should raise_error(TypeError)
lambda { IO.select(nil, nil, Object.new)}.should raise_error(TypeError)
end
it "raises an ArgumentError when passed a negative timeout" do
lambda { IO.select(nil, nil, nil, -5)}.should raise_error(ArgumentError)
end
end
describe "IO.select when passed nil for timeout" do
it "sleeps forever" do
t = ThreadRunner.new do
IO.select(nil, nil, nil, nil)
end
t.status.should == :killed
end
it "sets the thread's status to 'sleep'" do
t = ThreadRunner.new do
IO.select(nil, nil, nil, nil)
end
t.thread_status.should == "sleep"
end
end
|
