Class ControllableConnection
java.lang.Object
org.apache.zookeeper.server.ServerCnxn
org.apache.zookeeper.server.NIOServerCnxn
org.apache.zookeeper.server.controller.ControllableConnection
- All Implemented Interfaces:
Watcher
Extension of NIOServerCnxn which can inject changes per controller commands.
Similar extensions can implement on top of NettyServerCnxn as well.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.zookeeper.server.ServerCnxn
ServerCnxn.CloseRequestException, ServerCnxn.DisconnectReason, ServerCnxn.EndOfStreamExceptionNested classes/interfaces inherited from interface org.apache.zookeeper.Watcher
Watcher.Event, Watcher.WatcherType -
Field Summary
Fields inherited from class org.apache.zookeeper.server.NIOServerCnxn
incomingBufferFields inherited from class org.apache.zookeeper.server.ServerCnxn
count, disconnectReason, established, lastCxid, lastLatency, lastOp, lastResponseTime, lastZxid, maxLatency, me, minLatency, packetsReceived, packetsSent, totalLatency, zooKeeperSaslServer -
Constructor Summary
ConstructorsConstructorDescriptionControllableConnection(ZooKeeperServer zk, SocketChannel sock, SelectionKey sk, NIOServerCnxnFactory factory, NIOServerCnxnFactory.SelectorThread selectorThread) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidintsendResponse(ReplyHeader header, Record record, String tag) Methods inherited from class org.apache.zookeeper.server.NIOServerCnxn
close, closeSock, disableRecv, disableSelectable, enableRecv, enableSelectable, getClientCertificateChain, getInterestOps, getRemoteSocketAddress, getSessionId, getSessionTimeout, getSocketAddress, isSecure, isSelectable, isSocketOpen, process, sendBuffer, sendCloseSession, sendResponse, serverStats, setClientCertificateChain, setSessionId, setSessionTimeout, toStringMethods inherited from class org.apache.zookeeper.server.ServerCnxn
addAuthInfo, cleanupWriterSocket, decrOutstandingAndCheckThrottle, dumpConnectionInfo, getAuthInfo, getAvgLatency, getConnectionInfo, getEstablished, getHostAddress, getLastCxid, getLastLatency, getLastOperation, getLastResponseTime, getLastZxid, getMaxLatency, getMinLatency, getOutstandingRequests, getPacketsReceived, getPacketsSent, getSessionIdHex, incrOutstandingAndCheckThrottle, incrPacketsReceived, incrPacketsSent, isInvalid, isStale, isZKServerRunning, packetReceived, packetSent, removeAuthInfo, resetStats, serialize, serializeRecord, setInvalid, setStale, updateStatsForResponse
-
Constructor Details
-
ControllableConnection
public ControllableConnection(ZooKeeperServer zk, SocketChannel sock, SelectionKey sk, NIOServerCnxnFactory factory, NIOServerCnxnFactory.SelectorThread selectorThread) throws IOException - Throws:
IOException
-
-
Method Details
-
sendResponse
- Overrides:
sendResponsein classServerCnxn
-
readRequest
- Overrides:
readRequestin classNIOServerCnxn- Throws:
IOException
-