search for: agenthandler

...ask_controller' include Daemonize +class Logger + def format_message(severity, timestamp, progname, msg) + "#{severity} #{timestamp} (#{$$}) #{msg}\n" + end +end + # Monkey patch class Qmf::SchemaObjectClass attr_reader :id @@ -80,16 +86,47 @@ class OvirtAgent < Qmf::AgentHandler include Ovirt::SchemaParser - def initialize(host) + $logfile = '/var/log/ovirt-server/ovirt-agent.log' - ensure_credentials + def initialize() - # FIXME: Use RAILS_DEFAULT_LOGGER - @logger = Logger.new(STDERR) - @logger.level = Logger::DEBUG + ensure_credential...

...se) + end + def find(id) svc_show(id) render(@vm) diff --git a/src/ovirt-agent/ovirt-agent.rb b/src/ovirt-agent/ovirt-agent.rb index 62834b0..425699b 100755 --- a/src/ovirt-agent/ovirt-agent.rb +++ b/src/ovirt-agent/ovirt-agent.rb @@ -139,7 +139,7 @@ class OvirtAgent < Qmf::AgentHandler @settings.host = server # FIXME: Bug in swig! #@settings.port = port - @settings.mechanism = 'GSSAPI' + #@settings.mechanism = 'GSSAPI' @logger.info "Connecting to broker on #{@settings.host}.." @@ -165,7 +165,7 @@ class OvirtAgent < Qmf::A...

...bject(vmsvc.vm) + @agent.query_response(context, vmdef) + rescue Exception => ex + @logger.info "Couldn't get svc_show to show vm record: #{ex}" + 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...