org.infinispan.server.memcached

Class MemcachedDecoder

java.lang.Object

org.jboss.netty.channel.SimpleChannelUpstreamHandler

org.jboss.netty.handler.codec.frame.FrameDecoder

org.jboss.netty.handler.codec.replay.ReplayingDecoder<DecoderState>

org.infinispan.server.core.AbstractProtocolDecoder<String,byte[]>

org.infinispan.server.memcached.MemcachedDecoder

All Implemented Interfaces:

Log, ServerConstants, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler, org.jboss.netty.channel.LifeCycleAwareChannelHandler

public class MemcachedDecoder
extends AbstractProtocolDecoder<String,byte[]>

A Memcached protocol specific decoder

Since:

4.1

Author:

Galder Zamarreño

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class org.jboss.netty.handler.codec.frame.FrameDecoder

cumulation, DEFAULT_MAX_COMPOSITEBUFFER_COMPONENTS

Constructor Summary

Constructors

Constructor and Description
MemcachedDecoder(AdvancedCache<String,byte[]> memcachedCache, ScheduledExecutorService scheduler, NettyTransport transport)

Method Summary

Methods

Modifier and Type	Method and Description
protected Metadata	buildMetadata()
Object	createErrorResponse(Throwable t)
Object	createGetResponse(String k, CacheEntry entry)
RequestHeader	createHeader()
Object	createMultiGetResponse(scala.collection.immutable.Map<String,CacheEntry> pairs)
Object	createNotExecutedResponse(byte[] prev)
Object	createNotExistResponse()
protected scala.Tuple2<MemcachedException,Object>	createServerException(Exception e, org.jboss.netty.buffer.ChannelBuffer b)
Object	createStatsResponse()
Object	createSuccessResponse(byte[] prev)
byte[]	createValue()
protected Object	customDecodeHeader(org.jboss.netty.channel.Channel ch, org.jboss.netty.buffer.ChannelBuffer buffer)
protected Object	customDecodeKey(org.jboss.netty.channel.Channel ch, org.jboss.netty.buffer.ChannelBuffer buffer)
protected Object	customDecodeValue(org.jboss.netty.channel.Channel ch, org.jboss.netty.buffer.ChannelBuffer buffer)
protected Object	get(org.jboss.netty.buffer.ChannelBuffer buffer)
Cache<String,byte[]>	getCache()
scala.Option<Object>	readHeader(org.jboss.netty.buffer.ChannelBuffer buffer, RequestHeader header)
scala.Tuple2<String,Object>	readKey(org.jboss.netty.buffer.ChannelBuffer b) Returns the key read along with a boolean indicating whether the end of the operation was found or not.
boolean	readParameters(org.jboss.netty.channel.Channel ch, org.jboss.netty.buffer.ChannelBuffer b)
protected void	readValue(org.jboss.netty.buffer.ChannelBuffer b)

Methods inherited from class org.infinispan.server.core.AbstractProtocolDecoder

cache, channelOpen, checkpointTo, decode, decodeLast, defaultLifespanTime, defaultMaxIdleTime, exceptionCaught, generateVersion, getOptimizedCache, handleModification, header, key, messageReceived, params, rawValue, toMillis, writeComplete, writeResponse

Methods inherited from class org.jboss.netty.handler.codec.replay.ReplayingDecoder

checkpoint, checkpoint, cleanup, decode, decodeLast, getState, internalBuffer, setState

Methods inherited from class org.jboss.netty.handler.codec.frame.FrameDecoder

actualReadableBytes, afterAdd, afterRemove, appendToCumulation, beforeAdd, beforeRemove, channelClosed, channelDisconnected, extractFrame, getMaxCumulationBufferCapacity, getMaxCumulationBufferComponents, isUnfold, newCumulationBuffer, replace, setMaxCumulationBufferCapacity, setMaxCumulationBufferComponents, setUnfold, unfoldAndFireMessageReceived, updateCumulation

Methods inherited from class org.jboss.netty.channel.SimpleChannelUpstreamHandler

channelBound, channelConnected, channelInterestChanged, channelUnbound, childChannelClosed, childChannelOpen, handleUpstream

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.server.core.ServerConstants

EXPIRATION_DEFAULT, EXPIRATION_NONE

Methods inherited from interface org.infinispan.server.core.logging.Log

debug, debug, debug, debug, debug, debugf, error, info, info, isDebugEnabled, isTraceEnabled, log, logChannelStillBound, logChannelStillConnected, logErrorBeforeReadingRequest, logExceptionReported, logPostingShutdownRequest, logServerDidNotClose, logServerDidNotUnbind, logSettingMasterThreadsNotSupported, logStartWithArgs, trace, trace, trace, trace, tracef, warn

Constructor Detail

MemcachedDecoder

public MemcachedDecoder(AdvancedCache<String,byte[]> memcachedCache,
                ScheduledExecutorService scheduler,
                NettyTransport transport)

Method Detail

createHeader

public RequestHeader createHeader()

Specified by:

createHeader in class AbstractProtocolDecoder<String,byte[]>

readHeader

public scala.Option<Object> readHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
                              RequestHeader header)

Specified by:

readHeader in class AbstractProtocolDecoder<String,byte[]>

readKey

public scala.Tuple2<String,Object> readKey(org.jboss.netty.buffer.ChannelBuffer b)

Description copied from class: AbstractProtocolDecoder

Returns the key read along with a boolean indicating whether the end of the operation was found or not. This allows client to differentiate between extra parameters or pipelined sequence of operations.

Specified by:

readKey in class AbstractProtocolDecoder<String,byte[]>

get

protected Object get(org.jboss.netty.buffer.ChannelBuffer buffer)

Overrides:

get in class AbstractProtocolDecoder<String,byte[]>

readParameters

public boolean readParameters(org.jboss.netty.channel.Channel ch,
                     org.jboss.netty.buffer.ChannelBuffer b)

Specified by:

readParameters in class AbstractProtocolDecoder<String,byte[]>

readValue

protected void readValue(org.jboss.netty.buffer.ChannelBuffer b)

Specified by:

readValue in class AbstractProtocolDecoder<String,byte[]>

createValue

public byte[] createValue()

Specified by:

createValue in class AbstractProtocolDecoder<String,byte[]>

getCache

public Cache<String,byte[]> getCache()

Specified by:

getCache in class AbstractProtocolDecoder<String,byte[]>

customDecodeHeader

protected Object customDecodeHeader(org.jboss.netty.channel.Channel ch,
                        org.jboss.netty.buffer.ChannelBuffer buffer)

Specified by:

customDecodeHeader in class AbstractProtocolDecoder<String,byte[]>

customDecodeKey

protected Object customDecodeKey(org.jboss.netty.channel.Channel ch,
                     org.jboss.netty.buffer.ChannelBuffer buffer)

Specified by:

customDecodeKey in class AbstractProtocolDecoder<String,byte[]>

customDecodeValue

protected Object customDecodeValue(org.jboss.netty.channel.Channel ch,
                       org.jboss.netty.buffer.ChannelBuffer buffer)

Specified by:

customDecodeValue in class AbstractProtocolDecoder<String,byte[]>

createSuccessResponse

public Object createSuccessResponse(byte[] prev)

Specified by:

createSuccessResponse in class AbstractProtocolDecoder<String,byte[]>

createNotExecutedResponse

public Object createNotExecutedResponse(byte[] prev)

Specified by:

createNotExecutedResponse in class AbstractProtocolDecoder<String,byte[]>

createNotExistResponse

public Object createNotExistResponse()

Specified by:

createNotExistResponse in class AbstractProtocolDecoder<String,byte[]>

createGetResponse

public Object createGetResponse(String k,
                       CacheEntry entry)

Specified by:

createGetResponse in class AbstractProtocolDecoder<String,byte[]>

createMultiGetResponse

public Object createMultiGetResponse(scala.collection.immutable.Map<String,CacheEntry> pairs)

Specified by:

createMultiGetResponse in class AbstractProtocolDecoder<String,byte[]>

createErrorResponse

public Object createErrorResponse(Throwable t)

Specified by:

createErrorResponse in class AbstractProtocolDecoder<String,byte[]>

buildMetadata

protected Metadata buildMetadata()

Overrides:

buildMetadata in class AbstractProtocolDecoder<String,byte[]>

createServerException

protected scala.Tuple2<MemcachedException,Object> createServerException(Exception e,
                                                            org.jboss.netty.buffer.ChannelBuffer b)

createStatsResponse

public Object createStatsResponse()

Specified by:

createStatsResponse in class AbstractProtocolDecoder<String,byte[]>