search for: ensure_credentials

...imestamp} (#{$$}) #{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_credentials server, port = nil sleepy = 5 + + do_daemon = true + + opts = OptionParser.new do |opts| + opts.on("-h", "-...

...sponse(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 record, retrying.." if not server +...

...uot;) do |s| sleeptime = s @@ -94,6 +98,11 @@ class TaskOmatic @logger = Logger.new(STDERR) end + #@logger.level = Logger::DEBUG if do_debug + # + # For now I'm going to always enable debugging until we do a real release. + @logger.level = Logger::DEBUG + ensure_credentials server, port = nil @@ -197,6 +206,7 @@ class TaskOmatic phys_libvirt_pool.connect(@session, node) end + @logger.debug "Verifying mount of pool #{db_pool.ip_addr}:#{db_pool.type}:#{db_pool.target}:#{db_pool.export_path}" libvirt_pool = LibvirtPool.facto...

...e - +class DbOmatic < Qmf::ConsoleHandler # Use monitor mixin for mutual exclusion around checks to heartbeats # and updates to objects/heartbeats. - include MonitorMixin def initialize() @@ -77,7 +74,6 @@ class DbOmatic < Qpid::Qmf::Console begin ensure_credentials - database_connect server, port = nil @@ -91,8 +87,17 @@ class DbOmatic < Qpid::Qmf::Console end @logger.info "Connecting to amqp://#{server}:#{port}" - @session = Qpid::Qmf::Session.new(:console => self, :manage_con...