文件操作 - retry_action.rb

文件: /opt/puppetlabs/puppet/lib/ruby/vendor_ruby/puppet/util/retry_action.rb

编辑文件内容

# frozen_string_literal: true

module Puppet::Util::RetryAction
  class RetryException < Exception; end # rubocop:disable Lint/InheritException
  class RetryException::NoBlockGiven < RetryException; end
  class RetryException::NoRetriesGiven < RetryException; end
  class RetryException::RetriesExceeded < RetryException; end

# Execute the supplied block retrying with exponential backoff.
  #
  # @param [Hash] options the retry options
  # @option options [Integer] :retries Maximum number of times to retry.
  # @option options [Array<Exception>] :retry_exceptions ([StandardError]) Optional array of exceptions that are allowed to be retried.
  # @yield The block to be executed.
  def self.retry_action(options = {})
    # Retry actions for a specified amount of time. This method will allow the final
    # retry to complete even if that extends beyond the timeout period.
    unless block_given?
      raise RetryException::NoBlockGiven
    end

retries = options[:retries]
    if retries.nil?
      raise RetryException::NoRetriesGiven
    end

retry_exceptions = options[:retry_exceptions] || [StandardError]
    failures = 0
    begin
      yield
    rescue *retry_exceptions => e
      if failures >= retries
        raise RetryException::RetriesExceeded, _("%{retries} exceeded") % { retries: retries }, e.backtrace
      end

Puppet.info(_("Caught exception %{klass}:%{error} retrying") % { klass: e.class, error: e })

failures += 1

# Increase the amount of time that we sleep after every
      # failed retry attempt.
      sleep(((2**failures) - 1) * 0.1)

retry
    end
  end
end

文件操作 - retry_action.rb

文件: /opt/puppetlabs/puppet/lib/ruby/vendor_ruby/puppet/util/retry_action.rb

编辑文件内容

修改文件时间

删除文件