Package org.apache.zookeeper.server
Class ServerCnxn
- java.lang.Object
-
- org.apache.zookeeper.server.ServerCnxn
-
- All Implemented Interfaces:
Watcher
- Direct Known Subclasses:
NettyServerCnxn
,NIOServerCnxn
public abstract class ServerCnxn extends java.lang.Object implements Watcher
Interface to a Server connection - represents a connection from a client to the server.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
ServerCnxn.CloseRequestException
protected static class
ServerCnxn.EndOfStreamException
-
Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher
Watcher.Event, Watcher.WatcherType
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.ArrayList<org.apache.zookeeper.data.Id>
authInfo
protected long
count
protected java.util.Date
established
protected long
lastCxid
protected long
lastLatency
protected java.lang.String
lastOp
protected long
lastResponseTime
protected long
lastZxid
protected long
maxLatency
static java.lang.Object
me
protected long
minLatency
protected java.util.concurrent.atomic.AtomicLong
packetsReceived
protected java.util.concurrent.atomic.AtomicLong
packetsSent
protected long
totalLatency
protected ZooKeeperSaslServer
zooKeeperSaslServer
-
Constructor Summary
Constructors Constructor Description ServerCnxn()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
addAuthInfo(org.apache.zookeeper.data.Id id)
void
cleanupWriterSocket(java.io.PrintWriter pwriter)
clean up the socket related to a command and also make sure we flush the data before we do thatvoid
dumpConnectionInfo(java.io.PrintWriter pwriter, boolean brief)
Print information about the connection.java.util.List<org.apache.zookeeper.data.Id>
getAuthInfo()
auth info for the cnxn, returns an unmodifyable listlong
getAvgLatency()
abstract java.security.cert.Certificate[]
getClientCertificateChain()
java.util.Map<java.lang.String,java.lang.Object>
getConnectionInfo(boolean brief)
java.util.Date
getEstablished()
abstract int
getInterestOps()
long
getLastCxid()
long
getLastLatency()
java.lang.String
getLastOperation()
long
getLastResponseTime()
long
getLastZxid()
long
getMaxLatency()
long
getMinLatency()
abstract long
getOutstandingRequests()
long
getPacketsReceived()
long
getPacketsSent()
abstract java.net.InetSocketAddress
getRemoteSocketAddress()
abstract long
getSessionId()
protected void
incrOutstandingRequests(org.apache.zookeeper.proto.RequestHeader h)
protected long
incrPacketsReceived()
protected long
incrPacketsSent()
abstract boolean
isSecure()
protected void
packetReceived()
protected void
packetSent()
abstract void
process(WatchedEvent event)
boolean
removeAuthInfo(org.apache.zookeeper.data.Id id)
void
resetStats()
void
sendResponse(org.apache.zookeeper.proto.ReplyHeader h, org.apache.jute.Record r, java.lang.String tag)
protected abstract ServerStats
serverStats()
abstract void
setClientCertificateChain(java.security.cert.Certificate[] chain)
java.lang.String
toString()
Prints detailed stats information for the connection.protected void
updateStatsForResponse(long cxid, long zxid, java.lang.String op, long start, long end)
-
-
-
Field Detail
-
me
public static final java.lang.Object me
-
authInfo
protected java.util.ArrayList<org.apache.zookeeper.data.Id> authInfo
-
zooKeeperSaslServer
protected ZooKeeperSaslServer zooKeeperSaslServer
-
established
protected final java.util.Date established
-
packetsReceived
protected final java.util.concurrent.atomic.AtomicLong packetsReceived
-
packetsSent
protected final java.util.concurrent.atomic.AtomicLong packetsSent
-
minLatency
protected long minLatency
-
maxLatency
protected long maxLatency
-
lastOp
protected java.lang.String lastOp
-
lastCxid
protected long lastCxid
-
lastZxid
protected long lastZxid
-
lastResponseTime
protected long lastResponseTime
-
lastLatency
protected long lastLatency
-
count
protected long count
-
totalLatency
protected long totalLatency
-
-
Method Detail
-
sendResponse
public void sendResponse(org.apache.zookeeper.proto.ReplyHeader h, org.apache.jute.Record r, java.lang.String tag) throws java.io.IOException
- Throws:
java.io.IOException
-
process
public abstract void process(WatchedEvent event)
-
getSessionId
public abstract long getSessionId()
-
getAuthInfo
public java.util.List<org.apache.zookeeper.data.Id> getAuthInfo()
auth info for the cnxn, returns an unmodifyable list
-
addAuthInfo
public void addAuthInfo(org.apache.zookeeper.data.Id id)
-
removeAuthInfo
public boolean removeAuthInfo(org.apache.zookeeper.data.Id id)
-
packetReceived
protected void packetReceived()
-
packetSent
protected void packetSent()
-
serverStats
protected abstract ServerStats serverStats()
-
resetStats
public void resetStats()
-
incrPacketsReceived
protected long incrPacketsReceived()
-
incrOutstandingRequests
protected void incrOutstandingRequests(org.apache.zookeeper.proto.RequestHeader h)
-
incrPacketsSent
protected long incrPacketsSent()
-
updateStatsForResponse
protected void updateStatsForResponse(long cxid, long zxid, java.lang.String op, long start, long end)
-
getEstablished
public java.util.Date getEstablished()
-
getOutstandingRequests
public abstract long getOutstandingRequests()
-
getPacketsReceived
public long getPacketsReceived()
-
getPacketsSent
public long getPacketsSent()
-
getMinLatency
public long getMinLatency()
-
getAvgLatency
public long getAvgLatency()
-
getMaxLatency
public long getMaxLatency()
-
getLastOperation
public java.lang.String getLastOperation()
-
getLastCxid
public long getLastCxid()
-
getLastZxid
public long getLastZxid()
-
getLastResponseTime
public long getLastResponseTime()
-
getLastLatency
public long getLastLatency()
-
toString
public java.lang.String toString()
Prints detailed stats information for the connection.- Overrides:
toString
in classjava.lang.Object
- See Also:
for brief stats
-
getRemoteSocketAddress
public abstract java.net.InetSocketAddress getRemoteSocketAddress()
-
getInterestOps
public abstract int getInterestOps()
-
isSecure
public abstract boolean isSecure()
-
getClientCertificateChain
public abstract java.security.cert.Certificate[] getClientCertificateChain()
-
setClientCertificateChain
public abstract void setClientCertificateChain(java.security.cert.Certificate[] chain)
-
dumpConnectionInfo
public void dumpConnectionInfo(java.io.PrintWriter pwriter, boolean brief)
Print information about the connection.- Parameters:
brief
- iff true prints brief details, otw full detail
-
getConnectionInfo
public java.util.Map<java.lang.String,java.lang.Object> getConnectionInfo(boolean brief)
-
cleanupWriterSocket
public void cleanupWriterSocket(java.io.PrintWriter pwriter)
clean up the socket related to a command and also make sure we flush the data before we do that- Parameters:
pwriter
- the pwriter for a command socket
-
-