Compare commits

...
3 Commits
Author SHA1 Message Date
David Dollar 7bb1e58879 0.8.0 2010-09-20 16:22:31 -04:00
David Dollar 62b6cac741 print message when signal received 2010-09-20 16:22:13 -04:00
Keith Rarick 2a7dadc2b2 Wait cleanly for child processes to exit.
Signed-off-by: David Dollar <ddollar@gmail.com>
2010-09-20 16:21:41 -04:00
2 changed files with 8 additions and 10 deletions
+1 -1
View File
@@ -1,6 +1,6 @@
module Foreman module Foreman
VERSION = "0.7.5" VERSION = "0.8.0"
class AppDoesNotExist < Exception; end class AppDoesNotExist < Exception; end
+7 -9
View File
@@ -39,8 +39,8 @@ class Foreman::Engine
fork process, options fork process, options
end end
trap("TERM") { kill_and_exit("TERM") } trap("TERM") { puts "SIGTERM received"; kill_all("TERM") }
trap("INT") { kill_and_exit("INT") } trap("INT") { puts "SIGINT received"; kill_all("INT") }
watch_for_termination watch_for_termination
end end
@@ -48,8 +48,8 @@ class Foreman::Engine
def execute(name, options={}) def execute(name, options={})
fork processes[name], options fork processes[name], options
trap("TERM") { kill_and_exit("TERM") } trap("TERM") { puts "SIGTERM received"; kill_all("TERM") }
trap("INT") { kill_and_exit("INT") } trap("INT") { puts "SIGINT received"; kill_all("INT") }
watch_for_termination watch_for_termination
end end
@@ -97,18 +97,15 @@ private ######################################################################
rescue PTY::ChildExited, Interrupt rescue PTY::ChildExited, Interrupt
info "process exiting", process info "process exiting", process
end end
Process.waitall
end end
end end
def kill_and_exit(signal="TERM") def kill_all(signal="TERM")
info "terminating" info "terminating"
running_processes.each do |pid, process| running_processes.each do |pid, process|
info "killing #{process.name} in pid #{pid}" info "killing #{process.name} in pid #{pid}"
Process.kill(signal, pid) Process.kill(signal, pid)
end end
Process.waitall
exit 0
end end
def info(message, process=nil) def info(message, process=nil)
@@ -151,7 +148,8 @@ private ######################################################################
pid, status = Process.wait2 pid, status = Process.wait2
process = running_processes.delete(pid) process = running_processes.delete(pid)
info "process terminated", process info "process terminated", process
kill_and_exit kill_all
Process.waitall
end end
def running_processes def running_processes