election.py 文件源码

def _election(self):
        for retry in range(constant.Election.MAX_RETRY):
            try:
                self._locker.acquire(
                    blocking=False,
                    lock_ttl=constant.Election.LOCKER_TTL,
                    timeout=constant.Election.TIMEOUT
                )
            except etcd.EtcdLockExpired as e:
                log.warn(e)
            except Exception as e:
                log.warn(e)
            else:
                # May got locker
                break

            gevent.sleep(constant.Election.LOCK_INTERVAL)