SyncCallTest.java 文件源码

@Test
public void testSync() throws Exception {
    try {
        LOG.info("Starting ZK:" + (new Date()).toString());
        opsCount = new CountDownLatch(limit);
        ZooKeeper zk = createClient();

        LOG.info("Beginning test:" + (new Date()).toString());
        for(int i = 0; i < 50; i++)
            zk.create("/test" + i, new byte[0], Ids.OPEN_ACL_UNSAFE,
                      CreateMode.PERSISTENT, (StringCallback)this, results);

        for(int i = 50; i < 100; i++) {
          zk.create("/test" + i, new byte[0], Ids.OPEN_ACL_UNSAFE,
                    CreateMode.PERSISTENT, (Create2Callback)this, results);
        }
        zk.sync("/test", this, results);
        for(int i = 0; i < 100; i++)
            zk.delete("/test" + i, 0, this, results);
        for(int i = 0; i < 100; i++)
            zk.getChildren("/", new NullWatcher(), (ChildrenCallback)this,
                    results);
        for(int i = 0; i < 100; i++)
            zk.getChildren("/", new NullWatcher(), (Children2Callback)this,
                    results);
        LOG.info("Submitted all operations:" + (new Date()).toString());

        if(!opsCount.await(10000, TimeUnit.MILLISECONDS))
            Assert.fail("Haven't received all confirmations" + opsCount.getCount());

        for(int i = 0; i < limit ; i++){
            Assert.assertEquals(0, (int) results.get(i));
        }

    } catch (IOException e) {
        System.out.println(e.toString());
    } 
}