[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