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
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
|
# frozen_string_literal: true
require "spec_helper"
describe ParallelTests do
describe ".determine_number_of_processes" do
before do
allow(Parallel).to receive(:processor_count).and_return 20
end
def call(count)
ParallelTests.determine_number_of_processes(count)
end
it "uses the given count if set" do
expect(call('5')).to eq(5)
end
it "uses the processor count from Parallel" do
expect(call(nil)).to eq(20)
end
it "uses the processor count from ENV before Parallel" do
ENV['PARALLEL_TEST_PROCESSORS'] = '22'
expect(call(nil)).to eq(22)
end
it "does not use blank count" do
expect(call(' ')).to eq(20)
end
it "does not use blank env" do
ENV['PARALLEL_TEST_PROCESSORS'] = ' '
expect(call(nil)).to eq(20)
end
end
describe ".bundler_enabled?" do
before do
allow(Object).to receive(:const_defined?).with(:Bundler).and_return false
end
it "is false" do
use_temporary_directory do
expect(ParallelTests.send(:bundler_enabled?)).to eq(false)
end
end
it "is true when there is a constant called Bundler" do
use_temporary_directory do
allow(Object).to receive(:const_defined?).with(:Bundler).and_return true
expect(ParallelTests.send(:bundler_enabled?)).to eq(true)
end
end
it "is true when there is a Gemfile" do
use_temporary_directory do
FileUtils.touch("Gemfile")
expect(ParallelTests.send(:bundler_enabled?)).to eq(true)
end
end
it "is true when there is a Gemfile in the parent directory" do
use_temporary_directory do
FileUtils.mkdir "nested"
Dir.chdir "nested" do
FileUtils.touch(File.join("..", "Gemfile"))
expect(ParallelTests.send(:bundler_enabled?)).to eq(true)
end
end
end
end
describe ".wait_for_other_processes_to_finish" do
around do |example|
ParallelTests.with_pid_file do
example.run
end
end
def with_running_processes(count, wait = 0.2)
count.times { |x| ParallelTests.pids.add(x) }
sleep 0.1
yield
ensure
sleep wait # make sure the threads have finished
end
it "does not wait if not run in parallel" do
expect(ParallelTests).not_to receive(:sleep)
ParallelTests.wait_for_other_processes_to_finish
end
it "stops if only itself is running" do
ParallelTests.pids.add(123)
expect(ParallelTests).not_to receive(:sleep)
with_running_processes(1) do
ParallelTests.wait_for_other_processes_to_finish
end
end
it "waits for other processes to finish" do
skip if RUBY_PLATFORM == "java"
ENV["TEST_ENV_NUMBER"] = "2"
counter = 0
allow(ParallelTests).to receive(:sleep) do
sleep 0.1
ParallelTests.pids.delete(1) if counter > 3
counter += 1
end
with_running_processes(2, 0.6) do
ParallelTests.wait_for_other_processes_to_finish
end
expect(counter).to be >= 2
end
end
describe ".number_of_running_processes" do
around do |example|
ParallelTests.with_pid_file do
example.run
end
end
it "is 0 for nothing" do
expect(ParallelTests.number_of_running_processes).to eq(0)
end
it "is 2 when 2 are running" do
wait = 0.2
2.times { |_x| ParallelTests.pids.add(123) }
sleep wait / 2
expect(ParallelTests.number_of_running_processes).to eq(2)
sleep wait
end
end
describe ".first_process?" do
it "is first if no env is set" do
expect(ParallelTests.first_process?).to eq(true)
end
it "is first if env is set to blank" do
ENV["TEST_ENV_NUMBER"] = ""
expect(ParallelTests.first_process?).to eq(true)
end
it "is first if env is set to 1" do
ENV["TEST_ENV_NUMBER"] = "1"
expect(ParallelTests.first_process?).to eq(true)
end
it "is not first if env is set to something else" do
ENV["TEST_ENV_NUMBER"] = "2"
expect(ParallelTests.first_process?).to eq(false)
end
end
describe ".last_process?" do
it "is last if no envs are set" do
expect(ParallelTests.last_process?).to eq(true)
end
it "is last if envs are set to blank" do
ENV["TEST_ENV_NUMBER"] = ""
ENV["PARALLEL_TEST_GROUPS"] = ""
expect(ParallelTests.last_process?).to eq(true)
end
it "is last if TEST_ENV_NUMBER is set to PARALLEL_TEST_GROUPS" do
ENV["TEST_ENV_NUMBER"] = "4"
ENV["PARALLEL_TEST_GROUPS"] = "4"
expect(ParallelTests.last_process?).to eq(true)
end
it "is not last if TEST_ENV_NUMBER is set to else" do
ENV["TEST_ENV_NUMBER"] = "2"
ENV["PARALLEL_TEST_GROUPS"] = "4"
expect(ParallelTests.first_process?).to eq(false)
end
end
describe ".stop_all_processes" do
# Process.kill on Windows doesn't work as expected. It kills all process group instead of just one process.
it 'kills the running child process', unless: Gem.win_platform? do
ParallelTests.with_pid_file do
Thread.new do
ParallelTests::Test::Runner.execute_command(['sleep', '3'], 1, 1, {})
end
sleep(0.2)
expect(ParallelTests.pids.count).to eq(1)
ParallelTests.stop_all_processes
sleep(0.2)
expect(ParallelTests.pids.count).to eq(0)
end
end
end
it "has a version" do
expect(ParallelTests::VERSION).to match(/^\d+\.\d+\.\d+/)
end
end
|
