org.infinispan.client.hotrod.impl.protocol

Class Codec20

java.lang.Object

org.infinispan.client.hotrod.impl.protocol.Codec20

All Implemented Interfaces:

Codec, HotRodConstants

Direct Known Subclasses:

Codec21

public class Codec20
extends Object
implements Codec, HotRodConstants

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

Since:

7.0

Author:

Galder Zamarreño

Field Summary

Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

ADD_CLIENT_LISTENER_REQUEST, ADD_CLIENT_LISTENER_RESPONSE, AUTH_MECH_LIST_REQUEST, AUTH_MECH_LIST_RESPONSE, AUTH_REQUEST, AUTH_RESPONSE, BULK_GET_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, BULK_GET_REQUEST, BULK_GET_RESPONSE, CACHE_ENTRY_CREATED_EVENT_RESPONSE, CACHE_ENTRY_EXPIRED_EVENT_RESPONSE, CACHE_ENTRY_MODIFIED_EVENT_RESPONSE, CACHE_ENTRY_REMOVED_EVENT_RESPONSE, CLEAR_REQUEST, CLEAR_RESPONSE, CLIENT_INTELLIGENCE_BASIC, CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE, CLIENT_INTELLIGENCE_TOPOLOGY_AWARE, COMMAND_TIMEOUT_STATUS, CONTAINS_KEY_REQUEST, CONTAINS_KEY_RESPONSE, DEFAULT_CACHE_NAME_BYTES, DEFAULT_CACHE_TOPOLOGY, ERROR_RESPONSE, EXEC_REQUEST, EXEC_RESPONSE, GET_ALL_REQUEST, GET_ALL_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, ILLEGAL_LIFECYCLE_STATE, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INVALID_ITERATION, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, ITERATION_END_REQUEST, ITERATION_END_RESPONSE, ITERATION_NEXT_REQUEST, ITERATION_NEXT_RESPONSE, ITERATION_START_REQUEST, ITERATION_START_RESPONSE, KEY_DOES_NOT_EXIST_STATUS, NO_ERROR_STATUS, NO_ERROR_STATUS_COMPAT, NODE_SUSPECTED, NOT_EXECUTED_WITH_PREVIOUS, NOT_EXECUTED_WITH_PREVIOUS_COMPAT, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PUT_ALL_REQUEST, PUT_ALL_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, QUERY_REQUEST, QUERY_RESPONSE, REMOVE_CLIENT_LISTENER_REQUEST, REMOVE_CLIENT_LISTENER_RESPONSE, REMOVE_IF_UNMODIFIED_REQUEST, REMOVE_IF_UNMODIFIED_RESPONSE, REMOVE_REQUEST, REMOVE_RESPONSE, REPLACE_IF_UNMODIFIED_REQUEST, REPLACE_IF_UNMODIFIED_RESPONSE, REPLACE_REQUEST, REPLACE_RESPONSE, REQUEST_MAGIC, REQUEST_PARSING_ERROR_STATUS, RESPONSE_MAGIC, SERVER_ERROR_STATUS, SIZE_REQUEST, SIZE_RESPONSE, STATS_REQUEST, STATS_RESPONSE, SUCCESS_WITH_PREVIOUS, SUCCESS_WITH_PREVIOUS_COMPAT, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11, VERSION_12, VERSION_13, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25

Constructor Summary

Constructors

Constructor and Description
Codec20()

Method Summary

Modifier and Type	Method and Description
protected void	checkForErrorsInResponseStatus(Transport transport, HeaderParams params, short status)
protected ClientCacheEntryCreatedEvent<Object>	createCreatedEvent(Object key, long dataVersion, boolean isRetried)
protected ClientCacheEntryCustomEvent<Object>	createCustomEvent(Object eventData, ClientEvent.Type eventType, boolean isRetried)
protected ClientCacheEntryModifiedEvent	createModifiedEvent(Object key, long dataVersion, boolean isRetried)
protected ClientEvent	createRemovedEvent(Object key, boolean isRetried)
Log	getLog() Logger for Hot Rod client codec
ClientEvent	readEvent(Transport transport, byte[] expectedListenerId, Marshaller marshaller, List<String> whitelist)
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, List<String> whitelist)
protected void	readNewTopologyAndHash(Transport transport, HeaderParams params)
protected void	readNewTopologyIfPresent(Transport transport, HeaderParams params)
protected ClientEvent	readPartialEvent(Transport transport, byte[] expectedListenerId, Marshaller marshaller, short eventTypeId, List<String> whitelist)
<T> T	readUnmarshallByteArray(Transport transport, short status, List<String> whitelist) Read and unmarshall byte array.
Object	returnPossiblePrevValue(Transport transport, short status, int flags, List<String> whitelist)
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)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

hasCompatibility, hasPrevious, isInvalidIteration, isNotExecuted, isNotExist, isSuccess

Constructor Detail

Codec20

public Codec20()

Method Detail

readUnmarshallByteArray

public <T> T readUnmarshallByteArray(Transport transport,
                                     short status,
                                     List<String> whitelist)

Description copied from interface: Codec

Read and unmarshall byte array.

Specified by:

readUnmarshallByteArray in interface Codec

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

writeClientListenerParams

public void writeClientListenerParams(Transport transport,
                                      ClientListener clientListener,
                                      byte[][] filterFactoryParams,
                                      byte[][] converterFactoryParams)

Description copied from interface: Codec

Writes client listener parameters

Specified by:

writeClientListenerParams in interface Codec

writeExpirationParams

public void writeExpirationParams(Transport transport,
                                  long lifespan,
                                  TimeUnit lifespanTimeUnit,
                                  long maxIdle,
                                  TimeUnit maxIdleTimeUnit)

Description copied from interface: Codec

Write lifespan/maxidle parameters.

Specified by:

writeExpirationParams 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

readEvent

public ClientEvent readEvent(Transport transport,
                             byte[] expectedListenerId,
                             Marshaller marshaller,
                             List<String> whitelist)

Specified by:

readEvent in interface Codec

readPartialEvent

protected ClientEvent readPartialEvent(Transport transport,
                                       byte[] expectedListenerId,
                                       Marshaller marshaller,
                                       short eventTypeId,
                                       List<String> whitelist)

readHeaderOrEvent

public Either<Short,ClientEvent> readHeaderOrEvent(Transport transport,
                                                   HeaderParams params,
                                                   byte[] expectedListenerId,
                                                   Marshaller marshaller,
                                                   List<String> whitelist)

Specified by:

readHeaderOrEvent in interface Codec

returnPossiblePrevValue

public Object returnPossiblePrevValue(Transport transport,
                                      short status,
                                      int flags,
                                      List<String> whitelist)

Specified by:

returnPossiblePrevValue in interface Codec

createRemovedEvent

protected ClientEvent createRemovedEvent(Object key,
                                         boolean isRetried)

createModifiedEvent

protected ClientCacheEntryModifiedEvent createModifiedEvent(Object key,
                                                            long dataVersion,
                                                            boolean isRetried)

createCreatedEvent

protected ClientCacheEntryCreatedEvent<Object> createCreatedEvent(Object key,
                                                                  long dataVersion,
                                                                  boolean isRetried)

createCustomEvent

protected ClientCacheEntryCustomEvent<Object> createCustomEvent(Object eventData,
                                                                ClientEvent.Type eventType,
                                                                boolean isRetried)

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,
                                      HeaderParams params)