org.infinispan.server.hotrod

Class HotRodDecoder

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<byte[],byte[]>

org.infinispan.server.hotrod.HotRodDecoder

All Implemented Interfaces:

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

public class HotRodDecoder
extends AbstractProtocolDecoder<byte[],byte[]>
implements Constants

Top level Hot Rod decoder that after figuring out the version, delegates the rest of the reading to the corresponding versioned 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
HotRodDecoder(EmbeddedCacheManager cacheManager, NettyTransport transport, HotRodServer server)

Method Summary

Methods

Modifier and Type	Method and Description
Object	createErrorResponse(Throwable t)
Object	createGetResponse(byte[] k, CacheEntry entry)
protected HotRodHeader	createHeader()
Object	createMultiGetResponse(scala.collection.immutable.Map<byte[],CacheEntry> pairs)
Object	createNotExecutedResponse(byte[] prev)
Object	createNotExistResponse()
protected scala.Tuple2<HotRodException,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)
Cache<byte[],byte[]>	getCache()
protected AdvancedCache<byte[],byte[]>	getOptimizedCache(AdvancedCache<byte[],byte[]> c)
scala.Option<Object>	readHeader(org.jboss.netty.buffer.ChannelBuffer buffer, HotRodHeader header)
scala.Tuple2<byte[],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

buildMetadata, cache, channelOpen, checkpointTo, decode, decodeLast, defaultLifespanTime, defaultMaxIdleTime, exceptionCaught, generateVersion, get, handleModification, header, key, messageReceived, params, rawValue, readHeader, 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.hotrod.Constants

DEFAULT_HASH_FUNCTION_VERSION, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INTELLIGENCE_BASIC, INTELLIGENCE_HASH_DISTRIBUTION_AWARE, INTELLIGENCE_TOPOLOGY_AWARE, MAGIC_REQ, MAGIC_RES, VERSION_10, VERSION_11, VERSION_12, VERSION_13

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

HotRodDecoder

public HotRodDecoder(EmbeddedCacheManager cacheManager,
             NettyTransport transport,
             HotRodServer server)

Method Detail

createHeader

protected HotRodHeader createHeader()

Specified by:

createHeader in class AbstractProtocolDecoder<byte[],byte[]>

readHeader

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

getCache

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

Specified by:

getCache in class AbstractProtocolDecoder<byte[],byte[]>

readKey

public scala.Tuple2<byte[],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<byte[],byte[]>

readParameters

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

Specified by:

readParameters in class AbstractProtocolDecoder<byte[],byte[]>

readValue

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

Specified by:

readValue in class AbstractProtocolDecoder<byte[],byte[]>

createValue

public byte[] createValue()

Specified by:

createValue in class AbstractProtocolDecoder<byte[],byte[]>

createSuccessResponse

public Object createSuccessResponse(byte[] prev)

Specified by:

createSuccessResponse in class AbstractProtocolDecoder<byte[],byte[]>

createNotExecutedResponse

public Object createNotExecutedResponse(byte[] prev)

Specified by:

createNotExecutedResponse in class AbstractProtocolDecoder<byte[],byte[]>

createNotExistResponse

public Object createNotExistResponse()

Specified by:

createNotExistResponse in class AbstractProtocolDecoder<byte[],byte[]>

createGetResponse

public Object createGetResponse(byte[] k,
                       CacheEntry entry)

Specified by:

createGetResponse in class AbstractProtocolDecoder<byte[],byte[]>

createMultiGetResponse

public Object createMultiGetResponse(scala.collection.immutable.Map<byte[],CacheEntry> pairs)

Specified by:

createMultiGetResponse in class AbstractProtocolDecoder<byte[],byte[]>

customDecodeHeader

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

Specified by:

customDecodeHeader in class AbstractProtocolDecoder<byte[],byte[]>

customDecodeKey

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

Specified by:

customDecodeKey in class AbstractProtocolDecoder<byte[],byte[]>

customDecodeValue

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

Specified by:

customDecodeValue in class AbstractProtocolDecoder<byte[],byte[]>

createStatsResponse

public Object createStatsResponse()

Specified by:

createStatsResponse in class AbstractProtocolDecoder<byte[],byte[]>

createErrorResponse

public Object createErrorResponse(Throwable t)

Specified by:

createErrorResponse in class AbstractProtocolDecoder<byte[],byte[]>

getOptimizedCache

protected AdvancedCache<byte[],byte[]> getOptimizedCache(AdvancedCache<byte[],byte[]> c)

Overrides:

getOptimizedCache in class AbstractProtocolDecoder<byte[],byte[]>

createServerException

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