class SystemdMon::CallbackManager
Attributes
queue[RW]
states[RW]
Public Class Methods
new(queue)
click to toggle source
# File lib/systemd_mon/callback_manager.rb, line 5 def initialize(queue) self.queue = queue self.states = Hash.new { |h, u| h[u] = UnitWithState.new(u) } end
Public Instance Methods
start(change_callback, each_state_change_callback)
click to toggle source
# File lib/systemd_mon/callback_manager.rb, line 10 def start(change_callback, each_state_change_callback) loop do unit, state = queue.deq Logger.debug { "#{unit} new state: #{state}" } unit_state = states[unit] unit_state << state if each_state_change_callback with_error_handling { each_state_change_callback.call(unit_state) } end if change_callback && unit_state.state_change.important? with_error_handling { change_callback.call(unit_state) } end unit_state.reset! if unit_state.state_change.important? end end
with_error_handling() { || ... }
click to toggle source
# File lib/systemd_mon/callback_manager.rb, line 29 def with_error_handling yield rescue => e Logger.error "Uncaught exception (#{e.class}) in callback: #{e.message}" Logger.debug_error { "\n\t#{e.backtrace.join("\n\t")}\n" } end