slightly better runner support

This commit is contained in:
John Bintz 2011-06-29 09:47:08 -04:00
parent 63b9fcae98
commit 4836e968d6
1 changed files with 24 additions and 10 deletions

View File

@ -13,18 +13,14 @@ module Guard
def start def start
kill_unmanaged_pid! if options[:force_run] kill_unmanaged_pid! if options[:force_run]
run_rails_command! run_rails_command!
count = 0 wait_for_pid
while !has_pid? && count < MAX_WAIT_COUNT
wait_for_pid_action
count += 1
end
!(count == MAX_WAIT_COUNT)
end end
def stop def stop
if File.file?(pid_file) if File.file?(pid_file)
system %{kill -KILL #{File.read(pid_file).strip}} system %{kill -KILL #{File.read(pid_file).strip}}
sleep sleep_time wait_for_no_pid if $?.exitstatus == 0
FileUtils.rm pid_file
end end
end end
@ -72,20 +68,38 @@ module Guard
def kill_unmanaged_pid! def kill_unmanaged_pid!
if pid = unmanaged_pid if pid = unmanaged_pid
system %{kill -KILL #{pid}} system %{kill -KILL #{pid}}
FileUtils.rm pid_file FileUtils.rm pid_file
wait_for_no_pid
end end
end end
def unmanaged_pid def unmanaged_pid
pid_command = "lsof -n -i TCP:#{options[:port]}" %x{lsof -n -i TCP:#{options[:port]}}.each_line { |line|
%x{#{pid_command}}.each_line { |line|
if line["*:#{options[:port]} "] if line["*:#{options[:port]} "]
return line.split("\s")[1] return line.split("\s")[1]
end end
} }
nil nil
end end
private
def wait_for_pid
wait_for_pid_loop
end
def wait_for_no_pid
wait_for_pid_loop(false)
end
def wait_for_pid_loop(check_for_existince = true)
count = 0
while !(check_for_existince ? has_pid? : !has_pid?) && count < MAX_WAIT_COUNT
wait_for_pid_action
count += 1
end
!(count == MAX_WAIT_COUNT)
end
end end
end end