Package org.apache.zookeeper.server
Class NettyServerCnxn
java.lang.Object
org.apache.zookeeper.server.ServerCnxn
org.apache.zookeeper.server.NettyServerCnxn
- All Implemented Interfaces:
Watcher
-
Nested Class Summary
Nested ClassesNested 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
FieldsFields inherited from class org.apache.zookeeper.server.ServerCnxn
count, disconnectReason, established, lastCxid, lastLatency, lastOp, lastResponseTime, lastZxid, maxLatency, me, minLatency, packetsReceived, packetsSent, totalLatency, zooKeeperSaslServer -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidclose(ServerCnxn.DisconnectReason reason) Close the cnxn and remove it from the factory cnxns list.voiddisableRecv(boolean waitDisableRecv) Note that the netty implementation ignores thewaitDisableRecvparameter and is always asynchronous.voidintintlongintbooleanisSecure()voidprocess(WatchedEvent event) voidsendBuffer(ByteBuffer... buffers) voidSend close connection packet to the client.intsendResponse(ReplyHeader h, Record r, String tag, String cacheKey, Stat stat, int opCode) Serializes a ZooKeeper response and enqueues it for sending.protected ServerStatsvoidsetClientCertificateChain(Certificate[] chain) voidvoidsetSessionId(long sessionId) voidsetSessionTimeout(int sessionTimeout) Methods 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, sendResponse, serialize, serializeRecord, setInvalid, setStale, toString, updateStatsForResponse
-
Field Details
-
readIssuedAfterReadComplete
public int readIssuedAfterReadComplete
-
-
Method Details
-
close
Close the cnxn and remove it from the factory cnxns list.- Specified by:
closein classServerCnxn
-
close
public void close() -
getSessionId
public long getSessionId()- Specified by:
getSessionIdin classServerCnxn
-
getSessionTimeout
public int getSessionTimeout() -
process
- Specified by:
processin interfaceWatcher- Specified by:
processin classServerCnxn
-
sendResponse
public int sendResponse(ReplyHeader h, Record r, String tag, String cacheKey, Stat stat, int opCode) throws IOException Description copied from class:ServerCnxnSerializes a ZooKeeper response and enqueues it for sending. Serializes client response parts and enqueues them into outgoing queue. If both cache key and last modified zxid are provided, the serialized response is caŃhed under the provided key, the last modified zxid is stored along with the value. A cache entry is invalidated if the provided last modified zxid is more recent than the stored one. Attention: this function is not thread safe, due to caching not being thread safe.- Specified by:
sendResponsein classServerCnxn- Parameters:
h- reply headerr- reply payload, can be nulltag- Jute serialization tag, can be nullcacheKey- Key for caching the serialized payload. A null value prevents caching.stat- Stat information for the the reply payload, used for cache invalidation. A value of 0 prevents caching.opCode- The op code appertains to the corresponding request of the response, used to decide which cache (e.g. read response cache, list of children response cache, ...) object to look up to when applicable.- Throws:
IOException
-
setSessionId
public void setSessionId(long sessionId) -
sendBuffer
-
disableRecv
public void disableRecv(boolean waitDisableRecv) Note that the netty implementation ignores thewaitDisableRecvparameter and is always asynchronous.- Parameters:
waitDisableRecv- ignored by this implementation.
-
enableRecv
public void enableRecv() -
setSessionTimeout
public void setSessionTimeout(int sessionTimeout) -
getInterestOps
public int getInterestOps()- Specified by:
getInterestOpsin classServerCnxn
-
getRemoteSocketAddress
- Specified by:
getRemoteSocketAddressin classServerCnxn
-
sendCloseSession
public void sendCloseSession()Send close connection packet to the client.- Specified by:
sendCloseSessionin classServerCnxn
-
serverStats
- Specified by:
serverStatsin classServerCnxn
-
isSecure
public boolean isSecure()- Specified by:
isSecurein classServerCnxn
-
getClientCertificateChain
- Specified by:
getClientCertificateChainin classServerCnxn
-
setClientCertificateChain
- Specified by:
setClientCertificateChainin classServerCnxn
-
getQueuedReadableBytes
public int getQueuedReadableBytes() -
setHandshakeState
-
getHandshakeState
-