View Javadoc

1   /**
2    * Licensed to the Apache Software Foundation (ASF) under one
3    * or more contributor license agreements.  See the NOTICE file
4    * distributed with this work for additional information
5    * regarding copyright ownership.  The ASF licenses this file
6    * to you under the Apache License, Version 2.0 (the
7    * "License"); you may not use this file except in compliance
8    * with the License.  You may obtain a copy of the License at
9    *
10   *     http://www.apache.org/licenses/LICENSE-2.0
11   *
12   * Unless required by applicable law or agreed to in writing, software
13   * distributed under the License is distributed on an "AS IS" BASIS,
14   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15   * See the License for the specific language governing permissions and
16   * limitations under the License.
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  }