Displaying 4 results from an estimated 4 matches for "broker_bank".
2009 Nov 04
4
[PATCH server] Update daemons to use new QMF.
...new_object = false
if values == nil
@@ -318,8 +328,7 @@ class DbOmatic < Qpid::Qmf::Console
# Save the agent and broker bank so that we can tell what objects
# are expired when the heartbeat for them stops.
- values[:broker_bank] = obj.object_id.broker_bank
- values[:agent_bank] = obj.object_id.agent_bank
+ values[:agent_key] = obj.object_id.agent_key
values[:obj_key] = obj.object_id.to_s
values[:class_type] = type
values[:timed_out] = false
@...
2009 Jul 21
1
[PATCH server] Fixed db-omatic so it doesn't segfault because of newer qmf api.
...rt"
- type = obj.klass_key[1]
+ type = obj.schema.klass_key.klass_name
# I just sync this whole thing because there shouldn't be a lot of contention here..
synchronize do
@@ -289,7 +289,7 @@ class DbOmatic < Qpid::Qmf::Console
values[:broker_bank] = obj.object_id.broker_bank
values[:agent_bank] = obj.object_id.agent_bank
values[:obj_key] = obj.object_id.to_s
- values[:class_type] = obj.klass_key[1]
+ values[:class_type] = type
values[:timed_out] = false...
2009 Jun 25
2
[PATCH] Fix dbomatic state changes.
...red yet??"
@@ -344,6 +365,7 @@ class DbOmatic < Qpid::Qmf::Console
end
def heartbeat(agent, timestamp)
+ puts "heartbeat from agent #{agent}"
return if agent == nil
synchronize do
bank_key = "#{agent.agent_bank}.#{agent.broker.broker_bank}"
@@ -376,6 +398,8 @@ class DbOmatic < Qpid::Qmf::Console
values[:timed_out] = true
end
end
+ bank_key = "#{agent.agent_bank}.#{agent.broker.broker_bank}"
+ @heartbeats.delete(bank_key)
end
# The opposite of above, this...
2009 Jun 29
0
[PATCH server] Add svc_vm_actions method to VmService.
...red yet??"
@@ -344,6 +365,7 @@ class DbOmatic < Qpid::Qmf::Console
end
def heartbeat(agent, timestamp)
+ puts "heartbeat from agent #{agent}"
return if agent == nil
synchronize do
bank_key = "#{agent.agent_bank}.#{agent.broker.broker_bank}"
@@ -376,6 +398,8 @@ class DbOmatic < Qpid::Qmf::Console
values[:timed_out] = true
end
end
+ bank_key = "#{agent.agent_bank}.#{agent.broker.broker_bank}"
+ @heartbeats.delete(bank_key)
end
# The opposite of above, this...