Module: Delayed::Worker::ProcessHelper

Defined in:
lib/delayed/worker/process_helper.rb

Constant Summary collapse

STAT_LINUX = 
'stat --format=%%Y /proc/$WORKER_PID'
STAT_MAC = 
'ps -o lstart -p $WORKER_PID'
STAT = 
RUBY_PLATFORM =~ /darwin/ ? STAT_MAC : STAT_LINUX
ALIVE_CHECK_LINUX = 
'[ -d "/proc/$WORKER_PID" ]'
ALIVE_CHECK_MAC = 
'ps -p $WORKER_PID > /dev/null'
ALIVE_CHECK = 
RUBY_PLATFORM =~ /darwin/ ? ALIVE_CHECK_MAC : ALIVE_CHECK_LINUX
SCRIPT_TEMPLATE = 
<<-BASH.freeze
  WORKER_PID="%<pid>d" # an example, filled from ruby when the check is created
  ORIGINAL_MTIME="%<mtime>s" # an example, filled from ruby when the check is created

  if #{ALIVE_CHECK}; then
      CURRENT_MTIME=$(#{STAT})

      if [ "$ORIGINAL_MTIME" = "$CURRENT_MTIME" ]; then
          exit 0 # Happy day
      else
          echo "PID still exists but procfs entry has changed, current command:"
          ps -p $WORKER_PID -o 'command='
          exit 1 # Something is wrong, trigger a "warning" state
      fi
  else
      exit 255 # The process is no more, trigger a "critical" state.
  fi
BASH

Class Method Summary collapse

Class Method Details

.check_script(pid, mtime) ⇒ Object 



38
39
40
 
# File 'lib/delayed/worker/process_helper.rb', line 38

def self.check_script(pid, mtime)
  sprintf(SCRIPT_TEMPLATE, {pid: pid, mtime: mtime})
end

.mtime(pid) ⇒ Object 



30
31
32
33
34
35
36
 
# File 'lib/delayed/worker/process_helper.rb', line 30

def self.mtime(pid)
  if RUBY_PLATFORM =~ /darwin/
    `ps -o lstart -p #{pid}`.sub(/\n$/, '').presence
  else
    File::Stat.new("/proc/#{pid}").mtime.to_i.to_s rescue nil
  end
end

.process_is_still_running?(pid, mtime) ⇒ Boolean

Returns:

  • (Boolean) 


42
43
44
 
# File 'lib/delayed/worker/process_helper.rb', line 42

def self.process_is_still_running?(pid, mtime)
  system(self.check_script(pid, mtime))
end