Package org.apache.hadoop.hbase.ipc

Class SimpleRpcServer.ConnectionManager

java.lang.Object

org.apache.hadoop.hbase.ipc.SimpleRpcServer.ConnectionManager

Enclosing class:

SimpleRpcServer

private class SimpleRpcServer.ConnectionManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final Set<SimpleServerRpcConnection>	connections
private final AtomicInteger	count
private final int	idleScanInterval
private final int	idleScanThreshold
private final Timer	idleScanTimer
private final int	maxIdleTime
private final int	maxIdleToClose

Constructor Summary

Constructors

Constructor	Description
ConnectionManager()

Method Summary

Modifier and Type	Method	Description
private boolean	add(SimpleServerRpcConnection connection)
(package private) boolean	close(SimpleServerRpcConnection connection)
(package private) void	closeAll()
(package private) void	closeIdle(boolean scanAll)
(package private) SimpleServerRpcConnection	register(SocketChannel channel)
private boolean	remove(SimpleServerRpcConnection connection)
private void	scheduleIdleScanTask()
(package private) int	size()
(package private) void	startIdleScan()
(package private) void	stopIdleScan()
(package private) SimpleServerRpcConnection[]	toArray()

Methods inherited from class java.lang.Object

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

Field Details

count

private final AtomicInteger count

connections

private final Set<SimpleServerRpcConnection> connections

idleScanTimer

private final Timer idleScanTimer

idleScanThreshold

private final int idleScanThreshold

idleScanInterval

private final int idleScanInterval

maxIdleTime

private final int maxIdleTime

maxIdleToClose

private final int maxIdleToClose

Constructor Details

ConnectionManager

ConnectionManager()

Method Details

add

private boolean add(SimpleServerRpcConnection connection)

remove

private boolean remove(SimpleServerRpcConnection connection)

size

int size()

toArray

SimpleServerRpcConnection[] toArray()

register

SimpleServerRpcConnection register(SocketChannel channel)

close

boolean close(SimpleServerRpcConnection connection)

closeIdle

void closeIdle(boolean scanAll)

closeAll

void closeAll()

startIdleScan

void startIdleScan()

stopIdleScan

void stopIdleScan()

scheduleIdleScanTask

private void scheduleIdleScanTask()