Contents

# -*- encoding: utf-8 -*-
module Bluepill
  class Group
    attr_accessor :name, :processes, :logger
    attr_accessor :process_logger

    def initialize(name, options = {})
      self.name = name
      self.processes = []
      self.logger = options[:logger]
    end

    def add_process(process)
      process.logger = self.logger
      self.processes << process
    end

    def tick
      self.processes.each do |process|
        process.tick
      end
    end

    def determine_initial_state
      self.processes.each do |process|
        process.determine_initial_state
      end
    end

    # proxied events
    [:start, :unmonitor, :stop, :restart].each do |event|
      class_eval <<-END
        def #{event}(process_name = nil)
          threads = []
          affected = []
          self.processes.each do |process|
            next if process_name && process_name != process.name
            affected << [self.name, process.name].join(":")
            threads << Thread.new { process.handle_user_command("#{event}") }
          end
          threads.each { |t| t.join }
          affected
        end
      END
    end

    def status(process_name = nil)
      lines = []
      if process_name.nil?
        prefix = self.name ? "  " : ""
        lines << "#{self.name}:" if self.name

        self.processes.each do |process|
          lines << "%s%s(pid:%s): %s" % [prefix, process.name, process.actual_pid, process.state]
          if process.monitor_children?
            process.children.each do |child|
              lines << "  %s%s: %s" % [prefix, child.name, child.state]
            end
          end
        end
      else
        self.processes.each do |process|
          next if process_name != process.name
          lines << "%s%s(pid:%s): %s" % [prefix, process.name, process.actual_pid, process.state]
          lines << process.statistics.to_s
        end
      end
      lines << ""
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
kostya-bluepill-0.0.60.2	lib/bluepill/group.rb
kostya-bluepill-0.0.60.1	lib/bluepill/group.rb