Revision 35bb7807
Added by Kavita Gaikwad over 6 years ago
| definitions/features/katello_service.rb | ||
|---|---|---|
|
label :katello_service
|
||
|
end
|
||
|
|
||
|
RETRIES_FOR_SERVICES_RESTART = 5
|
||
|
PING_RETRY_INTERVAL = 30
|
||
|
|
||
|
def make_stop(spinner, options = {})
|
||
|
services = find_services_for_only_filter(running_services, options)
|
||
|
if services.empty?
|
||
| ... | ... | |
|
execute!("katello-service stop #{filters}")
|
||
|
yield
|
||
|
ensure
|
||
|
spinner.update 'Starting the katello services..'
|
||
|
spinner.update 'Starting katello services..'
|
||
|
execute("katello-service start #{filters}")
|
||
|
end
|
||
|
end
|
||
| ... | ... | |
|
spinner.update 'No katello service to start'
|
||
|
else
|
||
|
filters = "--only #{services.join(',')}"
|
||
|
spinner.update 'Starting the katello services..'
|
||
|
spinner.update 'Starting katello services..'
|
||
|
execute!("katello-service start #{filters}")
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def restart(options = {})
|
||
|
if options[:only] || options[:exclude]
|
||
|
filters = construct_filters_for_restart(options)
|
||
|
execute!("katello-service restart #{filters}")
|
||
|
else
|
||
|
execute!('katello-service restart')
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def hammer_ping_retry(spinner)
|
||
|
RETRIES_FOR_SERVICES_RESTART.times do |retry_count|
|
||
|
msg = "Try #{retry_count + 1}/#{RETRIES_FOR_SERVICES_RESTART}: checking status by hammer ping"
|
||
|
spinner.update msg
|
||
|
result = feature(:hammer).hammer_ping_cmd
|
||
|
if result[:success]
|
||
|
spinner.update 'All services are running.'
|
||
|
break
|
||
|
elsif retry_count < (RETRIES_FOR_SERVICES_RESTART - 1)
|
||
|
apply_sleep_before_retry(spinner, result)
|
||
|
end
|
||
|
end
|
||
|
rescue StandardError => e
|
||
|
logger.error e.message
|
||
|
end
|
||
|
|
||
|
private
|
||
|
|
||
|
def apply_sleep_before_retry(spinner, result)
|
||
|
puts "\n#{result[:message]}"
|
||
|
spinner.update "Waiting #{PING_RETRY_INTERVAL} seconds before retry."
|
||
|
sleep PING_RETRY_INTERVAL
|
||
|
end
|
||
|
|
||
|
def construct_filters_for_restart(options)
|
||
|
filters = ''
|
||
|
if options[:only]
|
||
|
filters += "--only #{options[:only].join(',')}" unless options[:only].empty?
|
||
|
end
|
||
|
if options[:exclude]
|
||
|
filters += "--exclude #{options[:exclude].join(',')}" unless options[:exclude].empty?
|
||
|
end
|
||
|
filters
|
||
|
end
|
||
|
|
||
|
def find_services_for_only_filter(curr_services, options)
|
||
|
defaults = { :only => [], :exclude => [] }
|
||
|
options = defaults.merge(options)
|
||
Also available in: Unified diff
Fixes #20870 - hammer ping check with default tag