Sha256: fab6858e8c510a6f9bf83b2db2b2604cba5d302b4d8cb238b6ae1aba4f078a01
Contents?: true
Size: 815 Bytes
Versions: 16
Compression:
Stored size: 815 Bytes
Contents
class Indocker::ServerPools::BuildServerPool def initialize(configuration:, logger:) @logger = logger @configuration = configuration @connections = configuration.build_servers.map do |build_server| Indocker::ServerPools::BuildServerConnection.new( logger: @logger, configuration: configuration, server: build_server, ) end end def create_sessions! @connections.each(&:create_session!) end def get context = nil loop do context = @connections.detect {|c| !c.busy?} sleep(0.1) break if context end context end def each(&proc) @connections.each(&proc) end def close_sessions @connections.each(&:close_session) rescue => e @logger.error("error during session close: #{e.inspect}") end end
Version data entries
16 entries across 16 versions & 1 rubygems