Contents

module SSHKit

  module Runner

    class Sequential < Abstract
      attr_writer :wait_interval
      def execute
        last_host = hosts.pop

        hosts.each do |host|
          run_backend(host, &block)
          sleep wait_interval
        end

        unless last_host.nil?
          run_backend(last_host, &block)
        end
      end
      private
      def run_backend(host, &block)
        backend(host, &block).run
      rescue StandardError => e
        e2 = ExecuteError.new e
        raise e2, "Exception while executing #{host.user ? "as #{host.user}@" : "on host "}#{host}: #{e.message}"
      end

      def wait_interval
        @wait_interval || options[:wait] || 2
      end
    end

  end

end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
sshkit-1.10.0	lib/sshkit/runners/sequential.rb
sshkit-1.9.0	lib/sshkit/runners/sequential.rb
sshkit-1.9.0.rc1	lib/sshkit/runners/sequential.rb
sshkit-1.8.1	lib/sshkit/runners/sequential.rb
sshkit-1.8.0	lib/sshkit/runners/sequential.rb