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(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) |
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, org.jboss.netty.buffer.ChannelBuffer buf, Cache<Address,ServerAddress> addressCache, HotRodServer server)
AbstractVersionedEncoder
writeHeader
in class AbstractVersionedEncoder
public void writeResponse(Response r, org.jboss.netty.buffer.ChannelBuffer 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, org.jboss.netty.buffer.ChannelBuffer buffer)
public void writeLimitedHashTopologyUpdate(AbstractTopologyResponse t, org.jboss.netty.buffer.ChannelBuffer buffer)
public void writeTopologyUpdate(TopologyAwareResponse t, org.jboss.netty.buffer.ChannelBuffer buffer)
public void writeNoTopologyUpdate(org.jboss.netty.buffer.ChannelBuffer buffer)
protected void writeCommonHashTopologyHeader(org.jboss.netty.buffer.ChannelBuffer buffer, int viewId, int numOwners, byte hashFct, int hashSpace, int numServers)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.