Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
342d30bbb8 | ||
|
|
268dd6240e | ||
|
|
9e60b3e1a4 | ||
|
|
1c6285f8af | ||
|
|
fff15bc627 | ||
|
|
a66157d611 |
+1
-1
@@ -1,7 +1,7 @@
|
|||||||
PATH
|
PATH
|
||||||
remote: .
|
remote: .
|
||||||
specs:
|
specs:
|
||||||
foreman (0.30.1)
|
foreman (0.31.0)
|
||||||
term-ansicolor (~> 1.0.5)
|
term-ansicolor (~> 1.0.5)
|
||||||
thor (>= 0.13.6)
|
thor (>= 0.13.6)
|
||||||
|
|
||||||
|
|||||||
@@ -58,7 +58,7 @@ private ######################################################################
|
|||||||
|
|
||||||
procfile.entries.each do |entry|
|
procfile.entries.each do |entry|
|
||||||
reader, writer = IO.pipe
|
reader, writer = IO.pipe
|
||||||
entry.spawn(concurrency[entry.name], writer, @directory, @environment, base_port).each do |process|
|
entry.spawn(concurrency[entry.name], writer, @directory, @environment, port_for(entry, 1, base_port)).each do |process|
|
||||||
running_processes[process.pid] = process
|
running_processes[process.pid] = process
|
||||||
readers[process] = reader
|
readers[process] = reader
|
||||||
end
|
end
|
||||||
@@ -71,6 +71,7 @@ private ######################################################################
|
|||||||
|
|
||||||
def kill_all(signal="SIGTERM")
|
def kill_all(signal="SIGTERM")
|
||||||
running_processes.each do |pid, process|
|
running_processes.each do |pid, process|
|
||||||
|
info "sending #{signal} to pid #{pid}"
|
||||||
Process.kill(signal, pid) rescue Errno::ESRCH
|
Process.kill(signal, pid) rescue Errno::ESRCH
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
+7
-10
@@ -28,21 +28,18 @@ class Foreman::Process
|
|||||||
private
|
private
|
||||||
|
|
||||||
def fork_with_io(command)
|
def fork_with_io(command)
|
||||||
io = case RUBY_VERSION
|
reader, writer = IO.pipe
|
||||||
when /^1\.9\./
|
pid = fork do
|
||||||
IO.popen([Foreman.runner, replace_command_env(command)], "w+")
|
trap("INT", "IGNORE")
|
||||||
when /^1\.8\./
|
$stdout.reopen writer
|
||||||
full_command = replace_command_env(command).gsub("'", "\\'")
|
reader.close
|
||||||
IO.popen("#{Foreman.runner} '#{full_command}'", "w+")
|
exec Foreman.runner, replace_command_env(command)
|
||||||
else
|
|
||||||
raise "Unknown Ruby version: #{RUBY_VERSION}"
|
|
||||||
end
|
end
|
||||||
[ io, io.pid ]
|
[ reader, pid ]
|
||||||
end
|
end
|
||||||
|
|
||||||
def run_process(command, pipe)
|
def run_process(command, pipe)
|
||||||
io, @pid = fork_with_io(command)
|
io, @pid = fork_with_io(command)
|
||||||
trap("SIGTERM") { "got sigterm for %d" % @pid }
|
|
||||||
output pipe, "started with pid %d" % @pid
|
output pipe, "started with pid %d" % @pid
|
||||||
Thread.new do
|
Thread.new do
|
||||||
until io.eof?
|
until io.eof?
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
module Foreman
|
module Foreman
|
||||||
|
|
||||||
VERSION = "0.30.1"
|
VERSION = "0.31.0"
|
||||||
|
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user