Method: Quartz::GoProcess#block_until_server_starts

Defined in:
lib/quartz/go_process.rb

#block_until_server_starts ⇒ Object 



63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/quartz/go_process.rb', line 63

def block_until_server_starts
  max_retries = 20
  retries = 0
  delay = 0.001 # seconds

  loop do
    return if File.exists?(@socket_path)
    raise Quartz::GoServerError, 'RPC server not starting' if retries > max_retries
    sleep(delay * 2**retries)
    retries += 1
  end
end