org.infinispan.server.hotrod

Class AbstractTopologyAwareEncoder1x

java.lang.Object

org.infinispan.server.hotrod.AbstractVersionedEncoder

org.infinispan.server.hotrod.AbstractEncoder1x

org.infinispan.server.hotrod.AbstractTopologyAwareEncoder1x

All Implemented Interfaces:

Log, Constants

Direct Known Subclasses:

Encoders.Encoder11$, Encoders.Encoder12$

public abstract class AbstractTopologyAwareEncoder1x
extends AbstractEncoder1x
implements Constants, Log

Hot Rod encoder for protocol version 1.1

Since:

5.2

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
AbstractTopologyAwareEncoder1x()

Method Summary

Methods

Modifier and Type	Method and Description
protected AbstractHashDistAwareResponse	createHashDistAwareResp(int lastViewId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)
scala.collection.Seq<Object>[]	denormalizeSegmentHashIds(ConsistentHash ch)
void	writeHashTopologyUpdate(AbstractHashDistAwareResponse h, HotRodServer server, Response r, org.jboss.netty.buffer.ChannelBuffer buf)
void	writeHashTopologyUpdate11(HashDistAware11Response h, HotRodServer server, Response r, org.jboss.netty.buffer.ChannelBuffer buf)
void	writeLimitedHashTopologyUpdate(AbstractTopologyResponse t, org.jboss.netty.buffer.ChannelBuffer buf)

Methods inherited from class org.infinispan.server.hotrod.AbstractEncoder1x

getTopologyResponse, writeCommonHashTopologyHeader, writeHeader, writeNoTopologyUpdate, writeResponse, writeTopologyUpdate

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

AbstractTopologyAwareEncoder1x

public AbstractTopologyAwareEncoder1x()

Method Detail

createHashDistAwareResp

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

Overrides:

createHashDistAwareResp in class AbstractEncoder1x

writeHashTopologyUpdate

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

Overrides:

writeHashTopologyUpdate in class AbstractEncoder1x

writeHashTopologyUpdate11

public void writeHashTopologyUpdate11(HashDistAware11Response h,
                             HotRodServer server,
                             Response r,
                             org.jboss.netty.buffer.ChannelBuffer buf)

writeLimitedHashTopologyUpdate

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

Overrides:

writeLimitedHashTopologyUpdate in class AbstractEncoder1x

denormalizeSegmentHashIds

public scala.collection.Seq<Object>[] denormalizeSegmentHashIds(ConsistentHash ch)