in modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/ClientMessageParser.java [459:737]
public ClientListenerRequest decode(BinaryReaderEx reader) {
short opCode = reader.readShort();
switch (opCode) {
case OP_CACHE_GET:
return new ClientCacheGetRequest(reader);
case OP_BINARY_TYPE_NAME_GET:
return new ClientBinaryTypeNameGetRequest(reader);
case OP_BINARY_TYPE_GET:
return new ClientBinaryTypeGetRequest(reader);
case OP_CACHE_PUT:
return new ClientCachePutRequest(reader);
case OP_BINARY_TYPE_NAME_PUT:
return new ClientBinaryTypeNamePutRequest(reader);
case OP_BINARY_TYPE_PUT:
return new ClientBinaryTypePutRequest(reader);
case OP_BINARY_CONFIGURATION_GET:
return new ClientBinaryConfigurationGetRequest(reader);
case OP_QUERY_SCAN:
return new ClientCacheScanQueryRequest(reader);
case OP_QUERY_SCAN_CURSOR_GET_PAGE:
case OP_QUERY_SQL_CURSOR_GET_PAGE:
case OP_QUERY_INDEX_CURSOR_GET_PAGE:
return new ClientCacheQueryNextPageRequest(reader);
case OP_RESOURCE_CLOSE:
return new ClientResourceCloseRequest(reader);
case OP_HEARTBEAT:
return new ClientRequest(reader);
case OP_GET_IDLE_TIMEOUT:
return new ClientGetIdleTimeoutRequest(reader);
case OP_CACHE_CONTAINS_KEY:
return new ClientCacheContainsKeyRequest(reader);
case OP_CACHE_CONTAINS_KEYS:
return new ClientCacheContainsKeysRequest(reader);
case OP_CACHE_GET_ALL:
return new ClientCacheGetAllRequest(reader);
case OP_CACHE_GET_AND_PUT:
return new ClientCacheGetAndPutRequest(reader);
case OP_CACHE_GET_AND_REPLACE:
return new ClientCacheGetAndReplaceRequest(reader);
case OP_CACHE_GET_AND_REMOVE:
return new ClientCacheGetAndRemoveRequest(reader);
case OP_CACHE_PUT_IF_ABSENT:
return new ClientCachePutIfAbsentRequest(reader);
case OP_CACHE_GET_AND_PUT_IF_ABSENT:
return new ClientCacheGetAndPutIfAbsentRequest(reader);
case OP_CACHE_REPLACE:
return new ClientCacheReplaceRequest(reader);
case OP_CACHE_REPLACE_IF_EQUALS:
return new ClientCacheReplaceIfEqualsRequest(reader);
case OP_CACHE_PUT_ALL:
return new ClientCachePutAllRequest(reader);
case OP_CACHE_CLEAR:
return new ClientCacheClearRequest(reader);
case OP_CACHE_CLEAR_KEY:
return new ClientCacheClearKeyRequest(reader);
case OP_CACHE_CLEAR_KEYS:
return new ClientCacheClearKeysRequest(reader);
case OP_CACHE_REMOVE_KEY:
return new ClientCacheRemoveKeyRequest(reader);
case OP_CACHE_REMOVE_IF_EQUALS:
return new ClientCacheRemoveIfEqualsRequest(reader);
case OP_CACHE_GET_SIZE:
return new ClientCacheGetSizeRequest(reader);
case OP_CACHE_REMOVE_KEYS:
return new ClientCacheRemoveKeysRequest(reader);
case OP_CACHE_LOCAL_PEEK:
return new ClientCacheLocalPeekRequest(reader);
case OP_CACHE_REMOVE_ALL:
return new ClientCacheRemoveAllRequest(reader);
case OP_CACHE_PUT_ALL_CONFLICT:
return new ClientCachePutAllConflictRequest(reader, ctx);
case OP_CACHE_REMOVE_ALL_CONFLICT:
return new ClientCacheRemoveAllConflictRequest(reader);
case OP_CACHE_INVOKE:
return new ClientCacheInvokeRequest(reader);
case OP_CACHE_INVOKE_ALL:
return new ClientCacheInvokeAllRequest(reader);
case OP_CACHE_CREATE_WITH_NAME:
return new ClientCacheCreateWithNameRequest(reader);
case OP_CACHE_GET_OR_CREATE_WITH_NAME:
return new ClientCacheGetOrCreateWithNameRequest(reader);
case OP_CACHE_DESTROY:
return new ClientCacheDestroyRequest(reader);
case OP_CACHE_NODE_PARTITIONS:
return new ClientCacheNodePartitionsRequest(reader);
case OP_CACHE_PARTITIONS:
return new ClientCachePartitionsRequest(reader, protocolCtx);
case OP_CACHE_GET_NAMES:
return new ClientCacheGetNamesRequest(reader);
case OP_CACHE_GET_CONFIGURATION:
return new ClientCacheGetConfigurationRequest(reader, protocolCtx);
case OP_CACHE_CREATE_WITH_CONFIGURATION:
return new ClientCacheCreateWithConfigurationRequest(reader, protocolCtx);
case OP_CACHE_GET_OR_CREATE_WITH_CONFIGURATION:
return new ClientCacheGetOrCreateWithConfigurationRequest(reader, protocolCtx);
case OP_QUERY_SQL:
return new ClientCacheSqlQueryRequest(reader);
case OP_QUERY_SQL_FIELDS:
return new ClientCacheSqlFieldsQueryRequest(reader, protocolCtx);
case OP_QUERY_SQL_FIELDS_CURSOR_GET_PAGE:
return new ClientCacheQueryNextPageRequest(reader);
case OP_QUERY_CONTINUOUS:
return new ClientCacheQueryContinuousRequest(reader);
case OP_QUERY_INDEX:
return new ClientCacheIndexQueryRequest(reader, protocolCtx);
case OP_TX_START:
return new ClientTxStartRequest(reader);
case OP_TX_END:
return new ClientTxEndRequest(reader);
case OP_CLUSTER_GET_STATE:
return new ClientClusterGetStateRequest(reader);
case OP_CLUSTER_CHANGE_STATE:
return new ClientClusterChangeStateRequest(reader, protocolCtx);
case OP_CLUSTER_CHANGE_WAL_STATE:
return new ClientClusterWalChangeStateRequest(reader);
case OP_CLUSTER_GET_WAL_STATE:
return new ClientClusterWalGetStateRequest(reader);
case OP_CLUSTER_GROUP_GET_NODE_IDS:
return new ClientClusterGroupGetNodeIdsRequest(reader);
case OP_CLUSTER_GROUP_GET_NODE_INFO:
return new ClientClusterGroupGetNodesDetailsRequest(reader);
case OP_CLUSTER_GROUP_GET_NODE_ENDPOINTS:
return new ClientClusterGroupGetNodesEndpointsRequest(reader);
case OP_COMPUTE_TASK_EXECUTE:
return new ClientExecuteTaskRequest(reader);
case OP_SERVICE_INVOKE:
return new ClientServiceInvokeRequest(reader, protocolCtx);
case OP_SERVICE_GET_DESCRIPTORS:
return new ClientServiceGetDescriptorsRequest(reader);
case OP_SERVICE_GET_DESCRIPTOR:
return new ClientServiceGetDescriptorRequest(reader);
case OP_DATA_STREAMER_START:
return new ClientDataStreamerStartRequest(reader);
case OP_DATA_STREAMER_ADD_DATA:
return new ClientDataStreamerAddDataRequest(reader);
case OP_ATOMIC_LONG_CREATE:
return new ClientAtomicLongCreateRequest(reader);
case OP_ATOMIC_LONG_REMOVE:
return new ClientAtomicLongRemoveRequest(reader);
case OP_ATOMIC_LONG_EXISTS:
return new ClientAtomicLongExistsRequest(reader);
case OP_ATOMIC_LONG_VALUE_GET:
return new ClientAtomicLongValueGetRequest(reader);
case OP_ATOMIC_LONG_VALUE_ADD_AND_GET:
return new ClientAtomicLongValueAddAndGetRequest(reader);
case OP_ATOMIC_LONG_VALUE_GET_AND_SET:
return new ClientAtomicLongValueGetAndSetRequest(reader);
case OP_ATOMIC_LONG_VALUE_COMPARE_AND_SET:
return new ClientAtomicLongValueCompareAndSetRequest(reader);
case OP_ATOMIC_LONG_VALUE_COMPARE_AND_SET_AND_GET:
return new ClientAtomicLongValueCompareAndSetAndGetRequest(reader);
case OP_SET_GET_OR_CREATE:
return new ClientIgniteSetGetOrCreateRequest(reader);
case OP_SET_CLOSE:
return new ClientIgniteSetCloseRequest(reader);
case OP_SET_EXISTS:
return new ClientIgniteSetExistsRequest(reader);
case OP_SET_VALUE_ADD:
return new ClientIgniteSetValueAddRequest(reader);
case OP_SET_VALUE_ADD_ALL:
return new ClientIgniteSetValueAddAllRequest(reader);
case OP_SET_VALUE_REMOVE:
return new ClientIgniteSetValueRemoveRequest(reader);
case OP_SET_VALUE_REMOVE_ALL:
return new ClientIgniteSetValueRemoveAllRequest(reader);
case OP_SET_VALUE_CONTAINS:
return new ClientIgniteSetValueContainsRequest(reader);
case OP_SET_VALUE_CONTAINS_ALL:
return new ClientIgniteSetValueContainsAllRequest(reader);
case OP_SET_VALUE_RETAIN_ALL:
return new ClientIgniteSetValueRetainAllRequest(reader);
case OP_SET_SIZE:
return new ClientIgniteSetSizeRequest(reader);
case OP_SET_CLEAR:
return new ClientIgniteSetClearRequest(reader);
case OP_SET_ITERATOR_START:
return new ClientIgniteSetIteratorStartRequest(reader);
case OP_SET_ITERATOR_GET_PAGE:
return new ClientIgniteSetIteratorGetPageRequest(reader);
case OP_SERVICE_GET_TOPOLOGY:
return new ClientServiceTopologyRequest(reader);
case OP_STOP_WARMUP:
return new ClientCacheStopWarmupRequest(reader);
}
return new ClientRawRequest(reader.readLong(), ClientStatus.INVALID_OP_CODE,
"Invalid request op code: " + opCode);
}