iep-spring-leader-redis-cluster/src/main/java/com/netflix/iep/leader/redis/RedisClusterLeaderDatabase.java [95:106]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    String key = getKey(resourceId);
    int slot = JedisClusterCRC16.getSlot(key);
    try {
      try (Jedis client = jedis.leaderForSlot(slot)) {
        String watchResult = client.watch(key);
        if (watchResult == null || !watchResult.equals("OK")) {
          logger.warn("Invalid watch response: {}", watchResult);
          return false;
        }

        try {
          String data = client.get(key);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



iep-spring-leader-redis-cluster/src/main/java/com/netflix/iep/leader/redis/RedisClusterLeaderDatabase.java [156:168]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    String key = getKey(resourceId);
    int slot = JedisClusterCRC16.getSlot(key);
    try {
      try (Jedis client = jedis.leaderForSlot(slot)) {
        String watchResult = client.watch(key);
        if (watchResult == null || !watchResult.equals("OK")) {
          logger.warn("Invalid watch response: {}", watchResult);
          return false;
        }

        try {
          // now we check for leadership since we're on a watch
          String data = client.get(key);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -