1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.zookeeper;
20
21 import static org.junit.Assert.*;
22
23 import java.io.IOException;
24
25 import org.apache.hadoop.hbase.HBaseConfiguration;
26 import org.apache.hadoop.hbase.ZooKeeperConnectionException;
27 import org.apache.hadoop.hbase.testclassification.SmallTests;
28 import org.junit.Test;
29 import org.junit.experimental.categories.Category;
30
31 @Category({SmallTests.class})
32 public class TestZooKeeperWatcher {
33
34 @Test
35 public void testIsClientReadable() throws ZooKeeperConnectionException, IOException {
36 ZooKeeperWatcher watcher = new ZooKeeperWatcher(HBaseConfiguration.create(),
37 "testIsClientReadable", null, false);
38
39 assertTrue(watcher.isClientReadable(watcher.baseZNode));
40 assertTrue(watcher.isClientReadable(watcher.getZNodeForReplica(0)));
41 assertTrue(watcher.isClientReadable(watcher.getMasterAddressZNode()));
42 assertTrue(watcher.isClientReadable(watcher.clusterIdZNode));
43 assertTrue(watcher.isClientReadable(watcher.tableZNode));
44 assertTrue(watcher.isClientReadable(ZKUtil.joinZNode(watcher.tableZNode, "foo")));
45 assertTrue(watcher.isClientReadable(watcher.rsZNode));
46
47
48 assertFalse(watcher.isClientReadable(watcher.tableLockZNode));
49 assertFalse(watcher.isClientReadable(watcher.balancerZNode));
50 assertFalse(watcher.isClientReadable(watcher.getRegionNormalizerZNode()));
51 assertFalse(watcher.isClientReadable(watcher.clusterStateZNode));
52 assertFalse(watcher.isClientReadable(watcher.drainingZNode));
53 assertFalse(watcher.isClientReadable(watcher.recoveringRegionsZNode));
54 assertFalse(watcher.isClientReadable(watcher.splitLogZNode));
55 assertFalse(watcher.isClientReadable(watcher.backupMasterAddressesZNode));
56
57 watcher.close();
58 }
59
60 }