Class: PerfectQueue::Multiprocess::ChildProcessMonitor

Inherits:
Object
  • Object
show all
Defined in:
lib/perfectqueue/multiprocess/child_process_monitor.rb

Instance Method Summary collapse

Constructor Details

#initialize(log, pid, rpipe) ⇒ ChildProcessMonitor

Returns a new instance of ChildProcessMonitor.



23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/perfectqueue/multiprocess/child_process_monitor.rb', line 23

def initialize(log, pid, rpipe)
  @log = log
  @pid = pid
  @rpipe = rpipe
  @last_heartbeat = Time.now.to_i

  @kill_start_time = nil
  @last_kill_time = nil
  @kill_immediate = false

  @rbuf = ''
end

Instance Method Details

#check_heartbeat(limit) ⇒ Object 



36
37
38
39
40
41
42
 
# File 'lib/perfectqueue/multiprocess/child_process_monitor.rb', line 36

def check_heartbeat(limit)
  @rpipe.read_nonblock(1024, @rbuf)
  @last_heartbeat = Time.now.to_i
  return true
rescue Errno::EINTR, Errno::EAGAIN
  return Time.now.to_i - @last_heartbeat <= limit
end

#cleanup ⇒ Object 



79
80
81
 
# File 'lib/perfectqueue/multiprocess/child_process_monitor.rb', line 79

def cleanup
  @rpipe.close unless @rpipe.closed?
end

#send_signal(sig) ⇒ Object 



83
84
85
86
87
88
89
 
# File 'lib/perfectqueue/multiprocess/child_process_monitor.rb', line 83

def send_signal(sig)
  begin
    Process.kill(sig, @pid)
  rescue Errno::ESRCH, Errno::EPERM
    # TODO log?
  end
end

#start_killing(immediate) ⇒ Object 



44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/perfectqueue/multiprocess/child_process_monitor.rb', line 44

def start_killing(immediate)
  if immediate && !@kill_immediate
    @kill_immediate = true  # escalation
  elsif @kill_start_time
    return
  end

  now = Time.now.to_i
  kill_child(now, nil)
  @kill_start_time = now
end

#try_join(kill_interval, graceful_kill_limit) ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/perfectqueue/multiprocess/child_process_monitor.rb', line 56

def try_join(kill_interval, graceful_kill_limit)
  return nil unless @kill_start_time

  begin
    if Process.waitpid(@pid, Process::WNOHANG)
      @log.info "Worker exited pid=#{@pid}"
      return true
    end
  rescue Errno::ECHILD
    # SIGCHLD is trapped in Worker#install_signal_handlers
    @log.info "Worker exited pid=#{@pid}"
    return true
  end

  # resend signal
  now = Time.now.to_i
  if @last_kill_time + kill_interval <= now
    kill_child(now, graceful_kill_limit)
  end

  return false
end