Permalink
Browse files

Reset consecutive unacked worker deaths upon upgrade

  • Loading branch information...
1 parent 703e398 commit b51a7db378b0ce47a403df18ee4f65dd2fabb04b @gdb gdb committed Sep 27, 2012
Showing with 5 additions and 0 deletions.
  1. +5 −0 lib/einhorn/command.rb
@@ -287,6 +287,11 @@ def self.upgrade_workers
Einhorn.log_info("Starting upgrade to #{Einhorn::State.version}...")
end
+ # Reset this, since we've just upgraded to a new universe (I'm
+ # not positive this is the right behavior, but it's not
+ # obviously wrong.)
+ Einhorn::State.consecutive_deaths_before_ack = 0
+
Einhorn::State.version += 1
replenish_immediately
end

0 comments on commit b51a7db

Please sign in to comment.