| Class | TCPSocket |
| In: |
lib/tcp_socket_extension.rb
|
| Parent: | Object |
# File lib/tcp_socket_extension.rb, line 6
6: def self.wait_for_service(options)
7: socket = nil
8: Timeout::timeout(options[:timeout] || 20) do
9: loop do
10: begin
11: socket = TCPSocket.new(options[:host], options[:port])
12: return
13: rescue Errno::ECONNREFUSED
14: puts ".\n"
15: sleep 2
16: end
17: end
18: end
19: ensure
20: socket.close unless socket.nil?
21: end