Watcher
public class NettyServerCnxn extends ServerCnxn
ServerCnxn.CloseRequestException, ServerCnxn.EndOfStreamException
Watcher.Event
authInfo, confCmd, consCmd, count, crstCmd, dumpCmd, enviCmd, established, getTraceMaskCmd, isroCmd, lastCxid, lastLatency, lastOp, lastResponseTime, lastZxid, maxLatency, me, minLatency, mntrCmd, packetsReceived, packetsSent, ruokCmd, setTraceMaskCmd, srstCmd, srvrCmd, statCmd, totalLatency, wchcCmd, wchpCmd, wchsCmd, zooKeeperSaslServer
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
|
void |
disableRecv() |
|
void |
enableRecv() |
|
int |
getInterestOps() |
|
long |
getOutstandingRequests() |
|
java.net.InetSocketAddress |
getRemoteSocketAddress() |
|
long |
getSessionId() |
|
int |
getSessionTimeout() |
|
java.net.InetAddress |
getSocketAddress() |
Wrapper method to return the socket address
|
void |
process(WatchedEvent event) |
|
void |
receiveMessage(ChannelBuffer message) |
|
void |
sendBuffer(java.nio.ByteBuffer sendBuffer) |
|
void |
sendCloseSession() |
Send close connection packet to the client.
|
void |
sendResponse(ReplyHeader h,
org.apache.jute.Record r,
java.lang.String tag) |
|
protected ServerStats |
serverStats() |
|
void |
setSessionId(long sessionId) |
|
void |
setSessionTimeout(int sessionTimeout) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAuthInfo, dumpConnectionInfo, getAuthInfo, getAvgLatency, getCommandString, getEstablished, getLastCxid, getLastLatency, getLastOperation, getLastResponseTime, getLastZxid, getMaxLatency, getMinLatency, getPacketsReceived, getPacketsSent, incrOutstandingRequests, incrPacketsReceived, incrPacketsSent, isEnabled, isKnown, packetReceived, packetSent, removeAuthInfo, resetStats, resetWhiteList, toString, updateStatsForResponse
public void close()
public long getSessionId()
public int getSessionTimeout()
public void process(WatchedEvent event)
process
in interface Watcher
process
in class ServerCnxn
public void sendResponse(ReplyHeader h, org.apache.jute.Record r, java.lang.String tag) throws java.io.IOException
sendResponse
in class ServerCnxn
java.io.IOException
public void setSessionId(long sessionId)
public void enableRecv()
public void sendBuffer(java.nio.ByteBuffer sendBuffer)
public java.net.InetAddress getSocketAddress()
ServerCnxn
getSocketAddress
in class ServerCnxn
public void receiveMessage(ChannelBuffer message)
public void disableRecv()
public long getOutstandingRequests()
getOutstandingRequests
in class ServerCnxn
public void setSessionTimeout(int sessionTimeout)
public int getInterestOps()
getInterestOps
in class ServerCnxn
public java.net.InetSocketAddress getRemoteSocketAddress()
getRemoteSocketAddress
in class ServerCnxn
public void sendCloseSession()
protected ServerStats serverStats()
serverStats
in class ServerCnxn
Copyright © 2018 The Apache Software Foundation