ServerCnxn (Apache ZooKeeper - Server 3.5.7 API)

java.lang.Object
- org.apache.zookeeper.server.ServerCnxn

All Implemented Interfaces:

Watcher

Direct Known Subclasses:

NettyServerCnxn, NIOServerCnxn
```
public abstract class ServerCnxn
extends 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 and 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

Nested Classes
Modifier and Type	Class and Description
`protected static class`	`ServerCnxn.CloseRequestException`
`protected static class`	`ServerCnxn.EndOfStreamException`

Field Summary

Fields
Modifier and Type	Field and Description
`protected ArrayList<Id>`	`authInfo`
`protected long`	`count`
`protected Date`	`established`
`protected long`	`lastCxid`
`protected long`	`lastLatency`
`protected String`	`lastOp`
`protected long`	`lastResponseTime`
`protected long`	`lastZxid`
`protected long`	`maxLatency`
`static Object`	`me`
`protected long`	`minLatency`
`protected AtomicLong`	`packetsReceived`
`protected AtomicLong`	`packetsSent`
`protected long`	`totalLatency`
`protected ZooKeeperSaslServer`	`zooKeeperSaslServer`

Constructor Summary

Constructors
Constructor and Description

ServerCnxn()

Constructors
Constructor and Description
`ServerCnxn()`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addAuthInfo(Id id)`
`void`	`cleanupWriterSocket(PrintWriter pwriter)` clean up the socket related to a command and also make sure we flush the data before we do that
`void`	`dumpConnectionInfo(PrintWriter pwriter, boolean brief)` Print information about the connection.
`List<Id>`	`getAuthInfo()` auth info for the cnxn, returns an unmodifyable list
`long`	`getAvgLatency()` Average latency in ms
`abstract Certificate[]`	`getClientCertificateChain()`
`Map<String,Object>`	`getConnectionInfo(boolean brief)`
`Date`	`getEstablished()` Date/time the connection was established
`abstract int`	`getInterestOps()`
`long`	`getLastCxid()` Last cxid of this connection
`long`	`getLastLatency()` Latency of last response to client on this connection in ms
`String`	`getLastOperation()` Last operation performed by this connection
`long`	`getLastResponseTime()` Last time server sent a response to client on this connection
`long`	`getLastZxid()` Last zxid of this connection
`long`	`getMaxLatency()` Max latency in ms
`long`	`getMinLatency()` Min latency in ms
`abstract long`	`getOutstandingRequests()` The number of requests that have been submitted but not yet responded to.
`long`	`getPacketsReceived()` Number of packets received
`long`	`getPacketsSent()` Number of packets sent (incl notifications)
`abstract InetSocketAddress`	`getRemoteSocketAddress()`
`abstract long`	`getSessionId()`
`protected void`	`incrOutstandingRequests(RequestHeader h)`
`protected long`	`incrPacketsReceived()`
`protected long`	`incrPacketsSent()`
`abstract boolean`	`isSecure()`
`protected void`	`packetReceived()`
`protected void`	`packetSent()`
`abstract void`	`process(WatchedEvent event)`
`boolean`	`removeAuthInfo(Id id)`
`void`	`resetStats()` Reset counters
`void`	`sendResponse(ReplyHeader h, Record r, String tag)`
`protected abstract ServerStats`	`serverStats()`
`abstract void`	`setClientCertificateChain(Certificate[] chain)`
`String`	`toString()` Prints detailed stats information for the connection.
`protected void`	`updateStatsForResponse(long cxid, long zxid, String op, long start, long end)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

me
```
public static final Object me
```

authInfo
```
protected ArrayList<Id> authInfo
```

zooKeeperSaslServer

protected ZooKeeperSaslServer zooKeeperSaslServer

established
```
protected final Date established
```

packetsReceived

protected final AtomicLong packetsReceived

packetsSent
```
protected final AtomicLong packetsSent
```

minLatency
```
protected long minLatency
```

maxLatency
```
protected long maxLatency
```

lastOp
```
protected 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
```

Constructor Detail
- ServerCnxn
```
public ServerCnxn()
```

Method Detail

sendResponse

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

Throws:: IOException

process

public abstract void process(WatchedEvent event)

Specified by:: process in interface Watcher

getSessionId
```
public abstract long getSessionId()
```

getAuthInfo
```
public List<Id> getAuthInfo()
```
auth info for the cnxn, returns an unmodifyable list

addAuthInfo
```
public void addAuthInfo(Id id)
```

removeAuthInfo
```
public boolean removeAuthInfo(Id id)
```

packetReceived
```
protected void packetReceived()
```

packetSent
```
protected void packetSent()
```

serverStats

protected abstract ServerStats serverStats()

resetStats
```
public void resetStats()
```
Reset counters

incrPacketsReceived
```
protected long incrPacketsReceived()
```

incrOutstandingRequests

protected void incrOutstandingRequests(RequestHeader h)

incrPacketsSent
```
protected long incrPacketsSent()
```

updateStatsForResponse

protected void updateStatsForResponse(long cxid,
                                      long zxid,
                                      String op,
                                      long start,
                                      long end)

getEstablished
```
public Date getEstablished()
```
Date/time the connection was established

getOutstandingRequests
```
public abstract long getOutstandingRequests()
```
The number of requests that have been submitted but not yet responded to.

getPacketsReceived
```
public long getPacketsReceived()
```
Number of packets received

getPacketsSent
```
public long getPacketsSent()
```
Number of packets sent (incl notifications)

getMinLatency
```
public long getMinLatency()
```
Min latency in ms

getAvgLatency
```
public long getAvgLatency()
```
Average latency in ms

getMaxLatency
```
public long getMaxLatency()
```
Max latency in ms

getLastOperation
```
public String getLastOperation()
```
Last operation performed by this connection

getLastCxid
```
public long getLastCxid()
```
Last cxid of this connection

getLastZxid
```
public long getLastZxid()
```
Last zxid of this connection

getLastResponseTime
```
public long getLastResponseTime()
```
Last time server sent a response to client on this connection

getLastLatency
```
public long getLastLatency()
```
Latency of last response to client on this connection in ms

toString
```
public String toString()
```
Prints detailed stats information for the connection.

Overrides:

toString in class Object

See Also:

for brief stats

getRemoteSocketAddress

public abstract InetSocketAddress getRemoteSocketAddress()

getInterestOps
```
public abstract int getInterestOps()
```

isSecure
```
public abstract boolean isSecure()
```

getClientCertificateChain

public abstract Certificate[] getClientCertificateChain()

setClientCertificateChain

public abstract void setClientCertificateChain(Certificate[] chain)

dumpConnectionInfo
```
public void dumpConnectionInfo(PrintWriter pwriter,
                               boolean brief)
```
Print information about the connection.

Parameters:

brief - iff true prints brief details, otw full detail

getConnectionInfo

public Map<String,Object> getConnectionInfo(boolean brief)

cleanupWriterSocket
```
public void cleanupWriterSocket(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

Class ServerCnxn

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

me

authInfo

zooKeeperSaslServer

established

packetsReceived

packetsSent

minLatency

maxLatency

lastOp

lastCxid

lastZxid

lastResponseTime

lastLatency

count

totalLatency

Constructor Detail

ServerCnxn

Method Detail

sendResponse

process

getSessionId

getAuthInfo

addAuthInfo

removeAuthInfo

packetReceived

packetSent

serverStats

resetStats

incrPacketsReceived

incrOutstandingRequests

incrPacketsSent

updateStatsForResponse

getEstablished

getOutstandingRequests

getPacketsReceived

getPacketsSent

getMinLatency

getAvgLatency

getMaxLatency

getLastOperation

getLastCxid

getLastZxid

getLastResponseTime

getLastLatency

toString

getRemoteSocketAddress

getInterestOps

isSecure

getClientCertificateChain

setClientCertificateChain

dumpConnectionInfo

getConnectionInfo

cleanupWriterSocket