public abstract class AbstractEncoder1x extends AbstractVersionedEncoder implements Constants, Log
Constructor and Description |
---|
AbstractEncoder1x() |
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(io.netty.buffer.ByteBuf buffer,
int viewId,
int numOwners,
byte hashFct,
int hashSpace,
int numServers) |
void |
writeHashTopologyUpdate(AbstractHashDistAwareResponse h,
HotRodServer server,
Response r,
io.netty.buffer.ByteBuf buffer) |
void |
writeHeader(Response r,
io.netty.buffer.ByteBuf buf,
Cache<Address,ServerAddress> addressCache,
HotRodServer server)
Write the header to the given channel buffer
|
void |
writeLimitedHashTopologyUpdate(AbstractTopologyResponse t,
io.netty.buffer.ByteBuf buffer) |
void |
writeNoTopologyUpdate(io.netty.buffer.ByteBuf buffer) |
void |
writeResponse(Response r,
io.netty.buffer.ByteBuf buf,
EmbeddedCacheManager cacheManager,
HotRodServer server)
Write operation response using the given channel buffer
|
void |
writeTopologyUpdate(TopologyAwareResponse t,
io.netty.buffer.ByteBuf buffer) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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
log, logErrorDetectingCrashedMember, logUnableToUpdateView, logViewNullWhileDetectingCrashedMember
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
public void writeHeader(Response r, io.netty.buffer.ByteBuf buf, Cache<Address,ServerAddress> addressCache, HotRodServer server)
AbstractVersionedEncoder
writeHeader
in class AbstractVersionedEncoder
public void writeResponse(Response r, io.netty.buffer.ByteBuf buf, EmbeddedCacheManager cacheManager, HotRodServer server)
AbstractVersionedEncoder
writeResponse
in class AbstractVersionedEncoder
public AbstractTopologyResponse getTopologyResponse(Response r, Cache<Address,ServerAddress> addressCache, HotRodServer server)
protected AbstractHashDistAwareResponse createHashDistAwareResp(int topologyId, scala.collection.immutable.Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)
public void writeHashTopologyUpdate(AbstractHashDistAwareResponse h, HotRodServer server, Response r, io.netty.buffer.ByteBuf buffer)
public void writeLimitedHashTopologyUpdate(AbstractTopologyResponse t, io.netty.buffer.ByteBuf buffer)
public void writeTopologyUpdate(TopologyAwareResponse t, io.netty.buffer.ByteBuf buffer)
public void writeNoTopologyUpdate(io.netty.buffer.ByteBuf buffer)
protected void writeCommonHashTopologyHeader(io.netty.buffer.ByteBuf buffer, int viewId, int numOwners, byte hashFct, int hashSpace, int numServers)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.