org.infinispan.client.hotrod.impl.protocol

Class Codec10

java.lang.Object

org.infinispan.client.hotrod.impl.protocol.Codec10

All Implemented Interfaces:

Codec

Direct Known Subclasses:

Codec11

public class Codec10
extends Object
implements Codec

A Hot Rod encoder/decoder for version 1.0 of the protocol.

Since:

5.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
Codec10()

Method Summary

Methods

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
short	readHeader(Transport transport, HeaderParams params) Reads a response header from the transport and returns the status of the response.
protected void	readNewTopologyAndHash(Transport transport, AtomicInteger topologyId)
protected void	readNewTopologyIfPresent(Transport transport, HeaderParams params)
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Codec10

public Codec10()

Method Detail

writeHeader

public HeaderParams writeHeader(Transport transport,
                       HeaderParams params)

Description copied from interface: Codec

Writes a request header with the given parameters to the transport and returns an updated header parameters.

Specified by:

writeHeader in interface Codec

writeHeader

protected HeaderParams writeHeader(Transport transport,
                       HeaderParams params,
                       byte version)

readHeader

public short readHeader(Transport transport,
               HeaderParams params)

Description copied from interface: Codec

Reads a response header from the transport and returns the status of the response.

Specified by:

readHeader in interface Codec

getLog

public Log getLog()

Description copied from interface: Codec

Logger for Hot Rod client codec

Specified by:

getLog in interface Codec

checkForErrorsInResponseStatus

protected void checkForErrorsInResponseStatus(Transport transport,
                                  HeaderParams params,
                                  short status)

readNewTopologyIfPresent

protected void readNewTopologyIfPresent(Transport transport,
                            HeaderParams params)

readNewTopologyAndHash

protected void readNewTopologyAndHash(Transport transport,
                          AtomicInteger topologyId)

computeNewHashes

protected Map<SocketAddress,Set<Integer>> computeNewHashes(Transport transport,
                                               Log localLog,
                                               int newTopologyId,
                                               int numKeyOwners,
                                               short hashFunctionVersion,
                                               int hashSpace,
                                               int clusterSize)