[Ovirt-devel] [PATCH] Get timestamp at check_heartbeat to avoid time lag
Arthur Clément
aclement at linagora.com
Wed Aug 18 13:37:22 UTC 2010
pushed (Wed Jul 21)
On mercredi 21 juillet 2010 11:27:14 Arthur Clement wrote:
> Avoid time lag and disconnection after several checks
>
> Signed-off-by: Arthur Clement <aclement at linagora.com>
> ---
> src/host-browser/host-register.rb | 7 ++++---
> 1 files changed, 4 insertions(+), 3 deletions(-)
>
> diff --git a/src/host-browser/host-register.rb
> b/src/host-browser/host-register.rb index e49f08e..693a6f2 100755
> --- a/src/host-browser/host-register.rb
> +++ b/src/host-browser/host-register.rb
> @@ -178,6 +178,7 @@ class HostRegister < Qmf::ConsoleHandler
> def agent_disconnected(agent)
> synchronize do
> debugputs "Marking objects for agent #{agent.key} inactive"
> + @logger.info "Marking objects for agent #{agent.key} inactive"
> @cached_hosts.keys.each do |objkey|
> if @cached_hosts[objkey][:agent_key] == agent.key
> cached_host = @cached_hosts[objkey]
> @@ -435,10 +436,10 @@ class HostRegister < Qmf::ConsoleHandler
> while true
> sleep(5)
> synchronize do
> - # Get seconds from the epoch
> - t = Time.new.to_i
>
> @heartbeats.keys.each do | key |
> + # Get seconds from the epoch
> + t = Time.new.to_i
> agent, timestamp = @heartbeats[key]
>
> # Heartbeats from qpid are in microseconds, we
> just need seconds.. @@ -447,7 +448,7 @@ class HostRegister <
> Qmf::ConsoleHandler
>
> if delta > 30
> # No heartbeat for 30 seconds.. deal with
> dead/disconnected agent. - debugputs "Agent
> #{key} timed out!"
> + @logger.info "Agent #{key} timed out! Check
> NTP || with delta #{delta} = t #{t} - s #{s}" @heartbeats.delete(key)
>
> agent_disconnected(agent)
--
Arthur CLEMENT
Linagora Paris
More information about the ovirt-devel
mailing list