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.

Author:

dennis

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_MERGE_FACTOR

Constructor Summary

Constructors

Constructor	Description
Optimizer(Protocol protocol)

Method Summary

Modifier and Type	Method	Description
List<Command>	getLocalList()
int	getMergeFactor()
boolean	isOptimizeGet()
boolean	isOptimizeMergeBuffer()
Command	optimiezeGet(Queue writeQueue, Queue<Command> executingCmds, Command optimiezeCommand)	Merge get operation to multi-get operation
Command	optimiezeMergeBuffer(Command optimiezeCommand, Queue writeQueue, Queue<Command> executingCmds, int sendBufferSize)	merge buffers to fit socket's send buffer size
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 Detail

DEFAULT_MERGE_FACTOR

public static final int DEFAULT_MERGE_FACTOR

See Also:

Constant Field Values

Constructor Detail

Optimizer

public Optimizer(Protocol protocol)

Method Detail

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)

getLocalList

public final List<Command> getLocalList()