Contents

module Eye::Process::Children

  def add_children
    add_or_update_children
  end

  def add_or_update_children
    return unless self[:monitor_children]
    return unless self.up?
    return if @updating_children
    @updating_children = true

    unless self.pid
      warn "can't add children; pid not set"
      return
    end

    now_children = Eye::SystemResources.children(self.pid)
    new_children = []
    exist_children = []

    now_children.each do |child_pid|
      if self.children[child_pid]
        exist_children << child_pid
      else
        new_children << child_pid
      end
    end

    removed_children = self.children.keys - now_children

    if new_children.present?
      new_children.each do |child_pid|
        cfg = self[:monitor_children].try :update, notify: self[:notify]
        self.children[child_pid] = Eye::ChildProcess.new(child_pid, cfg, logger.prefix, current_actor)
      end
    end

    if removed_children.present?
      removed_children.each { |child_pid| remove_child(child_pid) }
    end

    h = { new: new_children.size, removed: removed_children.size, exists: exist_children.size }
    debug { "children info: #{h.inspect}" }

    @updating_children = false
    h
  end

  def remove_children
    # here should .keys (not each_key), as it copy array of keys
    children.keys.each { |child_pid| clear_child(child_pid) }
  end

  def remove_child(child_pid)
    clear_child(child_pid)
  end

  def clear_child(child_pid)
    child = self.children.delete(child_pid)
    child.destroy if child && child.alive?
  end

end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
eye-0.10.1.pre	lib/eye/process/children.rb
eye-0.10.0	lib/eye/process/children.rb
eye-0.10.0.alpha2	lib/eye/process/children.rb
eye-0.10.0.alpha	lib/eye/process/children.rb
eye-0.9.4.nosigar	lib/eye/process/children.rb
eye-0.9.4	lib/eye/process/children.rb
eye-0.9.3	lib/eye/process/children.rb