Contents

module Eye::Process::Watchers

  def add_watchers(force = false)
    return unless self.up?

    remove_watchers if force

    if @watchers.blank?
      # default watcher :check_alive
      add_watcher(:check_alive, self[:check_alive_period]) do
        check_alive
      end

      if self[:check_identity]
        add_watcher(:check_identity, self[:check_identity_period]) do
          check_identity
        end
      end

      # monitor children pids
      if self[:monitor_children]
        add_watcher(:check_children, self[:children_update_period]) do
          add_or_update_children
        end
      end

      # monitor conditional watchers
      start_checkers
    else
      warn 'add_watchers failed, watchers are already present'
    end
  end

  def remove_watchers
    @watchers.each { |_, h| h[:timer].cancel }
    @watchers = {}
  end

private

  def add_watcher(type, period = 2, subject = nil, &block)
    return if @watchers[type]

    debug { "adding watcher: #{type}(#{period})" }

    timer = every(period.to_f) do
      debug { "check #{type}" }
      block.call(subject)
    end

    @watchers[type] ||= { timer: timer, subject: subject }
  end

  def start_checkers
    self[:checks].each { |name, cfg| start_checker(name, cfg) }
  end

  def start_checker(name, cfg)
    # cfg: {:type => :memory, :every => 5.seconds, :below => 100.megabytes, :times => [3, 5]}
    subject = Eye::Checker.create(pid, cfg, current_actor)
    add_watcher("check_#{name}".to_sym, subject.every, subject, &method(:watcher_tick).to_proc) if subject
  end

  def watcher_tick(subject)
    # double up? test needed because state can changed while subject.check
    subject.fire if up? && !subject.check && up?
  end

end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
eye-0.9.2.nosigar	lib/eye/process/watchers.rb
eye-0.9.2	lib/eye/process/watchers.rb
eye-0.9.1	lib/eye/process/watchers.rb
eye-0.9.pre	lib/eye/process/watchers.rb
eye-0.8.1	lib/eye/process/watchers.rb
eye-0.8.celluloid15	lib/eye/process/watchers.rb
eye-0.8	lib/eye/process/watchers.rb
eye-0.8.rc	lib/eye/process/watchers.rb