public class DumbWatcher extends ServerCnxn
ServerCnxn.CloseRequestException, ServerCnxn.DisconnectReason, ServerCnxn.EndOfStreamException
Watcher.Event, Watcher.WatcherType
count, disconnectReason, established, lastCxid, lastLatency, lastOp, lastResponseTime, lastZxid, maxLatency, me, minLatency, packetsReceived, packetsSent, requestsProcessedCount, totalLatency, zooKeeperSaslServer
Constructor and Description |
---|
DumbWatcher() |
DumbWatcher(long sessionId) |
Modifier and Type | Method and Description |
---|---|
void |
close(ServerCnxn.DisconnectReason reason) |
Certificate[] |
getClientCertificateChain() |
int |
getInterestOps() |
long |
getOutstandingRequests()
The number of requests that have been submitted but not yet
responded to.
|
InetSocketAddress |
getRemoteSocketAddress() |
long |
getSessionId() |
boolean |
isSecure() |
void |
process(WatchedEvent event) |
void |
sendCloseSession() |
void |
sendResponse(ReplyHeader h,
Record r,
String tag,
String cacheKey,
Stat stat,
int opCode)
Serializes a ZooKeeper response and enqueues it for sending.
|
protected ServerStats |
serverStats() |
void |
setClientCertificateChain(Certificate[] chain) |
addAuthInfo, cleanupWriterSocket, decrOutstandingAndCheckThrottle, dumpConnectionInfo, getAuthInfo, getAvgLatency, getConnectionInfo, getEstablished, getHostAddress, getLastCxid, getLastLatency, getLastOperation, getLastResponseTime, getLastZxid, getMaxLatency, getMinLatency, getPacketsReceived, getPacketsSent, getSessionIdHex, incrOutstandingAndCheckThrottle, incrPacketsReceived, incrPacketsSent, isInvalid, isStale, packetReceived, packetSent, removeAuthInfo, resetStats, sendResponse, serialize, serializeRecord, setInvalid, setStale, toString, updateStatsForResponse
public void process(WatchedEvent event)
process
in interface Watcher
process
in class ServerCnxn
public void close(ServerCnxn.DisconnectReason reason)
close
in class ServerCnxn
public void sendResponse(ReplyHeader h, Record r, String tag, String cacheKey, Stat stat, int opCode) throws IOException
ServerCnxn
sendResponse
in class ServerCnxn
h
- reply headerr
- reply payload, can be nulltag
- Jute serialization tag, can be nullcacheKey
- Key for caching the serialized payload. A null value prevents caching.stat
- Stat information for the the reply payload, used for cache invalidation.
A value of 0 prevents caching.opCode
- The op code appertains to the corresponding request of the response,
used to decide which cache (e.g. read response cache,
list of children response cache, ...) object to look up to when applicable.IOException
public void sendCloseSession()
sendCloseSession
in class ServerCnxn
public long getSessionId()
getSessionId
in class ServerCnxn
protected ServerStats serverStats()
serverStats
in class ServerCnxn
public long getOutstandingRequests()
getOutstandingRequests
in class ServerCnxn
public InetSocketAddress getRemoteSocketAddress()
getRemoteSocketAddress
in class ServerCnxn
public int getInterestOps()
getInterestOps
in class ServerCnxn
public boolean isSecure()
isSecure
in class ServerCnxn
public Certificate[] getClientCertificateChain()
getClientCertificateChain
in class ServerCnxn
public void setClientCertificateChain(Certificate[] chain)
setClientCertificateChain
in class ServerCnxn
Copyright © 2008–2020 The Apache Software Foundation. All rights reserved.