Modifier and Type | Field and Description |
---|---|
protected boolean |
trace |
Constructor and Description |
---|
Codec10() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkForErrorsInResponseStatus(Transport transport,
HeaderParams params,
short status) |
protected Map<SocketAddress,Set<Integer>> |
computeNewHashes(Transport transport,
Log localLog,
int newTopologyId,
int numKeyOwners,
short hashFunctionVersion,
int hashSpace,
int clusterSize) |
Log |
getLog()
Logger for Hot Rod client codec
|
ClientEvent |
readEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller) |
short |
readHeader(Transport transport,
HeaderParams params)
Reads a response header from the transport and returns the status
of the response.
|
Either<Short,ClientEvent> |
readHeaderOrEvent(Transport transport,
HeaderParams params,
byte[] expectedListenerId,
Marshaller marshaller) |
protected void |
readNewTopologyAndHash(Transport transport,
AtomicInteger topologyId,
byte[] cacheName) |
protected void |
readNewTopologyIfPresent(Transport transport,
HeaderParams params) |
<T> T |
readUnmarshallByteArray(Transport transport,
short status)
Read and unmarshall byte array.
|
Object |
returnPossiblePrevValue(Transport transport,
short status,
int flags) |
void |
writeClientListenerParams(Transport transport,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams)
Writes client listener parameters
|
void |
writeExpirationParams(Transport transport,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit)
Write lifespan/maxidle parameters.
|
HeaderParams |
writeHeader(Transport transport,
HeaderParams params)
Writes a request header with the given parameters to the transport and
returns an updated header parameters.
|
protected HeaderParams |
writeHeader(Transport transport,
HeaderParams params,
byte version) |
public HeaderParams writeHeader(Transport transport, HeaderParams params)
Codec
writeHeader
in interface Codec
public void writeClientListenerParams(Transport transport, ClientListener clientListener, byte[][] filterFactoryParams, byte[][] converterFactoryParams)
Codec
writeClientListenerParams
in interface Codec
public void writeExpirationParams(Transport transport, long lifespan, TimeUnit lifespanTimeUnit, long maxIdle, TimeUnit maxIdleTimeUnit)
Codec
writeExpirationParams
in interface Codec
protected HeaderParams writeHeader(Transport transport, HeaderParams params, byte version)
public short readHeader(Transport transport, HeaderParams params)
Codec
readHeader
in interface Codec
public ClientEvent readEvent(Transport transport, byte[] expectedListenerId, Marshaller marshaller)
public Either<Short,ClientEvent> readHeaderOrEvent(Transport transport, HeaderParams params, byte[] expectedListenerId, Marshaller marshaller)
readHeaderOrEvent
in interface Codec
public Object returnPossiblePrevValue(Transport transport, short status, int flags)
returnPossiblePrevValue
in interface Codec
public <T> T readUnmarshallByteArray(Transport transport, short status)
Codec
readUnmarshallByteArray
in interface Codec
protected void checkForErrorsInResponseStatus(Transport transport, HeaderParams params, short status)
protected void readNewTopologyIfPresent(Transport transport, HeaderParams params)
protected void readNewTopologyAndHash(Transport transport, AtomicInteger topologyId, byte[] cacheName)
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.