Package org.apache.hadoop.hbase.zookeeper

Class TestZKNodeTracker.TestingZKListener

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKListener

org.apache.hadoop.hbase.zookeeper.TestZKNodeTracker.TestingZKListener

Enclosing class:

TestZKNodeTracker

public static class TestZKNodeTracker.TestingZKListener
extends org.apache.hadoop.hbase.zookeeper.ZKListener

Field Summary

Fields

Modifier and Type	Field	Description
private Semaphore	changedLock
private Semaphore	createdLock
private Semaphore	deletedLock
private static final org.slf4j.Logger	LOG
private String	node

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

watcher

Constructor Summary

Constructors

Constructor	Description
TestingZKListener(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher, String node)

Method Summary

Modifier and Type	Method	Description
void	nodeCreated(String path)
void	nodeDataChanged(String path)
void	nodeDeleted(String path)
(package private) void	waitForCreation()
(package private) void	waitForDataChange()
(package private) void	waitForDeletion()

Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

getWatcher, nodeChildrenChanged

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

deletedLock

private Semaphore deletedLock

createdLock

private Semaphore createdLock

changedLock

private Semaphore changedLock

node

private String node

Constructor Details

TestingZKListener

TestingZKListener(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher,
 String node)

Method Details

nodeDeleted

public void nodeDeleted(String path)

Overrides:

nodeDeleted in class org.apache.hadoop.hbase.zookeeper.ZKListener

nodeCreated

public void nodeCreated(String path)

Overrides:

nodeCreated in class org.apache.hadoop.hbase.zookeeper.ZKListener

nodeDataChanged

public void nodeDataChanged(String path)

Overrides:

nodeDataChanged in class org.apache.hadoop.hbase.zookeeper.ZKListener

waitForDeletion

void waitForDeletion()
              throws InterruptedException

Throws:

InterruptedException

waitForCreation

void waitForCreation()
              throws InterruptedException

Throws:

InterruptedException

waitForDataChange

void waitForDataChange()
                throws InterruptedException

Throws:

InterruptedException