public class ClientCnxnSocketNIO
extends java.lang.Object
Modifier and Type | Field | Description |
---|---|---|
protected java.nio.ByteBuffer |
incomingBuffer |
After the length is read, a new incomingBuffer is allocated in
readLength() to receive the full message.
|
protected boolean |
initialized |
|
protected long |
lastHeard |
|
protected long |
lastSend |
|
protected java.nio.ByteBuffer |
lenBuffer |
This buffer is only used to read the length of the incoming message.
|
protected long |
now |
|
protected long |
recvCount |
|
protected org.apache.zookeeper.ClientCnxn.SendThread |
sendThread |
|
protected long |
sentCount |
|
protected long |
sessionId |
The sessionId is only available here for Log and Exception messages.
|
Modifier and Type | Method | Description |
---|---|---|
void |
disableWrite() |
|
protected void |
readLength() |
protected boolean initialized
protected final java.nio.ByteBuffer lenBuffer
protected java.nio.ByteBuffer incomingBuffer
protected long sentCount
protected long recvCount
protected long lastHeard
protected long lastSend
protected long now
protected org.apache.zookeeper.ClientCnxn.SendThread sendThread
protected long sessionId
Copyright © 2018 The Apache Software Foundation