diff options
Diffstat (limited to 'lib/custodian/worker.rb')
| -rw-r--r-- | lib/custodian/worker.rb | 92 |
1 files changed, 46 insertions, 46 deletions
diff --git a/lib/custodian/worker.rb b/lib/custodian/worker.rb index e5df5e5..746416f 100644 --- a/lib/custodian/worker.rb +++ b/lib/custodian/worker.rb @@ -67,13 +67,13 @@ module Custodian # # Connect to the queue, and record interesting settings away. # - def initialize( settings ) + def initialize(settings) # Save the settings @settings = settings # Connect to the queue - @queue = QueueType.create( @settings.queue_type ) + @queue = QueueType.create(@settings.queue_type) # Get the alerter-type(s) to instantiate @alerter = @settings.alerter @@ -92,7 +92,7 @@ module Custodian # # Show a message on STDOUT if "--verbose" was specified. # - def log_message( msg ) + def log_message(msg) puts msg if ENV['VERBOSE' ] end @@ -103,8 +103,8 @@ module Custodian # Process jobs from the queue - never return. # def run! - while( true ) - log_message( 'Waiting for job..' ) + while(true) + log_message('Waiting for job..') process_single_job end end @@ -131,8 +131,8 @@ module Custodian # # Create test-objects from our class-factory, and process them. # - Custodian::TestFactory.create( job ).each do |test| - process_single_test( test ) + Custodian::TestFactory.create(job).each do |test| + process_single_test(test) end end @@ -144,11 +144,11 @@ module Custodian # # Any test which fails for N-times in a row will raise an alert. # - def process_single_test( test ) + def process_single_test(test) begin - log_message( "Acquired job: #{test}" ) + log_message("Acquired job: #{test}") # # The count of times this test has run, the result, and the start-time @@ -162,9 +162,9 @@ module Custodian # # We exit here if we receive a single success. # - while ( count < ( @retry_count + 1 ) ) && ( result == false ) + while (count < (@retry_count + 1)) && (result == false) - log_message( "Running test - [#{count}/#{@retry_count}]" ) + log_message("Running test - [#{count}/#{@retry_count}]") # # Run the test - inverting the result if we should @@ -173,8 +173,8 @@ module Custodian result = ! result if test.inverted if result - log_message( 'Test succeeed - clearing alert' ) - do_clear( test ) + log_message('Test succeeed - clearing alert') + do_clear(test) end # @@ -186,9 +186,9 @@ module Custodian # The intention here is that if the test passes then there will # be no delay. If the test fails then we'll sleep. # - if ( result == false ) && ( @retry_delay > 0 ) && ( count < @retry_count ) - log_message( "Sleeping for #{@retry_delay} seconds to allow cool-down" ) - sleep( @retry_delay ) + if (result == false) && (@retry_delay > 0) && (count < @retry_count) + log_message("Sleeping for #{@retry_delay} seconds to allow cool-down") + sleep(@retry_delay) end # @@ -205,14 +205,14 @@ module Custodian # # Duration of the test-run, in milliseconds # - duration = (( end_time - start_time ) * 1000.0).to_i + duration = ((end_time - start_time) * 1000.0).to_i # # Record that, if we have any alerters that are interested # in run-times. # - do_duration( test, duration ) + do_duration(test, duration) # @@ -223,12 +223,12 @@ module Custodian # # Raise the alert, passing the error message. # - log_message( "Test failed - alerting with #{test.error}" ) - do_raise( test ) + log_message("Test failed - alerting with #{test.error}") + do_raise(test) end rescue => ex - log_message( "Exception raised processing job: #{ex}" ) + log_message("Exception raised processing job: #{ex}") end @@ -239,18 +239,18 @@ module Custodian # # Raise an alert, with each registered alerter. # - def do_raise( test ) - @alerter.split( ',' ).each do |alerter| + def do_raise(test) + @alerter.split(',').each do |alerter| - log_message( "Creating alerter: #{alerter}" ) - alert = Custodian::AlertFactory.create( alerter, test ) + log_message("Creating alerter: #{alerter}") + alert = Custodian::AlertFactory.create(alerter, test) - target = @settings.alerter_target( alerter ) - alert.set_target( target ) + target = @settings.alerter_target(alerter) + alert.set_target(target) log_message("Target for alert is #{target}") # give the alerter a reference to the settings object. - alert.set_settings( @settings ) + alert.set_settings(@settings) alert.raise end @@ -260,17 +260,17 @@ module Custodian # # Clear an alert, with each registered alerter. # - def do_clear( test ) - @alerter.split( ',' ).each do |alerter| - log_message( "Creating alerter: #{alerter}" ) - alert = Custodian::AlertFactory.create( alerter, test ) + def do_clear(test) + @alerter.split(',').each do |alerter| + log_message("Creating alerter: #{alerter}") + alert = Custodian::AlertFactory.create(alerter, test) - target = @settings.alerter_target( alerter ) - alert.set_target( target ) - log_message( "Target for alert is #{target}" ) + target = @settings.alerter_target(alerter) + alert.set_target(target) + log_message("Target for alert is #{target}") # give the alerter a reference to the settings object. - alert.set_settings( @settings ) + alert.set_settings(@settings) alert.clear end @@ -279,19 +279,19 @@ module Custodian # # Log the test duration with each registered alerter. # - def do_duration( test, duration ) - @alerter.split( ',' ).each do |alerter| - log_message( "Creating alerter: #{alerter}" ) - alert = Custodian::AlertFactory.create( alerter, test ) + def do_duration(test, duration) + @alerter.split(',').each do |alerter| + log_message("Creating alerter: #{alerter}") + alert = Custodian::AlertFactory.create(alerter, test) - target = @settings.alerter_target( alerter ) - alert.set_target( target ) - log_message( "Target for alert is #{target}" ) + target = @settings.alerter_target(alerter) + alert.set_target(target) + log_message("Target for alert is #{target}") # give the alerter a reference to the settings object. - alert.set_settings( @settings ) + alert.set_settings(@settings) - alert.duration( duration ) if alert.respond_to? 'duration' + alert.duration(duration) if alert.respond_to? 'duration' end end @@ -300,7 +300,7 @@ module Custodian # Process jobs until we see a failure, then stop. # def process_until_fail - while( process_single_job ) + while(process_single_job) # nop end end |