eleme / doctor Goto Github PK

        locked_span = time_now - locked_at
        if (locked_status == MODE_LOCKED and
                health_ok_now and
                locked_span >= self._min_recovery_time):
            # enter into recover mode
            lock['locked_status'] = MODE_RECOVER
            lock_changed = MODE_RECOVER
        elif locked_status == MODE_RECOVER:
            if self._metrics.api_latest_state.get(key, False):
                if locked_span >= self._max_recovery_time:
                    lock['locked_at'] = 0
                    lock['locked_status'] = MODE_UNLOCKED
                    lock_changed = MODE_UNLOCKED
            else:
                # still suffering, lock it again
                lock['locked_at'] = time_now
                lock['locked_status'] = MODE_LOCKED
                lock_changed = MODE_LOCKED
        elif locked_status == MODE_UNLOCKED and \
                not health_ok_now:
            # turns BAD
            lock['locked_at'] = time_now
            lock['locked_status'] = MODE_LOCKED
            lock_changed = MODE_LOCKED

        current_locked_status = lock['locked_status']
        if current_locked_status == MODE_LOCKED:
            result = False
        elif current_locked_status == MODE_UNLOCKED:
            result = True
        elif current_locked_status == MODE_RECOVER:
            if lock_changed is not None:
                # one request will be released for health checking once
                # this api enters recover mode
                result = True
            else:
                result = bool(random.random() <
                              float(locked_span) / self._max_recovery_time)