Displaying 6 results from an estimated 6 matches for "add_brok".
Did you mean:
add_book
2009 Jul 31
2
[PATCH server] Removed workaround for qmf bug that yielded 0 cpus and 0 nics for nodes from time to time.
...@logger.info "Connecting to amqp://#{server}:#{port}"
- @session = Qpid::Qmf::Session.new(:console => self, :manage_connections => false)
+ @session = Qpid::Qmf::Session.new(:console => self, :manage_connections => true)
@broker = @session.add_broker("amqp://#{server}:#{port}", :mechanism => 'GSSAPI')
rescue Exception => ex
--
1.6.2.5
2009 Jul 15
1
[PATCH] Rename qmf-libvirt-example to libvirt-list.rb
...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')
+
+nodes = s.objects(:class => "node")
+nodes.each do |node|
+ puts "node: #{node.hostname}"
+ for (key, val) in node.properties
+ puts " property: #{key}, #{val}"
+ end
+
+ # Find any domains that on the...
2009 Jul 13
1
[PATCH: server] Added qmf matahari example to ovirt-server.
...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')
+
+while true:
+ hosts = s.objects(:class => "host")
+ hosts.each do |host|
+ puts "host: #{host.hostname}"
+ for (key, val) in host.properties
+ puts " property: #{key}, #{val}"
+ end...
2009 Nov 04
4
[PATCH server] Update daemons to use new QMF.
...r, 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_connections => true)
- @broker = @session.add_broker("amqp://#{server}:#{port}", :mechanism => 'GSSAPI')
+ @settings = Qmf::ConnectionSettings.new
+ @settings.host = server
+ @settings.port = port
+# @settings.mechanism = 'GSSAPI'
+# @settings.service = 'qpidd...
2009 Jul 23
0
[PATCH server] Add network QMF apis.
...chema_class.id}"
@agent.register_class(controller_class.schema_class)
end
end
diff --git a/src/ovirt-agent/ovirt-test.rb b/src/ovirt-agent/ovirt-test.rb
index 412a8ee..ab67d10 100755
--- a/src/ovirt-agent/ovirt-test.rb
+++ b/src/ovirt-agent/ovirt-test.rb
@@ -18,6 +18,12 @@ b = s.add_broker(srv, :mechanism => 'GSSAPI')
# This segfaults in F10 (ruby-1.8.6.287-2.fc10.x86_64)
# p s.objects(:class => "Ovirt")
+def print_properties(obj)
+ for (key, val) in obj.properties
+ puts " property: #{key}, #{val}"
+ end
+end
+
ovirt = s.object(:class =...
2009 May 15
0
[PATCH server] Starting of new ovirt QMF API.
...t/ovirt-test.rb
@@ -0,0 +1,40 @@
+#!/usr/bin/ruby
+
+$: << File.join(File.dirname(__FILE__), "./dutils")
+
+require "rubygems"
+require "qpid"
+
+srv = "amqp://mc.mains.net"
+
+puts "Connecting to #{srv}.."
+s = Qpid::Qmf::Session.new()
+b = s.add_broker(srv)
+
+while true:
+ ovirt = s.object(:class => "Ovirt")
+ puts "id is #{ovirt.object_id}"
+ raise "ACK! NO ovirt class!" unless ovirt
+ puts "ovirt.version is #{ovirt.version}"
+ ovirt_by_id = s.object(:object_id => ovirt.object_id)
+...