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, Watcher.WatcherType

Field Summary

Fields inherited from class org.apache.zookeeper.server.ServerCnxn

authInfo, count, established, lastCxid, lastLatency, lastOp, lastResponseTime, lastZxid, maxLatency, me, minLatency, packetsReceived, packetsSent, totalLatency, zooKeeperSaslServer

Method Summary

Modifier and Type	Method and Description
void	close()
void	disableRecv() Note that both disableRecv() and disableRecvNoWait() are asynchronous in the netty implementation.
void	enableRecv()
Certificate[]	getClientCertificateChain()
int	getInterestOps()
long	getOutstandingRequests() The number of requests that have been submitted but not yet responded to.
InetSocketAddress	getRemoteSocketAddress()
long	getSessionId()
int	getSessionTimeout()
boolean	isSecure()
void	process(WatchedEvent event)
void	sendBuffer(ByteBuffer sendBuffer)
void	sendCloseSession() Send close connection packet to the client.
void	sendResponse(ReplyHeader h, Record r, String tag)
protected ServerStats	serverStats()
void	setClientCertificateChain(Certificate[] chain)
void	setSessionId(long sessionId)
void	setSessionTimeout(int sessionTimeout)

Methods inherited from class org.apache.zookeeper.server.ServerCnxn

addAuthInfo, cleanupWriterSocket, dumpConnectionInfo, getAuthInfo, getAvgLatency, getConnectionInfo, getEstablished, getLastCxid, getLastLatency, getLastOperation, getLastResponseTime, getLastZxid, getMaxLatency, getMinLatency, getPacketsReceived, getPacketsSent, incrOutstandingRequests, incrPacketsReceived, incrPacketsSent, packetReceived, packetSent, removeAuthInfo, resetStats, toString, updateStatsForResponse

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

close

public void close()

getSessionId

public long getSessionId()

Specified by:

getSessionId in class ServerCnxn

getSessionTimeout

public int getSessionTimeout()

process

public void process(WatchedEvent event)

Specified by:

process in interface Watcher

Specified by:

process in class ServerCnxn

sendResponse

public void sendResponse(ReplyHeader h,
                         Record r,
                         String tag)
                  throws IOException

Overrides:

sendResponse in class ServerCnxn

Throws:

IOException

setSessionId

public void setSessionId(long sessionId)

sendBuffer

public void sendBuffer(ByteBuffer sendBuffer)

disableRecv

public void disableRecv()

Note that both disableRecv() and disableRecvNoWait() are asynchronous in the netty implementation.

enableRecv

public void enableRecv()

getOutstandingRequests

public long getOutstandingRequests()

The number of requests that have been submitted but not yet responded to.

Specified by:

getOutstandingRequests in class ServerCnxn

setSessionTimeout

public void setSessionTimeout(int sessionTimeout)

getInterestOps

public int getInterestOps()

Specified by:

getInterestOps in class ServerCnxn

getRemoteSocketAddress

public InetSocketAddress getRemoteSocketAddress()

Specified by:

getRemoteSocketAddress in class ServerCnxn

sendCloseSession

public void sendCloseSession()

Send close connection packet to the client.

serverStats

protected ServerStats serverStats()

Specified by:

serverStats in class ServerCnxn

isSecure

public boolean isSecure()

Specified by:

isSecure in class ServerCnxn

getClientCertificateChain

public Certificate[] getClientCertificateChain()

Specified by:

getClientCertificateChain in class ServerCnxn

setClientCertificateChain

public void setClientCertificateChain(Certificate[] chain)

Specified by:

setClientCertificateChain in class ServerCnxn