module Bluepill::Socket
Constants
- MAX_ATTEMPTS
- TIMEOUT
Public Instance Methods
client(base_dir, name, &block)
click to toggle source
# File lib/bluepill/socket.rb, line 10 def client(base_dir, name, &block) UNIXSocket.open(socket_path(base_dir, name), &block) end
client_command(base_dir, name, command)
click to toggle source
# File lib/bluepill/socket.rb, line 14 def client_command(base_dir, name, command) res = nil MAX_ATTEMPTS.times do |current_attempt| begin client(base_dir, name) do |socket| Timeout.timeout(TIMEOUT) do socket.puts command res = Marshal.load(socket.read) end end break rescue EOFError, Timeout::Error if current_attempt == MAX_ATTEMPTS - 1 abort('Socket Timeout: Server may not be responding') end puts "Retry #{current_attempt + 1} of #{MAX_ATTEMPTS}" end end res end
server(base_dir, name)
click to toggle source
# File lib/bluepill/socket.rb, line 35 def server(base_dir, name) socket_path = self.socket_path(base_dir, name) UNIXServer.open(socket_path) rescue Errno::EADDRINUSE begin # if sock file has been created, test to see if there is a server UNIXSocket.open(socket_path) rescue Errno::ECONNREFUSED File.delete(socket_path) return UNIXServer.open(socket_path) else logger.err('Server is already running!') exit(7) end end
socket_path(base_dir, name)
click to toggle source
# File lib/bluepill/socket.rb, line 51 def socket_path(base_dir, name) File.join(base_dir, 'socks', name + '.sock') end