Package org.apache.zookeeper.server
Class NettyServerCnxn
- java.lang.Object
-
- org.apache.zookeeper.server.ServerCnxn
-
- org.apache.zookeeper.server.NettyServerCnxn
-
- All Implemented Interfaces:
Watcher
public class NettyServerCnxn extends ServerCnxn
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.zookeeper.server.ServerCnxn
ServerCnxn.CloseRequestException, ServerCnxn.EndOfStreamException
-
Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher
Watcher.Event
-
-
Field Summary
-
Fields inherited from class org.apache.zookeeper.server.ServerCnxn
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
-
-
Method Summary
All Methods Instance Methods Concrete Methods 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 addressvoid
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)
-
Methods inherited from class org.apache.zookeeper.server.ServerCnxn
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
-
-
-
-
Method Detail
-
close
public void close()
-
getSessionId
public long getSessionId()
-
getSessionTimeout
public int getSessionTimeout()
-
process
public void process(WatchedEvent event)
- Specified by:
process
in interfaceWatcher
- Specified by:
process
in classServerCnxn
-
sendResponse
public void sendResponse(ReplyHeader h, org.apache.jute.Record r, java.lang.String tag) throws java.io.IOException
- Specified by:
sendResponse
in classServerCnxn
- Throws:
java.io.IOException
-
setSessionId
public void setSessionId(long sessionId)
-
enableRecv
public void enableRecv()
-
sendBuffer
public void sendBuffer(java.nio.ByteBuffer sendBuffer)
-
getSocketAddress
public java.net.InetAddress getSocketAddress()
Description copied from class:ServerCnxn
Wrapper method to return the socket address- Specified by:
getSocketAddress
in classServerCnxn
-
receiveMessage
public void receiveMessage(ChannelBuffer message)
-
disableRecv
public void disableRecv()
-
getOutstandingRequests
public long getOutstandingRequests()
- Specified by:
getOutstandingRequests
in classServerCnxn
-
setSessionTimeout
public void setSessionTimeout(int sessionTimeout)
-
getInterestOps
public int getInterestOps()
- Specified by:
getInterestOps
in classServerCnxn
-
getRemoteSocketAddress
public java.net.InetSocketAddress getRemoteSocketAddress()
- Specified by:
getRemoteSocketAddress
in classServerCnxn
-
sendCloseSession
public void sendCloseSession()
Send close connection packet to the client.
-
serverStats
protected ServerStats serverStats()
- Specified by:
serverStats
in classServerCnxn
-
-