net.spy.memcached.protocol.binary
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
public class BinaryMemcachedNodeImpl
- extends TCPMemcachedNodeImpl
Implementation of MemcachedNode for speakers of the binary protocol.
Constructor Summary |
BinaryMemcachedNodeImpl(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize,
java.util.concurrent.BlockingQueue<Operation> rq,
java.util.concurrent.BlockingQueue<Operation> wq,
java.util.concurrent.BlockingQueue<Operation> iq,
java.lang.Long opQueueMaxBlockTimeNs,
boolean waitForAuth)
|
Method Summary |
protected void |
optimize()
|
Methods inherited from class net.spy.memcached.protocol.TCPMemcachedNodeImpl |
addOp, authComplete, connected, copyInputQueue, destroyInputQueue, fillWriteBuffer, fixupOps, getBytesRemainingToWrite, getChannel, getCurrentReadOp, getCurrentWriteOp, getRbuf, getReconnectCount, getSelectionOps, getSk, getSocketAddress, getWbuf, hasReadOp, hasWriteOp, insertOp, isActive, reconnecting, registerChannel, removeCurrentReadOp, removeCurrentWriteOp, setChannel, setSk, setupForAuth, setupResend, toString, transitionWriteItem, writeSome |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
BinaryMemcachedNodeImpl
public BinaryMemcachedNodeImpl(java.net.SocketAddress sa,
java.nio.channels.SocketChannel c,
int bufSize,
java.util.concurrent.BlockingQueue<Operation> rq,
java.util.concurrent.BlockingQueue<Operation> wq,
java.util.concurrent.BlockingQueue<Operation> iq,
java.lang.Long opQueueMaxBlockTimeNs,
boolean waitForAuth)
optimize
protected void optimize()
- Specified by:
optimize
in class TCPMemcachedNodeImpl