Contents

require 'pp'
require 'socket'
require_relative 'cfg'
require_relative 'database'
require_relative 'poller'
require_relative 'analyzer'
require_relative 'nodes'

module Ring
  class SQA
    def run
      Thread.abort_on_exception = true
      Thread.new { Responder.new }
      Thread.new { Sender.new @database, @nodes }
      Thread.new { Receiver.new @database }
      Analyzer.new(@database, @nodes).run
    end

    private

    def initialize
      require_relative 'log'
      @database  = Database.new
      # make sure Ping is created
      raise "Table 'pings' does not exist" unless Ring::SQA::Database::Ping.table_exists?
      @nodes     = Nodes.new
      run
    end

  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
ring-sqa-0.4.2	lib/ring/sqa/core.rb
ring-sqa-0.4.1	lib/ring/sqa/core.rb
ring-sqa-0.3.1	lib/ring/sqa/core.rb
ring-sqa-0.3.0	lib/ring/sqa/core.rb
ring-sqa-0.2.2	lib/ring/sqa/core.rb
ring-sqa-0.2.1	lib/ring/sqa/core.rb
ring-sqa-0.2.0	lib/ring/sqa/core.rb
ring-sqa-0.1.12	lib/ring/sqa/core.rb
ring-sqa-0.1.11	lib/ring/sqa/core.rb
ring-sqa-0.1.10	lib/ring/sqa/core.rb
ring-sqa-0.1.9	lib/ring/sqa/core.rb
ring-sqa-0.1.8	lib/ring/sqa/core.rb
ring-sqa-0.1.7	lib/ring/sqa/core.rb
ring-sqa-0.1.6	lib/ring/sqa/core.rb
ring-sqa-0.1.5	lib/ring/sqa/core.rb
ring-sqa-0.1.4	lib/ring/sqa/core.rb
ring-sqa-0.1.3	lib/ring/sqa/core.rb