org.apache.hadoop.hbase.zookeeper

Class TestRecoverableZooKeeper.ZookeeperStub

java.lang.Object

org.apache.zookeeper.ZooKeeper

org.apache.hadoop.hbase.zookeeper.TestRecoverableZooKeeper.ZookeeperStub

All Implemented Interfaces:

AutoCloseable

Enclosing class:

TestRecoverableZooKeeper

static class TestRecoverableZooKeeper.ZookeeperStub
extends org.apache.zookeeper.ZooKeeper

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.zookeeper.ZooKeeper

org.apache.zookeeper.ZooKeeper.States, org.apache.zookeeper.ZooKeeper.WatchRegistration

Field Summary

Fields

Modifier and Type	Field and Description
private int	throwExceptionInNumOperations

Fields inherited from class org.apache.zookeeper.ZooKeeper

cnxn, hostProvider, SECURE_CLIENT, watchManager, ZOOKEEPER_CLIENT_CNXN_SOCKET

Constructor Summary

Constructors

Constructor and Description
ZookeeperStub(String connectString, int sessionTimeout, org.apache.zookeeper.Watcher watcher)

Method Summary

Modifier and Type	Method and Description
private void	checkThrowKeeperException()
org.apache.zookeeper.data.Stat	setData(String path, byte[] data, int version)
(package private) void	setThrowExceptionInNumOperations(int throwExceptionInNumOperations)

Methods inherited from class org.apache.zookeeper.ZooKeeper

addAuthInfo, close, close, create, create, create, create, create, create, createConnection, defaultWatchManager, delete, delete, exists, exists, exists, exists, getACL, getACL, getChildren, getChildren, getChildren, getChildren, getChildren, getChildren, getChildren, getChildren, getChildWatches, getClientConfig, getConfig, getConfig, getConfig, getConfig, getData, getData, getData, getData, getDataWatches, getExistWatches, getSaslClient, getSessionId, getSessionPasswd, getSessionTimeout, getState, getTestable, internalReconfig, internalReconfig, internalReconfig, internalReconfig, multi, multi, multiInternal, multiInternal, reconfig, reconfig, reconfig, reconfig, register, removeAllWatches, removeAllWatches, removeWatches, removeWatches, setACL, setACL, setData, sync, testableLocalSocketAddress, testableRemoteSocketAddress, testableWaitForShutdown, toString, transaction, updateServerList

Methods inherited from class java.lang.Object

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

Field Detail

throwExceptionInNumOperations

private int throwExceptionInNumOperations

Constructor Detail

ZookeeperStub

ZookeeperStub(String connectString,
              int sessionTimeout,
              org.apache.zookeeper.Watcher watcher)
       throws IOException

Throws:

IOException

Method Detail

setThrowExceptionInNumOperations

void setThrowExceptionInNumOperations(int throwExceptionInNumOperations)

checkThrowKeeperException

private void checkThrowKeeperException()
                                throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

setData

public org.apache.zookeeper.data.Stat setData(String path,
                                              byte[] data,
                                              int version)
                                       throws org.apache.zookeeper.KeeperException,
                                              InterruptedException

Overrides:

setData in class org.apache.zookeeper.ZooKeeper

Throws:

org.apache.zookeeper.KeeperException

InterruptedException