Displaying 4 results from an estimated 4 matches for "agent_bank".
2009 Nov 04
4
[PATCH server] Update daemons to use new QMF.
...@ -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
@@ -370,53 +379,48 @@ class DbOmatic < Qpid::Qmf::Console...
2009 Jul 21
1
[PATCH server] Fixed db-omatic so it doesn't segfault because of newer qmf api.
...hema.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
values[:synced] = false
@logger.info &...
2009 Jun 25
2
[PATCH] Fix dbomatic state changes.
...39;]}, probably not registered 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
#...
2009 Jun 29
0
[PATCH server] Add svc_vm_actions method to VmService.
...39;]}, probably not registered 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
#...