| | |
| | | redis = __redisManager.getRedis() |
| | | key = "ths_state_dead_count-{}".format(client_id) |
| | | if not dead: |
| | | RedisUtils.setex(redis,key, tool.get_expire(), 0) |
| | | RedisUtils.setex(redis, key, tool.get_expire(), 0) |
| | | else: |
| | | redis.incrby(key, 1) |
| | | RedisUtils.incrby(redis, key, 1) |
| | | RedisUtils.expire(redis, key, tool.get_expire()) |
| | | |
| | | |
| | |
| | | def is_ths_dead(client_id): |
| | | key = "ths_state_dead_count-{}".format(client_id) |
| | | redis = __redisManager.getRedis() |
| | | val = redis.get(key) |
| | | val = RedisUtils.get(redis, key) |
| | | if val is not None and int(val) >= 5: |
| | | return True |
| | | else: |