class RRRSpec::Server::CLI
Public Instance Methods
server()
click to toggle source
# File lib/rrrspec/server/cli.rb, line 21 def server setup(ServerConfiguration.new) RRRSpec.configuration.daemonize = options[:daemonize] unless options[:daemonize] == nil RRRSpec.configuration.pidfile = options[:pidfile] unless options[:pidfile] == nil RRRSpec.configuration.user = options[:user] unless options[:user] == nil RRRSpec::Server.daemonizer('rrrspec-server server') do ActiveRecord::Base.establish_connection(**RRRSpec.configuration.persistence_db) Thread.abort_on_exception = true Thread.fork { Dispatcher.work_loop } Thread.fork { Arbiter.work_loop } Thread.fork { Persister.work_loop } Thread.fork { StatisticsUpdater.work_loop } Kernel.sleep end end
setup(conf)
click to toggle source
# File lib/rrrspec/server/cli.rb, line 12 def setup(conf) RRRSpec.setup(conf, options[:config].split(':')) end
worker()
click to toggle source
# File lib/rrrspec/server/cli.rb, line 43 def worker setup(WorkerConfiguration.new) RRRSpec.configuration.daemonize = options[:daemonize] unless options[:daemonize] == nil RRRSpec.configuration.pidfile = options[:pidfile] unless options[:pidfile] == nil RRRSpec.configuration.user = options[:user] unless options[:user] == nil RRRSpec::Server.daemonizer('rrrspec-server worker') do worker = Worker.create(options[:'worker-type'] || RRRSpec.configuration.worker_type) worker_runner = WorkerRunner.new(worker) Thread.abort_on_exception = true Thread.fork { RRRSpec.pacemaker(worker, 60, 5) } Thread.fork { worker_runner.work_loop } Kernel.sleep end end