Sha256: 1491b565fd89ce7889c168f4870c26a16ccd682066e2e82aee04b04200577efd
Contents?: true
Size: 977 Bytes
Versions: 6
Compression:
Stored size: 977 Bytes
Contents
module VagrantDns
class Server
def initialize
traps
@resolv = VagrantDns::ResolvConf.new
end
def unpack(message)
_, host, ip, msg = message.split ' ', 4
[host, ip, msg.to_sym]
end
def process
begin
# @resolv.append
zmq = EM::ZeroMQ::Context.new(1)
EM.run {
@dns = VagrantDns::DnsServer.new
puts "processing "
pull= zmq.socket(ZMQ::SUB)
pull.bind(CONF.get('zmq_url'))
pull.subscribe('vagrant')
pull.on(:message) { |part|
host, ip, stat= unpack(part.copy_out_string)
puts "[#{ip}->#{host}]: is #{stat.to_s}"
REG.register(host,ip) if :up.eql?(stat)
REG.delete(host) if :down.eql?(stat)
part.close
}
}
rescue => e
$stderr.puts e
$stderr.puts e.backtrace.join("\n")
shutdown
end
end
def traps
%w(INT SIGINT TERM).each{|s|
Signal.trap(s) {shutdown}
}
end
def shutdown
$stderr.puts "Cleaning up server"
# @resolv.clear
EM::stop()
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems