Public Member Functions | |
| void | addOp (Operation op) |
| void | connected () |
| void | fillWriteBuffer (boolean optimizeGets) |
| void | fixupOps () |
| int | getBytesRemainingToWrite () |
| SocketChannel | getChannel () |
| Operation | getCurrentReadOp () |
| Operation | getCurrentWriteOp () |
| ByteBuffer | getRbuf () |
| int | getReconnectCount () |
| int | getSelectionOps () |
| SelectionKey | getSk () |
| SocketAddress | getSocketAddress () |
| ByteBuffer | getWbuf () |
| boolean | hasReadOp () |
| boolean | hasWriteOp () |
| boolean | isActive () |
| void | reconnecting () |
| void | registerChannel (SocketChannel ch, SelectionKey selectionKey) |
| Operation | removeCurrentReadOp () |
| Operation | removeCurrentWriteOp () |
| void | setChannel (SocketChannel to) |
| void | setSk (SelectionKey to) |
| void | setupResend () |
| void | transitionWriteItem () |
| int | writeSome () throws IOException |
Package Functions | |
| void | copyInputQueue () |
| void addOp | ( | Operation | op | ) |
Add an operation to the queue.
Implemented in TCPMemcachedNodeImpl.
| void connected | ( | ) |
Notify this node that it has reconnected.
Implemented in TCPMemcachedNodeImpl.
| void copyInputQueue | ( | ) | [package] |
Move all of the operations delivered via addOperation into the internal write queue.
Implemented in TCPMemcachedNodeImpl.
| void fillWriteBuffer | ( | boolean | optimizeGets | ) |
Fill the write buffer with data from the next operations in the queue.
| optimizeGets | if true, combine sequential gets into a single multi-key get |
Implemented in TCPMemcachedNodeImpl.
| void fixupOps | ( | ) |
Fix up the selection ops on the selection key.
Implemented in TCPMemcachedNodeImpl.
| int getBytesRemainingToWrite | ( | ) |
Get the number of bytes remaining to write.
Implemented in TCPMemcachedNodeImpl.
| SocketChannel getChannel | ( | ) |
Get the SocketChannel for this connection.
Implemented in TCPMemcachedNodeImpl.
| Operation getCurrentReadOp | ( | ) |
Get the operation at the top of the queue that is requiring input.
Implemented in TCPMemcachedNodeImpl.
| Operation getCurrentWriteOp | ( | ) |
Get the operation at the top of the queue that has information available to write.
Implemented in TCPMemcachedNodeImpl.
| ByteBuffer getRbuf | ( | ) |
Get the buffer used for reading data from this node.
Implemented in TCPMemcachedNodeImpl.
| int getReconnectCount | ( | ) |
Get the current reconnect count.
Implemented in TCPMemcachedNodeImpl.
| int getSelectionOps | ( | ) |
Compute the appropriate selection operations for the channel this MemcachedNode holds to the server.
Implemented in TCPMemcachedNodeImpl.
| SelectionKey getSk | ( | ) |
Get the selection key from this node.
Implemented in TCPMemcachedNodeImpl.
| SocketAddress getSocketAddress | ( | ) |
Get the SocketAddress of the server to which this node is connected.
Implemented in TCPMemcachedNodeImpl.
| ByteBuffer getWbuf | ( | ) |
Get the buffer used for writing data to this node.
Implemented in TCPMemcachedNodeImpl.
| boolean hasReadOp | ( | ) |
True if an operation is available to read.
Implemented in TCPMemcachedNodeImpl.
| boolean hasWriteOp | ( | ) |
True if an operation is available to write.
Implemented in TCPMemcachedNodeImpl.
| boolean isActive | ( | ) |
True if this node is <q>active.</q> i.e. is is currently connected and expected to be able to process requests
Implemented in TCPMemcachedNodeImpl.
| void reconnecting | ( | ) |
Notify this node that it will be reconnecting.
Implemented in TCPMemcachedNodeImpl.
| void registerChannel | ( | SocketChannel | ch, | |
| SelectionKey | selectionKey | |||
| ) |
Register a channel with this node.
Implemented in TCPMemcachedNodeImpl.
| Operation removeCurrentReadOp | ( | ) |
Remove the operation at the top of the queue that is requiring input.
Implemented in TCPMemcachedNodeImpl.
| Operation removeCurrentWriteOp | ( | ) |
Remove the operation at the top of the queue that has information available to write.
Implemented in TCPMemcachedNodeImpl.
| void setChannel | ( | SocketChannel | to | ) |
Set the SocketChannel this node uses.
Implemented in TCPMemcachedNodeImpl.
| void setSk | ( | SelectionKey | to | ) |
Set the selection key for this node.
Implemented in TCPMemcachedNodeImpl.
| void setupResend | ( | ) |
Clear the queue of currently processing operations by either cancelling them or setting them up to be reapplied after a reconnect.
Implemented in TCPMemcachedNodeImpl.
| void transitionWriteItem | ( | ) |
Transition the current write item into a read state.
Implemented in TCPMemcachedNodeImpl.
| int writeSome | ( | ) | throws IOException |
Write some bytes and return the number of bytes written.
| IOException | if there's a problem writing |
Implemented in TCPMemcachedNodeImpl.
1.5.8