Package org.apache.hadoop.hbase.ipc

Class IntegrationTestRpcClient.Cluster

java.lang.Object

org.apache.hadoop.hbase.ipc.IntegrationTestRpcClient.Cluster

Enclosing class:

IntegrationTestRpcClient

class IntegrationTestRpcClient.Cluster
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) ReadWriteLock	lock
(package private) int	maxServers
(package private) int	minServers
(package private) HashMap<InetSocketAddress,org.apache.hadoop.hbase.ipc.RpcServer>	rpcServers
(package private) List<org.apache.hadoop.hbase.ipc.RpcServer>	serverList

Constructor Summary

Constructors

Constructor	Description
Cluster(int minServers, int maxServers)

Method Summary

Modifier and Type	Method	Description
(package private) org.apache.hadoop.hbase.ipc.RpcServer	getRandomServer()
(package private) org.apache.hadoop.hbase.ipc.RpcServer	startServer()
(package private) void	stopRandomServer()
(package private) void	stopRunning()
(package private) void	stopServer(org.apache.hadoop.hbase.ipc.RpcServer rpcServer)

Methods inherited from class java.lang.Object

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

Field Details

lock

ReadWriteLock lock

rpcServers

HashMap<InetSocketAddress,org.apache.hadoop.hbase.ipc.RpcServer> rpcServers

serverList

List<org.apache.hadoop.hbase.ipc.RpcServer> serverList

maxServers

int maxServers

minServers

int minServers

Constructor Details

Cluster

Cluster(int minServers,
 int maxServers)

Method Details

startServer

org.apache.hadoop.hbase.ipc.RpcServer startServer()
                                           throws IOException

Throws:

IOException

stopRandomServer

void stopRandomServer()
               throws Exception

Throws:

Exception

stopServer

void stopServer(org.apache.hadoop.hbase.ipc.RpcServer rpcServer)
         throws InterruptedException

Throws:

InterruptedException

stopRunning

void stopRunning()
          throws InterruptedException

Throws:

InterruptedException

getRandomServer

org.apache.hadoop.hbase.ipc.RpcServer getRandomServer()