org.infinispan.server.hotrod

Class AbstractEncoder1x

java.lang.Object

org.infinispan.server.hotrod.AbstractVersionedEncoder

org.infinispan.server.hotrod.AbstractEncoder1x

All Implemented Interfaces:

Log, Constants

Direct Known Subclasses:

AbstractTopologyAwareEncoder1x, Encoders.Encoder10$

public abstract class AbstractEncoder1x
extends AbstractVersionedEncoder
implements Constants, Log

Hot Rod encoder for protocol version 1.1

Since:

5.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
AbstractEncoder1x()

Method Summary

Methods

Modifier and Type	Method and Description
protected AbstractHashDistAwareResponse	createHashDistAwareResp(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)
AbstractTopologyResponse	getTopologyResponse(Response r, Cache<Address,ServerAddress> addressCache, HotRodServer server)
protected void	writeCommonHashTopologyHeader(org.jboss.netty.buffer.ChannelBuffer buffer, int viewId, int numOwners, byte hashFct, int hashSpace, int numServers)
void	writeHashTopologyUpdate(AbstractHashDistAwareResponse h, HotRodServer server, Response r, org.jboss.netty.buffer.ChannelBuffer buffer)
void	writeHeader(Response r, org.jboss.netty.buffer.ChannelBuffer buf, Cache<Address,ServerAddress> addressCache, HotRodServer server) Write the header to the given channel buffer
void	writeLimitedHashTopologyUpdate(AbstractTopologyResponse t, org.jboss.netty.buffer.ChannelBuffer buffer)
void	writeNoTopologyUpdate(org.jboss.netty.buffer.ChannelBuffer buffer)
void	writeResponse(Response r, org.jboss.netty.buffer.ChannelBuffer buf, EmbeddedCacheManager cacheManager, HotRodServer server) Write operation response using the given channel buffer
void	writeTopologyUpdate(TopologyAwareResponse t, org.jboss.netty.buffer.ChannelBuffer buffer)

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.hotrod.logging.Log

log, logErrorDetectingCrashedMember, logUnableToUpdateView, logViewNullWhileDetectingCrashedMember

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

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

Constructor Detail

AbstractEncoder1x

public AbstractEncoder1x()

Method Detail

writeHeader

public void writeHeader(Response r,
               org.jboss.netty.buffer.ChannelBuffer buf,
               Cache<Address,ServerAddress> addressCache,
               HotRodServer server)

Description copied from class: AbstractVersionedEncoder

Write the header to the given channel buffer

Specified by:

writeHeader in class AbstractVersionedEncoder

writeResponse

public void writeResponse(Response r,
                 org.jboss.netty.buffer.ChannelBuffer buf,
                 EmbeddedCacheManager cacheManager,
                 HotRodServer server)

Description copied from class: AbstractVersionedEncoder

Write operation response using the given channel buffer

Specified by:

writeResponse in class AbstractVersionedEncoder

getTopologyResponse

public AbstractTopologyResponse getTopologyResponse(Response r,
                                           Cache<Address,ServerAddress> addressCache,
                                           HotRodServer server)

createHashDistAwareResp

protected AbstractHashDistAwareResponse createHashDistAwareResp(int topologyId,
                                                    scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap,
                                                    Configuration cfg)

writeHashTopologyUpdate

public void writeHashTopologyUpdate(AbstractHashDistAwareResponse h,
                           HotRodServer server,
                           Response r,
                           org.jboss.netty.buffer.ChannelBuffer buffer)

writeLimitedHashTopologyUpdate

public void writeLimitedHashTopologyUpdate(AbstractTopologyResponse t,
                                  org.jboss.netty.buffer.ChannelBuffer buffer)

writeTopologyUpdate

public void writeTopologyUpdate(TopologyAwareResponse t,
                       org.jboss.netty.buffer.ChannelBuffer buffer)

writeNoTopologyUpdate

public void writeNoTopologyUpdate(org.jboss.netty.buffer.ChannelBuffer buffer)

writeCommonHashTopologyHeader

protected void writeCommonHashTopologyHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
                                 int viewId,
                                 int numOwners,
                                 byte hashFct,
                                 int hashSpace,
                                 int numServers)