kill osrm-routed if it refuses to shutdown in cuke tests

This commit is contained in:
Emil Tin 2012-12-15 17:01:24 +01:00
parent 7f7055a9e7
commit 7e9614b9ec

View File

@ -1,83 +1,90 @@
require 'socket'
require 'sys/proctable'
LAUNCH_TIMEOUT = 5
SHUTDOWN_TIMEOUT = 5
LAUNCH_TIMEOUT = 2
SHUTDOWN_TIMEOUT = 2
class OSRMLauncher
def initialize &block
Dir.chdir TEST_FOLDER do
begin
begin
Timeout.timeout(LAUNCH_TIMEOUT) do
osrm_up
wait_for_connection
end
rescue Timeout::Error
raise "*** Launching osrm-routed timed out."
end
launch
yield
ensure
begin
Timeout.timeout(SHUTDOWN_TIMEOUT) do
osrm_down
end
rescue Timeout::Error
raise "*** Shutting down osrm-routed timed out."
end
shutdown
end
end
end
end
def osrm_up?
if @pipe
begin
Process.getpgid @pipe.pid
true
rescue Errno::ESRCH
private
def launch
Timeout.timeout(LAUNCH_TIMEOUT) do
osrm_up
wait_for_connection
end
rescue Timeout::Error
raise "*** Launching osrm-routed timed out."
end
def shutdown
Timeout.timeout(SHUTDOWN_TIMEOUT) do
osrm_down
end
rescue Timeout::Error
kill
raise "*** Shutting down osrm-routed timed out."
end
def osrm_up?
if @pipe
begin
Process.getpgid @pipe.pid
true
rescue Errno::ESRCH
false
end
else
false
end
else
false
end
end
def osrm_up
return if osrm_up?
#exec avoids popen running osrm-routed inside a shell
#if the cmd is run inside a shell, popen returns the pid for the shell, and if we try to kill it,
#the child process is orphaned, and we can't terminate it.
@pipe = IO.popen('exec ../osrm-routed 1>>osrm-routed.log 2>>osrm-routed.log')
end
def osrm_down
if @pipe
Process.kill 'TERM', @pipe.pid
wait_for_shutdown
@pipe = nil
def osrm_up
return if osrm_up?
#exec avoids popen running osrm-routed inside a shell
#if the cmd is run inside a shell, popen returns the pid for the shell, and if we try to kill it,
#the child process is orphaned, and we can't terminate it.
@pipe = IO.popen('exec ../osrm-routed 1>>osrm-routed.log 2>>osrm-routed.log')
end
end
def kill
if @pipe
Process.kill 'KILL', @pipe.pid
def osrm_down
if @pipe
Process.kill 'TERM', @pipe.pid
wait_for_shutdown
end
end
end
def wait_for_connection
while true
begin
socket = TCPSocket.new('localhost', OSRM_PORT)
return
rescue Errno::ECONNREFUSED
def kill
if @pipe
Process.kill 'KILL', @pipe.pid
end
end
def wait_for_connection
while true
begin
socket = TCPSocket.new('localhost', OSRM_PORT)
return
rescue Errno::ECONNREFUSED
sleep 0.1
end
end
end
def wait_for_shutdown
while osrm_up?
sleep 0.1
end
end
end
def wait_for_shutdown
while osrm_up?
sleep 0.1
end
end