Class: Sonar::Connector::Controller
- Inherits:
-
Object
- Object
- Sonar::Connector::Controller
- Defined in:
- lib/sonar_connector/controller.rb
Constant Summary collapse
- DEFAULT_CONFIG_FILENAME =
File.join("config", "config.json")
Instance Attribute Summary collapse
-
#config ⇒ Object
readonly
instance of Sonar::Connector::Config.
-
#connectors ⇒ Object
readonly
array of instantiated connector instances.
-
#consumer ⇒ Object
readonly
instance of Sonar::Connector::Consumer.
-
#log ⇒ Object
readonly
controller logger.
-
#queue ⇒ Object
readonly
single command queue for threads to communicate with the controller.
-
#status ⇒ Object
readonly
instance of Sonar::Connector::Status.
-
#threads ⇒ Object
readonly
array of threads.
Instance Method Summary collapse
-
#initialize(config_filename = DEFAULT_CONFIG_FILENAME) ⇒ Controller
constructor
Parse the config file and create instances of each connector, parsing their config in turn.
- #prepare_connector ⇒ Object
- #shutdown_lambda ⇒ Object
- #start ⇒ Object
-
#start_console ⇒ Object
prepare the connector, start an IRB console, but don’t start any threads.
-
#start_threads ⇒ Object
Main framework loop.
- #switch_to_log_file ⇒ Object
Constructor Details
#initialize(config_filename = DEFAULT_CONFIG_FILENAME) ⇒ Controller
Parse the config file and create instances of each connector, parsing their config in turn.
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/sonar_connector/controller.rb', line 41 def initialize(config_filename = DEFAULT_CONFIG_FILENAME) @config = Sonar::Connector::Config.load config_filename @log = Sonar::Connector::Utils.stdout_logger @config @connectors = @config.connectors @consumer = Sonar::Connector::Consumer.new(self, @config) @threads = [] @queue = Queue.new create_startup_dirs_and_files rescue Sonar::Connector::InvalidConfig => e $stderr << ([e.class.to_s, e., *e.backtrace].join("\n")) << "\n" raise RuntimeError, "Invalid configuration in #{config_filename}: \n #{e.}" end |
Instance Attribute Details
#config ⇒ Object (readonly)
instance of Sonar::Connector::Config
24 25 26 |
# File 'lib/sonar_connector/controller.rb', line 24 def config @config end |
#connectors ⇒ Object (readonly)
array of instantiated connector instances
16 17 18 |
# File 'lib/sonar_connector/controller.rb', line 16 def connectors @connectors end |
#consumer ⇒ Object (readonly)
instance of Sonar::Connector::Consumer
20 21 22 |
# File 'lib/sonar_connector/controller.rb', line 20 def consumer @consumer end |
#log ⇒ Object (readonly)
controller logger
32 33 34 |
# File 'lib/sonar_connector/controller.rb', line 32 def log @log end |
#queue ⇒ Object (readonly)
single command queue for threads to communicate with the controller
12 13 14 |
# File 'lib/sonar_connector/controller.rb', line 12 def queue @queue end |
#status ⇒ Object (readonly)
instance of Sonar::Connector::Status
28 29 30 |
# File 'lib/sonar_connector/controller.rb', line 28 def status @status end |
#threads ⇒ Object (readonly)
array of threads
36 37 38 |
# File 'lib/sonar_connector/controller.rb', line 36 def threads @threads end |
Instance Method Details
#prepare_connector ⇒ Object
86 87 88 89 90 91 92 93 94 95 96 97 |
# File 'lib/sonar_connector/controller.rb', line 86 def prepare_connector switch_to_log_file log_startup_params connectors.each do |connector| log.info "preparing connector '#{connector.name}'" connector.prepare(queue) end log.info "preparing message queue consumer" consumer.prepare(queue) end |
#shutdown_lambda ⇒ Object
114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 |
# File 'lib/sonar_connector/controller.rb', line 114 def shutdown_lambda lambda do puts "\nGiving threads 10 seconds to shut down..." threads.each{|t| t.raise(ThreadTerminator)} begin Timeout::timeout(10) { threads.map(&:join) } rescue Timeout::Error puts "...couldn't stop all threads cleanly." log.info "Could not cleanly terminate all threads." log.close exit(1) rescue ThreadTerminator # ignore it, since it's come from one of the recently-nuked threads. rescue Exception => e log.debug ["Caught unhandled exception: ", e.class.to_s, e., *e.backtrace].join("\n") end puts "...exited cleanly." log.info "Terminated all threads cleanly." log.close exit(0) end end |
#start ⇒ Object
62 63 64 65 66 67 68 69 70 71 72 73 74 |
# File 'lib/sonar_connector/controller.rb', line 62 def start prepare_connector start_threads # let the controlling thread go into an endless sleep puts "Ctrl-C to stop." # Standardize shutdown via ctrl-c and SIGTERM (from god) trap "SIGINT", shutdown_lambda trap "SIGTERM", shutdown_lambda endless_sleep end |
#start_console ⇒ Object
prepare the connector, start an IRB console, but don’t start any threads
77 78 79 80 81 82 83 84 |
# File 'lib/sonar_connector/controller.rb', line 77 def start_console prepare_connector # make the Controller globally visible Connector.const_set("CONTROLLER", self) require 'irb' IRB.start end |
#start_threads ⇒ Object
Main framework loop. Fire up one thread per connector, plus the message queue consumer. Then wait for quit signal.
102 103 104 105 106 107 108 109 110 111 |
# File 'lib/sonar_connector/controller.rb', line 102 def start_threads # fire up the connector threads connectors.each do |connector| log.info "starting connector '#{connector.name}'" threads << Thread.new { connector.start } end log.info "starting the message queue consumer" threads << Thread.new{ consumer.watch } end |
#switch_to_log_file ⇒ Object
58 59 60 |
# File 'lib/sonar_connector/controller.rb', line 58 def switch_to_log_file @log = Sonar::Connector::Utils.disk_logger(config.controller_log_file, config) end |