public class NettyServerCnxn extends ServerCnxn
ServerCnxn.CloseRequestException, ServerCnxn.EndOfStreamException
Watcher.Event
authInfo, cmd2String, 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 and Description |
---|---|
void |
close() |
void |
disableRecv() |
void |
enableRecv() |
int |
getInterestOps() |
long |
getOutstandingRequests()
The number of requests that have been submitted but not yet
responded to.
|
InetSocketAddress |
getRemoteSocketAddress() |
long |
getSessionId() |
int |
getSessionTimeout() |
void |
process(WatchedEvent event) |
void |
receiveMessage(org.jboss.netty.buffer.ChannelBuffer message) |
void |
sendBuffer(ByteBuffer sendBuffer) |
void |
sendCloseSession()
Send close connection packet to the client.
|
void |
sendResponse(ReplyHeader h,
org.apache.jute.Record r,
String tag) |
protected ServerStats |
serverStats() |
void |
setSessionId(long sessionId) |
void |
setSessionTimeout(int sessionTimeout) |
addAuthInfo, dumpConnectionInfo, getAuthInfo, getAvgLatency, getEstablished, getLastCxid, getLastLatency, getLastOperation, getLastResponseTime, getLastZxid, getMaxLatency, getMinLatency, getPacketsReceived, getPacketsSent, incrOutstandingRequests, incrPacketsReceived, incrPacketsSent, packetReceived, packetSent, removeAuthInfo, resetStats, 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, String tag) throws IOException
sendResponse
in class ServerCnxn
IOException
public void setSessionId(long sessionId)
public void enableRecv()
public void sendBuffer(ByteBuffer sendBuffer)
public void receiveMessage(org.jboss.netty.buffer.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 InetSocketAddress getRemoteSocketAddress()
getRemoteSocketAddress
in class ServerCnxn
public void sendCloseSession()
protected ServerStats serverStats()
serverStats
in class ServerCnxn
Copyright © 2014 The Apache Software Foundation