search for: get_srv

Displaying 7 results from an estimated 7 matches for "get_srv".

2009 Jul 07
1
[PATCH] Let ovirt-test use DNS SRV to get qpidd server.
...dex 71f9a9f..412a8ee 100755 --- a/src/ovirt-agent/ovirt-test.rb +++ b/src/ovirt-agent/ovirt-test.rb @@ -6,14 +6,10 @@ require 'rubygems' require 'qpid' require 'dutils' -if ARGV.size == 1 - srv = ARGV[0] -else - srv = "amqp://localhost" -end - +server, port = get_srv('qpidd', 'tcp') get_credentials('qpidd') +srv = "amqp://#{server}:#{port}" puts "Connecting to #{srv}.." s = Qpid::Qmf::Session.new() -- 1.6.0.6
2009 Jul 15
1
[PATCH] Rename qmf-libvirt-example to libvirt-list.rb
...00000..54e8b7e --- /dev/null +++ b/src/libvirt-list.rb @@ -0,0 +1,65 @@ +#!/usr/bin/ruby + +$: << File.join(File.dirname(__FILE__), "./dutils") + +require "rubygems" +require "qpid" +require "dutils" + +get_credentials('qpidd') + +server, port = get_srv('qpidd', 'tcp') +raise "Unable to determine qpid server from DNS SRV record" if not server + +srv = "amqp://#{server}:#{port}" +puts "Connecting to #{srv}.." +s = Qpid::Qmf::Session.new() +b = s.add_broker(srv, :mechanism => 'GSSAPI') + +node...
2009 Jul 13
1
[PATCH: server] Added qmf matahari example to ovirt-server.
...934ac9 --- /dev/null +++ b/src/qmf-matahari.example.rb @@ -0,0 +1,50 @@ +#!/usr/bin/ruby + +$: << File.join(File.dirname(__FILE__), "./dutils") + +require "rubygems" +require "qpid" +require "dutils" + +get_credentials('qpidd') + +server, port = get_srv('qpidd', 'tcp') +raise "Unable to determine qpid server from DNS SRV record" if not server + +srv = "amqp://#{server}:#{port}" +puts "Connecting to #{srv}.." +s = Qpid::Qmf::Session.new() +b = s.add_broker(srv, :mechanism => 'GSSAPI') + +whil...
2009 Jul 07
1
[PATCH] Set up ovirt-agent so it starts as a daemon
...range + # things so the db stuff is included after daemonizing. + pwd = Dir.pwd + daemonize + Dir.chdir(pwd) + @logger = Logger.new($logfile) + else + @logger = Logger.new(STDERR) + end + @logger.level = Logger::DEBUG + while true do server, port = get_srv('qpidd', 'tcp') break if server @@ -99,12 +136,12 @@ class OvirtAgent < Qmf::AgentHandler end @settings = Qmf::ConnectionSettings.new - #@settings.server = server + @settings.host = server + # FIXME: Bug in swig! #@settings.port = port - #@sett...
2009 May 15
0
[PATCH server] Starting of new ovirt QMF API.
...t; + end + end + end + + def implement_method_call(context, method) + end + +end + +class OvirtAgent < Qmf::AgentHandler + + def initialize + + ensure_credentials + + @logger = Logger.new(STDERR) + + server, port = nil + sleepy = 5 + while true do + server, port = get_srv('qpidd', 'tcp') + break if server + @logger.error "Unable to determine qpid server from DNS SRV record, retrying.." if not server + sleep(sleepy) + sleepy *= 2 if sleepy < 120 + end + + @settings = Qmf::ConnectionSettings.new + #@settings.se...
2009 Jul 13
0
[PATCH server] remove vm forward vnc and vm host history
...nat_rules(vm, history_record = nil) - if history_record.nil? - ip = find_host_ip(vm.host.hostname) - vnc_port = vm.vnc_port.to_s - else - ip = find_host_ip(history_record.host.hostname) - vnc_port = history_record.vnc_port.to_s - end - - server,port = get_srv('ovirt', 'tcp') - local_ip = find_host_ip(server) - return " -p tcp --dport " + vm.forward_vnc_port.to_s + " -j DNAT --to " + ip + ":" + vnc_port, - " -d " + ip + " -p tcp --dport " + vnc_port + " -j SNAT -...
2009 Nov 04
4
[PATCH server] Update daemons to use new QMF.
...File.join(File.dirname(__FILE__), "./dutils") -require "rubygems" -require "qpid" -require "dutils" +require 'rubygems' +require 'dutils' +require 'qmf' +require 'socket' get_credentials('qpidd') server, port = get_srv('qpidd', 'tcp') raise "Unable to determine qpid server from DNS SRV record" if not server -srv = "amqp://#{server}:#{port}" -puts "Connecting to #{srv}.." -s = Qpid::Qmf::Session.new() -b = s.add_broker(srv, :mechanism => 'GSSAPI') +puts &...