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
|
require 'timeout'
describe ServerEngine::MultiSpawnServer do
include_context 'test server and worker'
context 'with command_sender=pipe' do
it 'starts worker processes' do
config = {workers: 2, command_sender: 'pipe', log_stdout: false, log_stderr: false}
s = ServerEngine::MultiSpawnServer.new(TestWorker) { config.dup }
t = Thread.new { s.main }
begin
wait_for_fork
Timeout.timeout(5) do
sleep(0.5) until test_state(:worker_run) == 2
end
test_state(:worker_run).should == 2
ensure
s.stop(true)
t.join
end
end
end
end
|
