test_class.declarator: LOOP = 100
test_class.modifier: private static final
test_class.original_string: private static final int LOOP = 100;
test_class.type: int
test_class.var_name: LOOP
test_class.declarator: TEST_PATH = "/test1/test"
test_class.modifier: private static final
test_class.original_string: private static final String TEST_PATH = "/test1/test";
test_class.type: String
test_class.var_name: TEST_PATH
test_class.declarator: TEST_PATH2 = "/test2/test"
test_class.modifier: private static final
test_class.original_string: private static final String TEST_PATH2 = "/test2/test";
test_class.type: String
test_class.var_name: TEST_PATH2
test_class.declarator: mapper
test_class.modifier: private static
test_class.original_string: private static ObjectMapper mapper;
test_class.type: ObjectMapper
test_class.var_name: mapper
test_class.declarator: testingServer
test_class.modifier: private static
test_class.original_string: private static TestingServer testingServer;
test_class.type: TestingServer
test_class.var_name: testingServer
test_class.declarator: curatorFramework
test_class.modifier: private static
test_class.original_string: private static CuratorFramework curatorFramework;
test_class.type: CuratorFramework
test_class.var_name: curatorFramework
test_class.declarator: otherConnectionStr
test_class.modifier: private static
test_class.original_string: private static String otherConnectionStr;
test_class.type: String
test_class.var_name: otherConnectionStr
test_class.file: core/src/test/java/com/github/phantomthief/zookeeper/util/ZkUtilsTest.java
test_class.identifier: ZkUtilsTest
test_case.body: @Test
      void testConcurrent() throws Exception {
          ExecutorService executor = Executors.newFixedThreadPool(100);
          for (int i = 0; i < LOOP; i++) {
              executor.execute(() -> {
                  ZkUtils.changeZkValue(curatorFramework, TEST_PATH2, old -> old + 1, this::intDecode,
                          this::intEncode);
              });
          }
          MoreExecutors.shutdownAndAwaitTermination(executor, 1, DAYS);
          assertEquals(intDecode(curatorFramework.getData().forPath(TEST_PATH2)), LOOP);
      }
test_case.class_method_signature: ZkUtilsTest.testConcurrent()
test_case.full_signature: @Test void testConcurrent()
test_case.identifier: testConcurrent
test_case.invocations: newFixedThreadPool execute changeZkValue shutdownAndAwaitTermination assertEquals intDecode forPath getData
test_case.modifiers: @Test
test_case.parameters: ()
test_case.return: void
test_case.signature: void testConcurrent()
focal_class.declarator: logger = getLogger(ZkUtils.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger logger = getLogger(ZkUtils.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: DEFAULT_WAIT = SECONDS.toMillis(1)
focal_class.modifier: private static final
focal_class.original_string: private static final long DEFAULT_WAIT = SECONDS.toMillis(1);
focal_class.type: long
focal_class.var_name: DEFAULT_WAIT
focal_class.declarator: INFINITY_LOOP = -1
focal_class.modifier: private static final
focal_class.original_string: private static final int INFINITY_LOOP = -1;
focal_class.type: int
focal_class.var_name: INFINITY_LOOP
focal_class.file: core/src/main/java/com/github/phantomthief/zookeeper/util/ZkUtils.java
focal_class.identifier: ZkUtils
focal_class.class_method_signature: ZkUtils.ZkUtils()
focal_class.full_signature: private  ZkUtils()
focal_class.identifier: ZkUtils
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.signature:  ZkUtils()
focal_class.class_method_signature: ZkUtils.getStringFromZk(CuratorFramework client, String path)
focal_class.full_signature: public static String getStringFromZk(CuratorFramework client, String path)
focal_class.identifier: getStringFromZk
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path)
focal_class.return: String
focal_class.signature: String getStringFromZk(CuratorFramework client, String path)
focal_class.class_method_signature: ZkUtils.getBytesFromZk(CuratorFramework client, String path)
focal_class.full_signature: public static byte[] getBytesFromZk(CuratorFramework client, String path)
focal_class.identifier: getBytesFromZk
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path)
focal_class.return: byte[]
focal_class.signature: byte[] getBytesFromZk(CuratorFramework client, String path)
focal_class.class_method_signature: ZkUtils.getFromZk(CuratorFramework client, String path,
              ThrowableFunction<byte[], T, X> decoder)
focal_class.full_signature: public static T getFromZk(CuratorFramework client, String path,
              ThrowableFunction<byte[], T, X> decoder)
focal_class.identifier: getFromZk
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path,
              ThrowableFunction<byte[], T, X> decoder)
focal_class.return: T
focal_class.signature: T getFromZk(CuratorFramework client, String path,
              ThrowableFunction<byte[], T, X> decoder)
focal_class.class_method_signature: ZkUtils.setToZk(CuratorFramework client, String path, byte[] value)
focal_class.full_signature: public static void setToZk(CuratorFramework client, String path, byte[] value)
focal_class.identifier: setToZk
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path, byte[] value)
focal_class.return: void
focal_class.signature: void setToZk(CuratorFramework client, String path, byte[] value)
focal_class.class_method_signature: ZkUtils.setToZk(CuratorFramework client, String path, byte[] value,
              CreateMode createMode)
focal_class.full_signature: @Deprecated public static void setToZk(CuratorFramework client, String path, byte[] value,
              CreateMode createMode)
focal_class.identifier: setToZk
focal_class.modifiers: @Deprecated public static
focal_class.parameters: (CuratorFramework client, String path, byte[] value,
              CreateMode createMode)
focal_class.return: void
focal_class.signature: void setToZk(CuratorFramework client, String path, byte[] value,
              CreateMode createMode)
focal_class.class_method_signature: ZkUtils.createEphemeralNode(CuratorFramework client, String path,
              byte[] value)
focal_class.full_signature: public static EphemeralNode createEphemeralNode(CuratorFramework client, String path,
              byte[] value)
focal_class.identifier: createEphemeralNode
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path,
              byte[] value)
focal_class.return: EphemeralNode
focal_class.signature: EphemeralNode createEphemeralNode(CuratorFramework client, String path,
              byte[] value)
focal_class.class_method_signature: ZkUtils.removeFromZk(CuratorFramework client, String path)
focal_class.full_signature: public static void removeFromZk(CuratorFramework client, String path)
focal_class.identifier: removeFromZk
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path)
focal_class.return: void
focal_class.signature: void removeFromZk(CuratorFramework client, String path)
focal_class.class_method_signature: ZkUtils.removeFromZk(CuratorFramework client, String path,
              boolean recruitDeletedChildren)
focal_class.full_signature: public static void removeFromZk(CuratorFramework client, String path,
              boolean recruitDeletedChildren)
focal_class.identifier: removeFromZk
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path,
              boolean recruitDeletedChildren)
focal_class.return: void
focal_class.signature: void removeFromZk(CuratorFramework client, String path,
              boolean recruitDeletedChildren)
focal_class.class_method_signature: ZkUtils.changeZkValue(CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)
focal_class.full_signature: public static void changeZkValue(CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)
focal_class.identifier: changeZkValue
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)
focal_class.return: void
focal_class.signature: void changeZkValue(CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)
focal_class.class_method_signature: ZkUtils.changeZkValue(CuratorFramework client, String path,
              Function<byte[], byte[]> changeFunction, int retryTimes, long retryWait)
focal_class.full_signature: public static boolean changeZkValue(CuratorFramework client, String path,
              Function<byte[], byte[]> changeFunction, int retryTimes, long retryWait)
focal_class.identifier: changeZkValue
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework client, String path,
              Function<byte[], byte[]> changeFunction, int retryTimes, long retryWait)
focal_class.return: boolean
focal_class.signature: boolean changeZkValue(CuratorFramework client, String path,
              Function<byte[], byte[]> changeFunction, int retryTimes, long retryWait)
focal_class.class_method_signature: ZkUtils.getAllChildrenWithData(CuratorFramework curator, String parentPath)
focal_class.full_signature: public static Stream<ChildData> getAllChildrenWithData(CuratorFramework curator, String parentPath)
focal_class.identifier: getAllChildrenWithData
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework curator, String parentPath)
focal_class.return: Stream<ChildData>
focal_class.signature: Stream<ChildData> getAllChildrenWithData(CuratorFramework curator, String parentPath)
focal_class.class_method_signature: ZkUtils.getAllChildrenWithData0(CuratorFramework curator, String parentPath)
focal_class.full_signature: private static Stream<ChildData> getAllChildrenWithData0(CuratorFramework curator, String parentPath)
focal_class.identifier: getAllChildrenWithData0
focal_class.modifiers: private static
focal_class.parameters: (CuratorFramework curator, String parentPath)
focal_class.return: Stream<ChildData>
focal_class.signature: Stream<ChildData> getAllChildrenWithData0(CuratorFramework curator, String parentPath)
focal_class.class_method_signature: ZkUtils.toChildData(CuratorFramework curator, String path)
focal_class.full_signature: @Nullable private static ChildData toChildData(CuratorFramework curator, String path)
focal_class.identifier: toChildData
focal_class.modifiers: @Nullable private static
focal_class.parameters: (CuratorFramework curator, String path)
focal_class.return: ChildData
focal_class.signature: ChildData toChildData(CuratorFramework curator, String path)
focal_class.class_method_signature: ZkUtils.getAllChildren(CuratorFramework curator, String parentPath)
focal_class.full_signature: public static Stream<String> getAllChildren(CuratorFramework curator, String parentPath)
focal_class.identifier: getAllChildren
focal_class.modifiers: public static
focal_class.parameters: (CuratorFramework curator, String parentPath)
focal_class.return: Stream<String>
focal_class.signature: Stream<String> getAllChildren(CuratorFramework curator, String parentPath)
focal_class.class_method_signature: ZkUtils.getAllChildren0(CuratorFramework curator, String parentPath)
focal_class.full_signature: private static Stream<String> getAllChildren0(CuratorFramework curator, String parentPath)
focal_class.identifier: getAllChildren0
focal_class.modifiers: private static
focal_class.parameters: (CuratorFramework curator, String parentPath)
focal_class.return: Stream<String>
focal_class.signature: Stream<String> getAllChildren0(CuratorFramework curator, String parentPath)
focal_method.body: public static <T> void changeZkValue(CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder) {
          Function<byte[], byte[]> realFunction = old -> {
              T decodedOld = decoder.apply(old);
              return encoder.apply(changeFunction.apply(decodedOld));
          };
          changeZkValue(client, path, realFunction, INFINITY_LOOP, DEFAULT_WAIT);
      }
focal_method.class_method_signature: ZkUtils.changeZkValue(CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)
focal_method.full_signature: public static void changeZkValue(CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)
focal_method.identifier: changeZkValue
focal_method.invocations: apply apply apply changeZkValue
focal_method.modifiers: public static
focal_method.parameters: (CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)
focal_method.return: void
focal_method.signature: void changeZkValue(CuratorFramework client, String path,
              Function<T, T> changeFunction, Function<byte[], T> decoder,
              Function<T, byte[]> encoder)