@@ -86,15 +86,22 @@ module Politics # If another process got there first, this is a noop. # We add an expiry so that the master token will constantly # need to be refreshed (in case the current leader dies). - nominate - time = 0 - if leader? - Politics::log.info { "#{worker_name} elected leader at #{Time.now}" } - # If we are the master worker, do the work. - time = time_for do - result = block.call(*args) + begin + nominate + + if leader? + Politics::log.info { "#{worker_name} elected leader at #{Time.now}" } + # If we are the master worker, do the work. + time = time_for do + result = block.call(*args) + end end + rescue MemCache::MemCacheError => me + Politics::log.error("Error from memcached, pausing until the next iteration...") + Politics::log.error(me.message) + Politics::log.error(me.backtrace.join("\n")) + self.memcache_client.reset end pause_until_expiry(time) lib/politics/token_worker.rb 170614baca5a8d2483829225fbd1ee6445d85a16 Mike Perham mperham@gmail.com http://github.com/mperham/politics/commit/38a432af969d986dd896df7c2844e904394a68b5 38a432af969d986dd896df7c2844e904394a68b5 2009-02-04T08:58:25-08:00 2009-02-04T08:58:25-08:00 Catch and try to handle memcached failures gracefully. 497a31662f38a4d1f3452d0b219d866ae5e415cb Mike Perham mperham@gmail.com