Contents

# frozen_string_literal: true

module God
  module Conditions
    # Trigger when a process exits.
    #
    #     +pid_file+ is the pid file of the process in question. Automatically
    #                populated for Watches.
    #
    # Examples
    #
    #   # Trigger if process exits (from a Watch).
    #   on.condition(:process_exits)
    #
    #   # Trigger if process exits (non-Watch).
    #   on.condition(:process_exits) do |c|
    #     c.pid_file = "/var/run/mongrel.3000.pid"
    #   end
    class ProcessExits < EventCondition
      # The String PID file location of the process in question. Automatically
      # populated for Watches.
      attr_accessor :pid_file

      def initialize
        super
        self.info = 'process exited'
      end

      def valid?
        true
      end

      def pid
        pid_file ? File.read(pid_file).strip.to_i : watch.pid
      end

      def register
        pid = self.pid

        begin
          EventHandler.register(pid, :proc_exit) do |extra|
            formatted_extra = extra.empty? ? '' : " #{extra.inspect}"
            self.info = "process #{pid} exited#{formatted_extra}"
            watch.trigger(self)
          end

          msg = "#{watch.name} registered 'proc_exit' event for pid #{pid}"
          applog(watch, :info, msg)
        rescue StandardError
          raise EventRegistrationFailedError
        end
      end

      def deregister
        pid = self.pid
        if pid
          EventHandler.deregister(pid, :proc_exit)

          msg = "#{watch.name} deregistered 'proc_exit' event for pid #{pid}"
          applog(watch, :info, msg)
        else
          pid_file_location = pid_file || watch.pid_file
          applog(watch, :error, "#{watch.name} could not deregister: no cached PID or PID file #{pid_file_location} (#{base_name})")
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
resurrected_god-1.1.1	lib/god/conditions/process_exits.rb
resurrected_god-1.1.0	lib/god/conditions/process_exits.rb