|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object net.spy.memcached.compat.SpyObject net.spy.memcached.DefaultConnectionFactory
public class DefaultConnectionFactory
Default implementation of ConnectionFactory.
This implementation creates connections where the operation queue is an
ArrayBlockingQueue and the read and write queues are unbounded
LinkedBlockingQueues. The Redistribute
FailureMode is used
by default.
Field Summary | |
---|---|
static FailureMode |
DEFAULT_FAILURE_MODE
Default failure mode. |
static HashAlgorithm |
DEFAULT_HASH
Default hash algorithm. |
static long |
DEFAULT_MAX_RECONNECT_DELAY
Maximum amount of time (in seconds) to wait between reconnect attempts. |
static int |
DEFAULT_OP_QUEUE_LEN
Maximum length of the operation queue returned by this connection factory. |
static long |
DEFAULT_OPERATION_TIMEOUT
Default operation timeout in milliseconds. |
static int |
DEFAULT_READ_BUFFER_SIZE
The read buffer size for each server connection from this factory. |
Constructor Summary | |
---|---|
DefaultConnectionFactory()
Create a DefaultConnectionFactory with the default parameters. |
|
DefaultConnectionFactory(int qLen,
int bufSize)
Create a DefaultConnectionFactory with the given maximum operation queue length, and the given read buffer size. |
|
DefaultConnectionFactory(int qLen,
int bufSize,
HashAlgorithm hash)
Construct a DefaultConnectionFactory with the given parameters. |
Method Summary | |
---|---|
MemcachedConnection |
createConnection(List<InetSocketAddress> addrs)
Create a MemcachedConnection for the given SocketAddresses. |
NodeLocator |
createLocator(List<MemcachedNode> nodes)
Create a NodeLocator instance for the given list of nodes. |
MemcachedNode |
createMemcachedNode(SocketAddress sa,
SocketChannel c,
int bufSize)
Create a new memcached node. |
BlockingQueue<Operation> |
createOperationQueue()
Create a BlockingQueue for operations for a connection. |
BlockingQueue<Operation> |
createReadOperationQueue()
Create a BlockingQueue for the operations currently expecting to read responses from memcached. |
BlockingQueue<Operation> |
createWriteOperationQueue()
Create a BlockingQueue for the operations currently expecting to write requests to memcached. |
Transcoder<Object> |
getDefaultTranscoder()
Get the default transcoder to be used in connections created by this factory. |
FailureMode |
getFailureMode()
Get the default failure mode for the underlying connection. |
HashAlgorithm |
getHashAlg()
Get the hash algorithm to be used. |
Collection<ConnectionObserver> |
getInitialObservers()
Observers that should be established at the time of connection instantiation. |
long |
getMaxReconnectDelay()
Maximum number of milliseconds to wait between reconnect attempts. |
OperationFactory |
getOperationFactory()
Get the operation factory for connections built by this connection factory. |
long |
getOperationTimeout()
Get the operation timeout used by this connection. |
int |
getOpQueueLen()
Get the op queue length set at construct time. |
int |
getReadBufSize()
|
boolean |
isDaemon()
If true, the IO thread should be a daemon thread. |
boolean |
shouldOptimize()
If true, low-level optimization is in effect. |
boolean |
useNagleAlgorithm()
If true, the nagle algorithm will be used on connected sockets. |
Methods inherited from class net.spy.memcached.compat.SpyObject |
---|
getLogger |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final FailureMode DEFAULT_FAILURE_MODE
public static final HashAlgorithm DEFAULT_HASH
public static final int DEFAULT_OP_QUEUE_LEN
public static final int DEFAULT_READ_BUFFER_SIZE
public static final long DEFAULT_OPERATION_TIMEOUT
public static final long DEFAULT_MAX_RECONNECT_DELAY
Constructor Detail |
---|
public DefaultConnectionFactory(int qLen, int bufSize, HashAlgorithm hash)
qLen
- the queue length.bufSize
- the buffer sizehash
- the algorithm to use for hashingpublic DefaultConnectionFactory(int qLen, int bufSize)
public DefaultConnectionFactory()
Method Detail |
---|
public MemcachedNode createMemcachedNode(SocketAddress sa, SocketChannel c, int bufSize)
ConnectionFactory
createMemcachedNode
in interface ConnectionFactory
public MemcachedConnection createConnection(List<InetSocketAddress> addrs) throws IOException
ConnectionFactory
createConnection
in interface ConnectionFactory
addrs
- the addresses of the memcached servers
IOException
- for problems initializing the memcached connectionspublic FailureMode getFailureMode()
ConnectionFactory
getFailureMode
in interface ConnectionFactory
public BlockingQueue<Operation> createOperationQueue()
ConnectionFactory
createOperationQueue
in interface ConnectionFactory
public BlockingQueue<Operation> createReadOperationQueue()
ConnectionFactory
createReadOperationQueue
in interface ConnectionFactory
public BlockingQueue<Operation> createWriteOperationQueue()
ConnectionFactory
createWriteOperationQueue
in interface ConnectionFactory
public NodeLocator createLocator(List<MemcachedNode> nodes)
ConnectionFactory
createLocator
in interface ConnectionFactory
public int getOpQueueLen()
public int getReadBufSize()
getReadBufSize
in interface ConnectionFactory
public HashAlgorithm getHashAlg()
ConnectionFactory
getHashAlg
in interface ConnectionFactory
public OperationFactory getOperationFactory()
ConnectionFactory
getOperationFactory
in interface ConnectionFactory
public long getOperationTimeout()
ConnectionFactory
getOperationTimeout
in interface ConnectionFactory
public boolean isDaemon()
ConnectionFactory
isDaemon
in interface ConnectionFactory
public Collection<ConnectionObserver> getInitialObservers()
ConnectionFactory
getInitialObservers
in interface ConnectionFactory
public Transcoder<Object> getDefaultTranscoder()
ConnectionFactory
getDefaultTranscoder
in interface ConnectionFactory
public boolean useNagleAlgorithm()
ConnectionFactory
See Socket.setTcpNoDelay(boolean)
for more information.
useNagleAlgorithm
in interface ConnectionFactory
public boolean shouldOptimize()
ConnectionFactory
shouldOptimize
in interface ConnectionFactory
public long getMaxReconnectDelay()
ConnectionFactory
getMaxReconnectDelay
in interface ConnectionFactory
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |