diff options
Diffstat (limited to 'zookeeper-server/src/test/java/org/apache/zookeeper/test/StatTest.java')
-rw-r--r-- | zookeeper-server/src/test/java/org/apache/zookeeper/test/StatTest.java | 156 |
1 files changed, 72 insertions, 84 deletions
diff --git a/zookeeper-server/src/test/java/org/apache/zookeeper/test/StatTest.java b/zookeeper-server/src/test/java/org/apache/zookeeper/test/StatTest.java index f4c01aa5c..cf575139b 100644 --- a/zookeeper-server/src/test/java/org/apache/zookeeper/test/StatTest.java +++ b/zookeeper-server/src/test/java/org/apache/zookeeper/test/StatTest.java @@ -1,4 +1,4 @@ -/** +/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information @@ -18,17 +18,18 @@ package org.apache.zookeeper.test; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotSame; import java.io.IOException; - import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.KeeperException; -import org.apache.zookeeper.ZooKeeper; import org.apache.zookeeper.ZooDefs.Ids; +import org.apache.zookeeper.ZooKeeper; import org.apache.zookeeper.data.Stat; -import org.junit.Assert; import org.junit.Test; public class StatTest extends ClientBase { + private ZooKeeper zk; @Override @@ -46,7 +47,7 @@ public class StatTest extends ClientBase { } /** - * Create a new Stat, fill in dummy values trying to catch Assert.failure + * Create a new Stat, fill in dummy values trying to catch failure * to copy in client or server code. * * @return a new stat with dummy values @@ -70,136 +71,123 @@ public class StatTest extends ClientBase { } @Test - public void testBasic() - throws IOException, KeeperException, InterruptedException - { + public void testBasic() throws IOException, KeeperException, InterruptedException { String name = "/foo"; - zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, - CreateMode.PERSISTENT); + zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); Stat stat; stat = newStat(); zk.getData(name, false, stat); - Assert.assertEquals(stat.getCzxid(), stat.getMzxid()); - Assert.assertEquals(stat.getCzxid(), stat.getPzxid()); - Assert.assertEquals(stat.getCtime(), stat.getMtime()); - Assert.assertEquals(0, stat.getCversion()); - Assert.assertEquals(0, stat.getVersion()); - Assert.assertEquals(0, stat.getAversion()); - Assert.assertEquals(0, stat.getEphemeralOwner()); - Assert.assertEquals(name.length(), stat.getDataLength()); - Assert.assertEquals(0, stat.getNumChildren()); + assertEquals(stat.getCzxid(), stat.getMzxid()); + assertEquals(stat.getCzxid(), stat.getPzxid()); + assertEquals(stat.getCtime(), stat.getMtime()); + assertEquals(0, stat.getCversion()); + assertEquals(0, stat.getVersion()); + assertEquals(0, stat.getAversion()); + assertEquals(0, stat.getEphemeralOwner()); + assertEquals(name.length(), stat.getDataLength()); + assertEquals(0, stat.getNumChildren()); } @Test - public void testChild() - throws IOException, KeeperException, InterruptedException - { + public void testChild() throws IOException, KeeperException, InterruptedException { String name = "/foo"; - zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, - CreateMode.PERSISTENT); + zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); String childname = name + "/bar"; - zk.create(childname, childname.getBytes(), Ids.OPEN_ACL_UNSAFE, - CreateMode.EPHEMERAL); + zk.create(childname, childname.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); Stat stat; stat = newStat(); zk.getData(name, false, stat); - Assert.assertEquals(stat.getCzxid(), stat.getMzxid()); - Assert.assertEquals(stat.getCzxid() + 1, stat.getPzxid()); - Assert.assertEquals(stat.getCtime(), stat.getMtime()); - Assert.assertEquals(1, stat.getCversion()); - Assert.assertEquals(0, stat.getVersion()); - Assert.assertEquals(0, stat.getAversion()); - Assert.assertEquals(0, stat.getEphemeralOwner()); - Assert.assertEquals(name.length(), stat.getDataLength()); - Assert.assertEquals(1, stat.getNumChildren()); + assertEquals(stat.getCzxid(), stat.getMzxid()); + assertEquals(stat.getCzxid() + 1, stat.getPzxid()); + assertEquals(stat.getCtime(), stat.getMtime()); + assertEquals(1, stat.getCversion()); + assertEquals(0, stat.getVersion()); + assertEquals(0, stat.getAversion()); + assertEquals(0, stat.getEphemeralOwner()); + assertEquals(name.length(), stat.getDataLength()); + assertEquals(1, stat.getNumChildren()); stat = newStat(); zk.getData(childname, false, stat); - Assert.assertEquals(stat.getCzxid(), stat.getMzxid()); - Assert.assertEquals(stat.getCzxid(), stat.getPzxid()); - Assert.assertEquals(stat.getCtime(), stat.getMtime()); - Assert.assertEquals(0, stat.getCversion()); - Assert.assertEquals(0, stat.getVersion()); - Assert.assertEquals(0, stat.getAversion()); - Assert.assertEquals(zk.getSessionId(), stat.getEphemeralOwner()); - Assert.assertEquals(childname.length(), stat.getDataLength()); - Assert.assertEquals(0, stat.getNumChildren()); + assertEquals(stat.getCzxid(), stat.getMzxid()); + assertEquals(stat.getCzxid(), stat.getPzxid()); + assertEquals(stat.getCtime(), stat.getMtime()); + assertEquals(0, stat.getCversion()); + assertEquals(0, stat.getVersion()); + assertEquals(0, stat.getAversion()); + assertEquals(zk.getSessionId(), stat.getEphemeralOwner()); + assertEquals(childname.length(), stat.getDataLength()); + assertEquals(0, stat.getNumChildren()); } @Test - public void testChildren() - throws IOException, KeeperException, InterruptedException - { + public void testChildren() throws IOException, KeeperException, InterruptedException { String name = "/foo"; - zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, - CreateMode.PERSISTENT); + zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); - for(int i = 0; i < 10; i++) { + for (int i = 0; i < 10; i++) { String childname = name + "/bar" + i; - zk.create(childname, childname.getBytes(), Ids.OPEN_ACL_UNSAFE, - CreateMode.EPHEMERAL); + zk.create(childname, childname.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL); Stat stat; stat = newStat(); zk.getData(name, false, stat); - Assert.assertEquals(stat.getCzxid(), stat.getMzxid()); - Assert.assertEquals(stat.getCzxid() + i + 1, stat.getPzxid()); - Assert.assertEquals(stat.getCtime(), stat.getMtime()); - Assert.assertEquals(i + 1, stat.getCversion()); - Assert.assertEquals(0, stat.getVersion()); - Assert.assertEquals(0, stat.getAversion()); - Assert.assertEquals(0, stat.getEphemeralOwner()); - Assert.assertEquals(name.length(), stat.getDataLength()); - Assert.assertEquals(i + 1, stat.getNumChildren()); + assertEquals(stat.getCzxid(), stat.getMzxid()); + assertEquals(stat.getCzxid() + i + 1, stat.getPzxid()); + assertEquals(stat.getCtime(), stat.getMtime()); + assertEquals(i + 1, stat.getCversion()); + assertEquals(0, stat.getVersion()); + assertEquals(0, stat.getAversion()); + assertEquals(0, stat.getEphemeralOwner()); + assertEquals(name.length(), stat.getDataLength()); + assertEquals(i + 1, stat.getNumChildren()); } } @Test - public void testDataSizeChange() - throws IOException, KeeperException, InterruptedException - { + public void testDataSizeChange() throws IOException, KeeperException, InterruptedException { String name = "/foo"; - zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, - CreateMode.PERSISTENT); + zk.create(name, name.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); Stat stat; stat = newStat(); zk.getData(name, false, stat); - Assert.assertEquals(stat.getCzxid(), stat.getMzxid()); - Assert.assertEquals(stat.getCzxid(), stat.getPzxid()); - Assert.assertEquals(stat.getCtime(), stat.getMtime()); - Assert.assertEquals(0, stat.getCversion()); - Assert.assertEquals(0, stat.getVersion()); - Assert.assertEquals(0, stat.getAversion()); - Assert.assertEquals(0, stat.getEphemeralOwner()); - Assert.assertEquals(name.length(), stat.getDataLength()); - Assert.assertEquals(0, stat.getNumChildren()); + assertEquals(stat.getCzxid(), stat.getMzxid()); + assertEquals(stat.getCzxid(), stat.getPzxid()); + assertEquals(stat.getCtime(), stat.getMtime()); + assertEquals(0, stat.getCversion()); + assertEquals(0, stat.getVersion()); + assertEquals(0, stat.getAversion()); + assertEquals(0, stat.getEphemeralOwner()); + assertEquals(name.length(), stat.getDataLength()); + assertEquals(0, stat.getNumChildren()); zk.setData(name, (name + name).getBytes(), -1); stat = newStat(); zk.getData(name, false, stat); - Assert.assertNotSame(stat.getCzxid(), stat.getMzxid()); - Assert.assertEquals(stat.getCzxid(), stat.getPzxid()); - Assert.assertNotSame(stat.getCtime(), stat.getMtime()); - Assert.assertEquals(0, stat.getCversion()); - Assert.assertEquals(1, stat.getVersion()); - Assert.assertEquals(0, stat.getAversion()); - Assert.assertEquals(0, stat.getEphemeralOwner()); - Assert.assertEquals(name.length() * 2, stat.getDataLength()); - Assert.assertEquals(0, stat.getNumChildren()); + assertNotSame(stat.getCzxid(), stat.getMzxid()); + assertEquals(stat.getCzxid(), stat.getPzxid()); + assertNotSame(stat.getCtime(), stat.getMtime()); + assertEquals(0, stat.getCversion()); + assertEquals(1, stat.getVersion()); + assertEquals(0, stat.getAversion()); + assertEquals(0, stat.getEphemeralOwner()); + assertEquals(name.length() * 2, stat.getDataLength()); + assertEquals(0, stat.getNumChildren()); } + } |