Class BinaryMemcachedNodeImpl
java.lang.Object
net.spy.memcached.compat.SpyObject
net.spy.memcached.protocol.TCPMemcachedNodeImpl
net.spy.memcached.protocol.binary.BinaryMemcachedNodeImpl
- All Implemented Interfaces:
MemcachedNode
Implementation of MemcachedNode for speakers of the binary protocol.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final int
private static final int
private static final int
Fields inherited from class net.spy.memcached.protocol.TCPMemcachedNodeImpl
optimizedOp, writeQ
-
Constructor Summary
ConstructorsConstructorDescriptionBinaryMemcachedNodeImpl
(SocketAddress sa, SocketChannel c, int bufSize, BlockingQueue<Operation> rq, BlockingQueue<Operation> wq, BlockingQueue<Operation> iq, Long opQueueMaxBlockTimeNs, boolean waitForAuth, long dt, long at, ConnectionFactory fa) -
Method Summary
Methods inherited from class net.spy.memcached.protocol.TCPMemcachedNodeImpl
addOp, authComplete, completedRead, connected, copyInputQueue, destroyInputQueue, fillWriteBuffer, fixupOps, getBytesRemainingToWrite, getChannel, getConnection, getContinuousTimeout, getCurrentReadOp, getCurrentWriteOp, getRbuf, getReconnectCount, getSelectionOps, getSk, getSocketAddress, getWbuf, hasReadOp, hasWriteOp, insertOp, isActive, isAuthenticated, lastReadDelta, reconnecting, registerChannel, removeCurrentReadOp, removeCurrentWriteOp, setChannel, setConnection, setContinuousTimeout, setSk, setupForAuth, setupResend, toString, transitionWriteItem, writeSome
-
Field Details
-
MAX_GET_OPTIMIZATION_COUNT
private static final int MAX_GET_OPTIMIZATION_COUNT- See Also:
-
MAX_SET_OPTIMIZATION_COUNT
private static final int MAX_SET_OPTIMIZATION_COUNT- See Also:
-
MAX_SET_OPTIMIZATION_BYTES
private static final int MAX_SET_OPTIMIZATION_BYTES- See Also:
-
-
Constructor Details
-
BinaryMemcachedNodeImpl
public BinaryMemcachedNodeImpl(SocketAddress sa, SocketChannel c, int bufSize, BlockingQueue<Operation> rq, BlockingQueue<Operation> wq, BlockingQueue<Operation> iq, Long opQueueMaxBlockTimeNs, boolean waitForAuth, long dt, long at, ConnectionFactory fa)
-
-
Method Details
-
optimize
protected void optimize()- Specified by:
optimize
in classTCPMemcachedNodeImpl
-
optimizeGets
private void optimizeGets() -
optimizeSets
private void optimizeSets()
-