Package | Description |
---|---|
com.google.code.yanf4j.core |
Networking core package
|
com.google.code.yanf4j.core.impl | |
com.google.code.yanf4j.nio |
Nio implementation
|
com.google.code.yanf4j.nio.impl | |
net.rubyeye.xmemcached.command |
Memcached protocol implementations
|
net.rubyeye.xmemcached.command.binary |
Memcached text protocol implementations
|
net.rubyeye.xmemcached.command.kestrel |
Kestrel protocol implementations
|
net.rubyeye.xmemcached.command.text |
Memcached text protocol implementations
|
net.rubyeye.xmemcached.impl |
Manage tcp connection,memcached protocol optimized,and some
MBeans for monitor.
|
Modifier and Type | Field and Description |
---|---|
Queue<WriteMessage> |
SessionConfig.queue |
Constructor and Description |
---|
SessionConfig(Handler handler,
CodecFactory codecFactory,
Statistics statistics,
Queue<WriteMessage> queue,
Dispatcher dispatchMessageDispatcher,
boolean handleReadWriteConcurrently,
long sessionTimeout,
long sessionIdelTimeout) |
Modifier and Type | Class and Description |
---|---|
class |
WriteMessageImpl
Write message implementation with a buffer
|
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<WriteMessage> |
AbstractSession.currentMessage |
protected Queue<WriteMessage> |
AbstractSession.writeQueue |
Modifier and Type | Method and Description |
---|---|
protected WriteMessage |
AbstractSession.preprocessWriteMessage(WriteMessage writeMessage)
Pre-Process WriteMessage before writing to channel
|
protected abstract WriteMessage |
AbstractSession.wrapMessage(Object msg,
Future<Boolean> writeFuture) |
Modifier and Type | Method and Description |
---|---|
protected Queue<WriteMessage> |
AbstractController.buildQueue()
Build write queue for session
|
Queue<WriteMessage> |
AbstractSession.getWriteQueue() |
Modifier and Type | Method and Description |
---|---|
protected WriteMessage |
AbstractSession.preprocessWriteMessage(WriteMessage writeMessage)
Pre-Process WriteMessage before writing to channel
|
abstract void |
AbstractSession.writeFromUserCode(WriteMessage message) |
Constructor and Description |
---|
NioSessionConfig(SelectableChannel sc,
Handler handler,
SelectorManager reactor,
CodecFactory codecFactory,
Statistics statistics,
Queue<WriteMessage> queue,
Dispatcher dispatchMessageDispatcher,
boolean handleReadWriteConcurrently,
long sessionTimeout,
long sessionIdleTimeout) |
Modifier and Type | Method and Description |
---|---|
protected WriteMessage |
NioTCPSession.wrapMessage(Object msg,
Future<Boolean> writeFuture) |
Modifier and Type | Method and Description |
---|---|
protected Object |
NioTCPSession.blockingWrite(SelectableChannel channel,
WriteMessage message,
IoBuffer writeBuffer)
Blocking write using temp selector
|
protected boolean |
AbstractNioSession.schduleWriteMessage(WriteMessage writeMessage) |
void |
AbstractNioSession.writeFromUserCode(WriteMessage message) |
protected Object |
NioTCPSession.writeToChannel(WriteMessage message) |
protected abstract Object |
AbstractNioSession.writeToChannel(WriteMessage msg) |
Modifier and Type | Method and Description |
---|---|
protected NioSessionConfig |
NioController.buildSessionConfig(SelectableChannel sc,
Queue<WriteMessage> queue)
Build nio session config
|
Modifier and Type | Class and Description |
---|---|
class |
Command
Abstract Memcached Command
|
class |
VerbosityCommand
Abstract verbosity command for text protocol
|
Modifier and Type | Class and Description |
---|---|
class |
BaseBinaryCommand
Base Binary command.
|
class |
BinaryAppendPrependCommand
Binary protocol for append,prepend
|
class |
BinaryAuthListMechanismsCommand
List auth mechanisms command
|
class |
BinaryAuthStartCommand
Auth start command
|
class |
BinaryAuthStepCommand
Auth step command
|
class |
BinaryCASCommand
CAS binary protocol implementation
|
class |
BinaryDeleteCommand
Binary delete command
|
class |
BinaryFlushAllCommand
Flush command for binary protocol
|
class |
BinaryGetAndTouchCommand
Binary GAT/GATQ command
|
class |
BinaryGetCommand
Implements get/getq,getk/getkq protocol
|
class |
BinaryGetMultiCommand
A command for holding getkq commands
|
class |
BinaryIncrDecrCommand
Binary incr/decr command
|
class |
BinaryNoopCommand
Implement noop protocol
|
class |
BinaryQuitCommand
Quit command for binary protocol
|
class |
BinarySetMultiCommand
A command for holding getkq commands
|
class |
BinaryStatsCommand
Stats command for binary protocol
|
class |
BinaryStoreCommand
Base binary protocol implementation
|
class |
BinaryTouchCommand
Binary touch command
|
class |
BinaryVerbosityCommand
Binary verbosity command
|
class |
BinaryVersionCommand
Version command for binary protocol
|
Modifier and Type | Class and Description |
---|---|
class |
KestrelDeleteCommand |
class |
KestrelFlushAllCommand
Kestrel flush command
|
class |
KestrelGetCommand
Kestrel get command
|
class |
KestrelSetCommand
kestrel set command
|
Modifier and Type | Class and Description |
---|---|
class |
TextCacheDumpCommand |
class |
TextCASCommand
CAS command for text protocol
|
class |
TextDeleteCommand
Delete command for text protocol
|
class |
TextFlushAllCommand
FlushAll command for text protocol
|
class |
TextGetCommand
Abstract get command for text protocol
|
class |
TextGetMultiCommand
Bulk-get command for text protocol
|
class |
TextGetOneCommand
Get command for text protocol
|
class |
TextIncrDecrCommand
Incr/Decr command for text protocol
|
class |
TextQuitCommand
Quit command for text protocol
|
class |
TextStatsCommand
Stats command for text protocol
|
class |
TextStoreCommand
Store command for text protocol
|
class |
TextTouchCommand
Touch command for touch protocol.
|
class |
TextVerbosityCommand
Verbosity command for text protocol
|
class |
TextVersionCommand
Version command for text protocol
|
Modifier and Type | Method and Description |
---|---|
WriteMessage |
FlowControlLinkedTransferQueue.peek() |
WriteMessage |
FlowControlLinkedTransferQueue.poll() |
WriteMessage |
FlowControlLinkedTransferQueue.poll(long timeout,
TimeUnit unit) |
protected WriteMessage |
MemcachedTCPSession.preprocessWriteMessage(WriteMessage writeMessage) |
WriteMessage |
FlowControlLinkedTransferQueue.take() |
protected WriteMessage |
MemcachedTCPSession.wrapMessage(Object msg,
Future<Boolean> writeFuture) |
Modifier and Type | Method and Description |
---|---|
protected Queue<WriteMessage> |
MemcachedConnector.buildQueue()
Build write queue for session
|
Iterator<WriteMessage> |
FlowControlLinkedTransferQueue.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
FlowControlLinkedTransferQueue.offer(WriteMessage e) |
boolean |
FlowControlLinkedTransferQueue.offer(WriteMessage e,
long timeout,
TimeUnit unit) |
protected WriteMessage |
MemcachedTCPSession.preprocessWriteMessage(WriteMessage writeMessage) |
void |
FlowControlLinkedTransferQueue.put(WriteMessage e) |
void |
FlowControlLinkedTransferQueue.transfer(WriteMessage e) |
boolean |
FlowControlLinkedTransferQueue.tryTransfer(WriteMessage e) |
boolean |
FlowControlLinkedTransferQueue.tryTransfer(WriteMessage e,
long timeout,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
int |
FlowControlLinkedTransferQueue.drainTo(Collection<? super WriteMessage> c) |
int |
FlowControlLinkedTransferQueue.drainTo(Collection<? super WriteMessage> c,
int maxElements) |
Copyright © 2016. All rights reserved.