summaryrefslogtreecommitdiff
path: root/lib/custodian/worker.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/custodian/worker.rb')
-rw-r--r--lib/custodian/worker.rb92
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