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 and Description
private Set<SimpleServerRpcConnection>	connections
private AtomicInteger	count
private int	idleScanInterval
private int	idleScanThreshold
private Timer	idleScanTimer
private int	maxIdleTime
private int	maxIdleToClose

Constructor Summary

Constructors

Constructor and Description
ConnectionManager()

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

ConnectionManager

ConnectionManager()

Method Detail

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()