Package net.rubyeye.xmemcached.impl

Class Optimizer

java.lang.Object

net.rubyeye.xmemcached.impl.Optimizer

All Implemented Interfaces:

OptimizerMBean, MemcachedOptimizer

public class Optimizer
extends Object
implements OptimizerMBean, MemcachedOptimizer

Memcached command optimizer,merge single-get comands to multi-get command, merge ByteBuffers to fit the socket's sendBufferSize etc.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	Optimizer.BinaryGetQCollector
private static class	Optimizer.BinarySetQCollector
(package private) static interface	Optimizer.CommandCollector
(package private) static class	Optimizer.KeyStringCollector

Field Summary

Fields

Modifier and Type	Field	Description
private static ThreadLocal<Optimizer.BinaryGetQCollector>	BIN_GET_CMD_COLLECTOR_THREAD_LOCAL
private static final ThreadLocal<Optimizer.BinarySetQCollector>	BIN_SET_CMD_COLLECTOR_THREAD_LOCAL
static final int	DEFAULT_MERGE_FACTOR
private static final org.slf4j.Logger	log
private static final int	MARGIN
private int	mergeFactor
private boolean	optimiezeGet
private boolean	optimiezeMergeBuffer
private final boolean	optimiezeSet
private Protocol	protocol
private static ThreadLocal<Optimizer.KeyStringCollector>	TEXT_GET_CMD_COLLECTOR_THREAD_LOCAL
private final ThreadLocal<List<Command>>	threadLocal

Constructor Summary

Constructors

Constructor	Description
Optimizer(Protocol protocol)

Method Summary

Modifier and Type	Method	Description
private Optimizer.CommandCollector	createGetCommandCollector()
final List<Command>	getLocalList()
int	getMergeFactor()
boolean	isOptimizeGet()
boolean	isOptimizeMergeBuffer()
private final Command	mergeBuffer(Command firstCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)
private final Command	mergeGetCommands(Command currentCmd, Queue writeQueue, Queue<Command> executingCmds, CommandType expectedCommandType)
private final Command	mergeSetCommands(Command currentCmd, Queue writeQueue, Queue<Command> executingCmds, CommandType expectedCommandType, int sendBufferSize)
private Command	newMergedCommand(Map<Object,Command> mergeCommands, int mergeCount, Optimizer.CommandCollector commandCollector, CommandType commandType)
final Command	optimiezeGet(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand)	Merge get operation to multi-get operation
final Command	optimiezeMergeBuffer(Command optimiezeCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)	merge buffers to fit socket's send buffer size
final Command	optimiezeSet(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand, int sendBufferSize)
Command	optimize(Command currentCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)
void	setBufferAllocator(BufferAllocator bufferAllocator)
void	setMergeFactor(int mergeFactor)
void	setOptimizeGet(boolean optimiezeGet)
void	setOptimizeMergeBuffer(boolean optimiezeMergeBuffer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MARGIN

private static final int MARGIN

See Also:

• Constant Field Values

DEFAULT_MERGE_FACTOR

public static final int DEFAULT_MERGE_FACTOR

See Also:

• Constant Field Values

mergeFactor

private int mergeFactor

optimiezeGet

private boolean optimiezeGet

optimiezeSet

private final boolean optimiezeSet

See Also:

• Constant Field Values

optimiezeMergeBuffer

private boolean optimiezeMergeBuffer

log

private static final org.slf4j.Logger log

protocol

private Protocol protocol

threadLocal

private final ThreadLocal<List<Command>> threadLocal

BIN_SET_CMD_COLLECTOR_THREAD_LOCAL

private static final ThreadLocal<Optimizer.BinarySetQCollector> BIN_SET_CMD_COLLECTOR_THREAD_LOCAL

TEXT_GET_CMD_COLLECTOR_THREAD_LOCAL

private static ThreadLocal<Optimizer.KeyStringCollector> TEXT_GET_CMD_COLLECTOR_THREAD_LOCAL

BIN_GET_CMD_COLLECTOR_THREAD_LOCAL

private static ThreadLocal<Optimizer.BinaryGetQCollector> BIN_GET_CMD_COLLECTOR_THREAD_LOCAL

Constructor Details

Optimizer

public Optimizer(Protocol protocol)

Method Details

setBufferAllocator

public void setBufferAllocator(BufferAllocator bufferAllocator)

Specified by:

setBufferAllocator in interface MemcachedOptimizer

getMergeFactor

public int getMergeFactor()

Specified by:

getMergeFactor in interface OptimizerMBean

setMergeFactor

public void setMergeFactor(int mergeFactor)

Specified by:

setMergeFactor in interface OptimizerMBean

isOptimizeGet

public boolean isOptimizeGet()

Specified by:

isOptimizeGet in interface OptimizerMBean

setOptimizeGet

public void setOptimizeGet(boolean optimiezeGet)

Specified by:

setOptimizeGet in interface OptimizerMBean

isOptimizeMergeBuffer

public boolean isOptimizeMergeBuffer()

Specified by:

isOptimizeMergeBuffer in interface OptimizerMBean

setOptimizeMergeBuffer

public void setOptimizeMergeBuffer(boolean optimiezeMergeBuffer)

Specified by:

setOptimizeMergeBuffer in interface OptimizerMBean

optimize

public Command optimize(Command currentCommand,
 Queue writeQueue,
 Queue<Command> executingCmds,
 int sendBufferSize)

Specified by:

optimize in interface MemcachedOptimizer

optimiezeMergeBuffer

public final Command optimiezeMergeBuffer(Command optimiezeCommand,
 Queue writeQueue,
 Queue<Command> executingCmds,
 int sendBufferSize)

merge buffers to fit socket's send buffer size

Parameters:

currentCommand -

Returns:

Throws:

InterruptedException

optimiezeGet

public final Command optimiezeGet(Queue writeQueue,
 Queue<Command> executingCmds,
 Command optimiezeCommand)

Merge get operation to multi-get operation

Parameters:

currentCmd -

mergeCommands -

Returns:

Throws:

InterruptedException

optimiezeSet

public final Command optimiezeSet(Queue writeQueue,
 Queue<Command> executingCmds,
 Command optimiezeCommand,
 int sendBufferSize)

mergeBuffer

private final Command mergeBuffer(Command firstCommand,
 Queue writeQueue,
 Queue<Command> executingCmds,
 int sendBufferSize)

getLocalList

public final List<Command> getLocalList()

mergeGetCommands

private final Command mergeGetCommands(Command currentCmd,
 Queue writeQueue,
 Queue<Command> executingCmds,
 CommandType expectedCommandType)

mergeSetCommands

private final Command mergeSetCommands(Command currentCmd,
 Queue writeQueue,
 Queue<Command> executingCmds,
 CommandType expectedCommandType,
 int sendBufferSize)

createGetCommandCollector

private Optimizer.CommandCollector createGetCommandCollector()

newMergedCommand

private Command newMergedCommand(Map<Object,Command> mergeCommands,
 int mergeCount,
 Optimizer.CommandCollector commandCollector,
 CommandType commandType)