# gg-9791 - Communication fixes
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d85b5133 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d85b5133 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d85b5133 Branch: refs/heads/ignite-sql-tests Commit: d85b513338009dd41889bf1e2ef02a7a01042136 Parents: 86b233c Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Thu Feb 19 20:56:42 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Thu Feb 19 20:56:42 2015 -0800 ---------------------------------------------------------------------- .../apache/ignite/internal/GridJobCancelRequest.java | 5 +++++ .../ignite/internal/GridJobExecuteRequest.java | 5 +++++ .../ignite/internal/GridJobExecuteResponse.java | 5 +++++ .../ignite/internal/GridJobSiblingsRequest.java | 5 +++++ .../ignite/internal/GridJobSiblingsResponse.java | 5 +++++ .../ignite/internal/GridTaskCancelRequest.java | 5 +++++ .../ignite/internal/GridTaskSessionRequest.java | 5 +++++ .../managers/checkpoint/GridCheckpointRequest.java | 5 +++++ .../managers/communication/GridIoMessage.java | 5 +++++ .../managers/communication/GridIoUserMessage.java | 5 +++++ .../managers/deployment/GridDeploymentInfoBean.java | 5 +++++ .../managers/deployment/GridDeploymentRequest.java | 5 +++++ .../managers/deployment/GridDeploymentResponse.java | 5 +++++ .../eventstorage/GridEventStorageMessage.java | 5 +++++ .../processors/cache/GridCacheEvictionRequest.java | 5 +++++ .../processors/cache/GridCacheEvictionResponse.java | 5 +++++ .../processors/cache/GridCacheValueBytes.java | 5 +++++ .../GridCacheOptimisticCheckPreparedTxRequest.java | 5 +++++ .../GridCacheOptimisticCheckPreparedTxResponse.java | 5 +++++ .../cache/distributed/GridCacheTtlUpdateRequest.java | 15 ++++++++++----- .../distributed/GridDistributedLockRequest.java | 5 +++++ .../distributed/GridDistributedLockResponse.java | 5 +++++ .../distributed/GridDistributedTxFinishRequest.java | 5 +++++ .../distributed/GridDistributedTxFinishResponse.java | 5 +++++ .../distributed/GridDistributedTxPrepareRequest.java | 5 +++++ .../GridDistributedTxPrepareResponse.java | 5 +++++ .../distributed/GridDistributedUnlockRequest.java | 5 +++++ .../dht/GridDhtAffinityAssignmentRequest.java | 5 +++++ .../dht/GridDhtAffinityAssignmentResponse.java | 5 +++++ .../cache/distributed/dht/GridDhtLockRequest.java | 5 +++++ .../cache/distributed/dht/GridDhtLockResponse.java | 5 +++++ .../distributed/dht/GridDhtTxFinishRequest.java | 5 +++++ .../distributed/dht/GridDhtTxFinishResponse.java | 5 +++++ .../distributed/dht/GridDhtTxPrepareRequest.java | 5 +++++ .../distributed/dht/GridDhtTxPrepareResponse.java | 5 +++++ .../cache/distributed/dht/GridDhtUnlockRequest.java | 5 +++++ .../atomic/GridDhtAtomicDeferredUpdateResponse.java | 5 +++++ .../dht/atomic/GridDhtAtomicUpdateRequest.java | 5 +++++ .../dht/atomic/GridDhtAtomicUpdateResponse.java | 5 +++++ .../dht/atomic/GridNearAtomicUpdateRequest.java | 5 +++++ .../dht/atomic/GridNearAtomicUpdateResponse.java | 5 +++++ .../dht/preloader/GridDhtForceKeysRequest.java | 5 +++++ .../dht/preloader/GridDhtForceKeysResponse.java | 5 +++++ .../dht/preloader/GridDhtPartitionDemandMessage.java | 5 +++++ .../dht/preloader/GridDhtPartitionExchangeId.java | 5 +++++ .../dht/preloader/GridDhtPartitionSupplyMessage.java | 5 +++++ .../dht/preloader/GridDhtPartitionsFullMessage.java | 5 +++++ .../preloader/GridDhtPartitionsSingleMessage.java | 5 +++++ .../preloader/GridDhtPartitionsSingleRequest.java | 5 +++++ .../cache/distributed/near/GridNearGetRequest.java | 6 ++++++ .../cache/distributed/near/GridNearGetResponse.java | 5 +++++ .../cache/distributed/near/GridNearLockRequest.java | 5 +++++ .../cache/distributed/near/GridNearLockResponse.java | 5 +++++ .../distributed/near/GridNearTxFinishRequest.java | 5 +++++ .../distributed/near/GridNearTxFinishResponse.java | 5 +++++ .../distributed/near/GridNearTxPrepareRequest.java | 5 +++++ .../distributed/near/GridNearTxPrepareResponse.java | 5 +++++ .../distributed/near/GridNearUnlockRequest.java | 5 +++++ .../cache/query/GridCacheQueryRequest.java | 5 +++++ .../cache/query/GridCacheQueryResponse.java | 5 +++++ .../processors/cache/version/GridCacheVersion.java | 5 +++++ .../clock/GridClockDeltaSnapshotMessage.java | 5 +++++ .../processors/clock/GridClockDeltaVersion.java | 5 +++++ .../processors/continuous/GridContinuousMessage.java | 5 +++++ .../processors/dataload/GridDataLoadRequest.java | 5 +++++ .../processors/dataload/GridDataLoadResponse.java | 5 +++++ .../internal/processors/igfs/IgfsAckMessage.java | 5 +++++ .../internal/processors/igfs/IgfsBlockKey.java | 5 +++++ .../internal/processors/igfs/IgfsBlocksMessage.java | 5 +++++ .../processors/igfs/IgfsCommunicationMessage.java | 5 +++++ .../internal/processors/igfs/IgfsDeleteMessage.java | 5 +++++ .../processors/igfs/IgfsFileAffinityRange.java | 5 +++++ .../processors/igfs/IgfsFragmentizerRequest.java | 5 +++++ .../processors/igfs/IgfsFragmentizerResponse.java | 5 +++++ .../internal/processors/igfs/IgfsSyncMessage.java | 5 +++++ .../rest/handlers/task/GridTaskResultRequest.java | 5 +++++ .../rest/handlers/task/GridTaskResultResponse.java | 5 +++++ .../streamer/GridStreamerCancelRequest.java | 5 +++++ .../streamer/GridStreamerExecutionRequest.java | 5 +++++ .../processors/streamer/GridStreamerResponse.java | 5 +++++ .../ignite/internal/util/GridByteArrayList.java | 5 +++++ .../apache/ignite/internal/util/GridLongList.java | 5 +++++ .../collision/jobstealing/JobStealingRequest.java | 5 +++++ .../spi/communication/tcp/TcpCommunicationSpi.java | 13 +++++++++++++ .../GridCommunicationSendMessageSelfTest.java | 5 +++++ .../communication/GridIoManagerSelfTest.java | 5 +++++ .../loadtests/communication/GridTestMessage.java | 5 +++++ .../ignite/spi/communication/GridTestMessage.java | 7 ++++++- 88 files changed, 455 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java index 670a34a..da24143 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobCancelRequest.java @@ -187,6 +187,11 @@ public class GridJobCancelRequest extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridJobCancelRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java index cd4cba5..a806e70 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteRequest.java @@ -745,6 +745,11 @@ public class GridJobExecuteRequest extends MessageAdapter implements GridTaskMes } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridJobExecuteRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java index 3621af9..461ff57 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobExecuteResponse.java @@ -338,6 +338,11 @@ public class GridJobExecuteResponse extends MessageAdapter implements GridTaskMe } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridJobExecuteResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java index 10ddf79..e43658d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsRequest.java @@ -147,6 +147,11 @@ public class GridJobSiblingsRequest extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridJobSiblingsRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java index 7b7469a..0fc7027 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridJobSiblingsResponse.java @@ -126,6 +126,11 @@ public class GridJobSiblingsResponse extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridJobSiblingsResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java index 2a17dd8..92ca3e9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskCancelRequest.java @@ -110,6 +110,11 @@ public class GridTaskCancelRequest extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridTaskCancelRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java index 6e5e755..5029eb8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java @@ -175,6 +175,11 @@ public class GridTaskSessionRequest extends MessageAdapter implements GridTaskMe } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridTaskSessionRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java index 82e7845..4ca6894 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointRequest.java @@ -161,6 +161,11 @@ public class GridCheckpointRequest extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCheckpointRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java index e18f53d..d708410 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java @@ -316,6 +316,11 @@ public class GridIoMessage extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridIoMessage.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java index ba94f23..533909c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoUserMessage.java @@ -340,6 +340,11 @@ public class GridIoUserMessage extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridIoUserMessage.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java index 083c6e7..ca6847b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentInfoBean.java @@ -247,6 +247,11 @@ public class GridDeploymentInfoBean extends MessageAdapter implements GridDeploy } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { U.writeGridUuid(out, clsLdrId); U.writeEnum(out, depMode); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java index 8666420..8d3277e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentRequest.java @@ -261,6 +261,11 @@ public class GridDeploymentRequest extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDeploymentRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java index f769334..6e65363 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentResponse.java @@ -183,6 +183,11 @@ public class GridDeploymentResponse extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDeploymentResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java index 0250363..67349f0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageMessage.java @@ -426,6 +426,11 @@ public class GridEventStorageMessage extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridEventStorageMessage.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java index 3c25ecb..8146d2d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionRequest.java @@ -223,6 +223,11 @@ public class GridCacheEvictionRequest<K, V> extends GridCacheMessage<K, V> imple } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheEvictionRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java index 279808d..748af3c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEvictionResponse.java @@ -212,6 +212,11 @@ public class GridCacheEvictionResponse<K, V> extends GridCacheMessage<K, V> { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheEvictionResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java index 735738b..50bd20c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheValueBytes.java @@ -183,6 +183,11 @@ public class GridCacheValueBytes extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheValueBytes.class, this, "len", bytes != null ? bytes.length : -1); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java index 916fc25..938520a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxRequest.java @@ -221,6 +221,11 @@ public class GridCacheOptimisticCheckPreparedTxRequest<K, V> extends GridDistrib } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheOptimisticCheckPreparedTxRequest.class, this, "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java index c3c3623..8fb67d7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheOptimisticCheckPreparedTxResponse.java @@ -168,6 +168,11 @@ public class GridCacheOptimisticCheckPreparedTxResponse<K, V> extends GridDistri } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheOptimisticCheckPreparedTxResponse.class, this, "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java index 5493700..62360d1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTtlUpdateRequest.java @@ -182,11 +182,6 @@ public class GridCacheTtlUpdateRequest<K, V> extends GridCacheMessage<K, V> { } /** {@inheritDoc} */ - @Override public byte directType() { - return 20; - } - - /** {@inheritDoc} */ @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); @@ -307,6 +302,16 @@ public class GridCacheTtlUpdateRequest<K, V> extends GridCacheMessage<K, V> { } /** {@inheritDoc} */ + @Override public byte directType() { + return 20; + } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheTtlUpdateRequest.class, this, "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java index 7a59c05..3fb2ac2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockRequest.java @@ -587,6 +587,11 @@ public class GridDistributedLockRequest<K, V> extends GridDistributedBaseMessage } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDistributedLockRequest.class, this, "keysCnt", retVals.length, "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java index a6f3109..21f6e36 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedLockResponse.java @@ -360,6 +360,11 @@ public class GridDistributedLockResponse<K, V> extends GridDistributedBaseMessag } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDistributedLockResponse.class, this, "valBytesLen", valBytes == null ? 0 : valBytes.size(), http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java index 8d149fd..7072270 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishRequest.java @@ -441,6 +441,11 @@ public class GridDistributedTxFinishRequest<K, V> extends GridDistributedBaseMes } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return GridToStringBuilder.toString(GridDistributedTxFinishRequest.class, this, "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java index 0583640..15d818d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxFinishResponse.java @@ -143,6 +143,11 @@ public class GridDistributedTxFinishResponse<K, V> extends GridCacheMessage<K, V } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return GridToStringBuilder.toString(GridDistributedTxFinishResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java index 2488648..e1d6088 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareRequest.java @@ -674,6 +674,11 @@ public class GridDistributedTxPrepareRequest<K, V> extends GridDistributedBaseMe } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return GridToStringBuilder.toString(GridDistributedTxPrepareRequest.class, this, "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java index 77e5f8d..f03542b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxPrepareResponse.java @@ -218,6 +218,11 @@ public class GridDistributedTxPrepareResponse<K, V> extends GridDistributedBaseM } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return GridToStringBuilder.toString(GridDistributedTxPrepareResponse.class, this, "err", err == null ? "null" : err.toString(), "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java index a980cf3..4e32adc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedUnlockRequest.java @@ -170,6 +170,11 @@ public class GridDistributedUnlockRequest<K, V> extends GridDistributedBaseMessa } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDistributedUnlockRequest.class, this, "keyBytesSize", keyBytes == null ? 0 : keyBytes.size(), "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java index 63a38b5..e966406 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentRequest.java @@ -67,6 +67,11 @@ public class GridDhtAffinityAssignmentRequest<K, V> extends GridCacheMessage<K, } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java index 5c12305..a62fc3c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAffinityAssignmentResponse.java @@ -88,6 +88,11 @@ public class GridDhtAffinityAssignmentResponse<K, V> extends GridCacheMessage<K, return 29; } + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + /** * @param ctx Context. */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java index f415711..cd189f3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java @@ -504,6 +504,11 @@ public class GridDhtLockRequest<K, V> extends GridDistributedLockRequest<K, V> { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtLockRequest.class, this, "nearKeyBytesSize", nearKeyBytes.size(), "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java index 3cdbd2f..f3b11d4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockResponse.java @@ -296,6 +296,11 @@ public class GridDhtLockResponse<K, V> extends GridDistributedLockResponse<K, V> } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtLockResponse.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java index ee73d94..43282f4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishRequest.java @@ -393,4 +393,9 @@ public class GridDhtTxFinishRequest<K, V> extends GridDistributedTxFinishRequest @Override public byte directType() { return 32; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java index 56e0fe0..fbd406b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishResponse.java @@ -122,4 +122,9 @@ public class GridDhtTxFinishResponse<K, V> extends GridDistributedTxFinishRespon @Override public byte directType() { return 33; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java index 1494956..ca62237 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareRequest.java @@ -521,4 +521,9 @@ public class GridDhtTxPrepareRequest<K, V> extends GridDistributedTxPrepareReque @Override public byte directType() { return 34; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java index 6c922c2..4390cf2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareResponse.java @@ -316,4 +316,9 @@ public class GridDhtTxPrepareResponse<K, V> extends GridDistributedTxPrepareResp @Override public byte directType() { return 35; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java index 0aa96fc..9b6b033 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtUnlockRequest.java @@ -157,4 +157,9 @@ public class GridDhtUnlockRequest<K, V> extends GridDistributedUnlockRequest<K, @Override public byte directType() { return 36; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java index cf85d28..9054d8f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicDeferredUpdateResponse.java @@ -126,4 +126,9 @@ public class GridDhtAtomicDeferredUpdateResponse<K, V> extends GridCacheMessage< @Override public byte directType() { return 37; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java index 4e067c0..603c53b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateRequest.java @@ -992,6 +992,11 @@ public class GridDhtAtomicUpdateRequest<K, V> extends GridCacheMessage<K, V> imp } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtAtomicUpdateRequest.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java index e018f7d..9165dd4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicUpdateResponse.java @@ -275,6 +275,11 @@ public class GridDhtAtomicUpdateResponse<K, V> extends GridCacheMessage<K, V> im } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtAtomicUpdateResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java index 1b1b6bb..7062b35 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateRequest.java @@ -846,6 +846,11 @@ public class GridNearAtomicUpdateRequest<K, V> extends GridCacheMessage<K, V> im } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearAtomicUpdateRequest.class, this, "filter", Arrays.toString(filter), "parent", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java index 0001ee5..1c783ea 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateResponse.java @@ -613,6 +613,11 @@ public class GridNearAtomicUpdateResponse<K, V> extends GridCacheMessage<K, V> i } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearAtomicUpdateResponse.class, this, "parent"); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java index 4ccf042..fcbc931 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysRequest.java @@ -259,6 +259,11 @@ public class GridDhtForceKeysRequest<K, V> extends GridCacheMessage<K, V> implem } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtForceKeysRequest.class, this, "keyCnt", keyCount(), "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java index b6ab31b..1abd6f3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java @@ -262,6 +262,11 @@ public class GridDhtForceKeysResponse<K, V> extends GridCacheMessage<K, V> imple } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtForceKeysResponse.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java index 6244579..dc9c5a2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandMessage.java @@ -315,6 +315,11 @@ public class GridDhtPartitionDemandMessage<K, V> extends GridCacheMessage<K, V> } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtPartitionDemandMessage.class, this, "partCnt", parts.size(), "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java index 993219a..0c9bfb1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionExchangeId.java @@ -223,6 +223,11 @@ public class GridDhtPartitionExchangeId extends MessageAdapter implements Compar } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtPartitionExchangeId.class, this, "nodeId", U.id8(nodeId), http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java index 8e8b4fb..203822e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplyMessage.java @@ -398,6 +398,11 @@ public class GridDhtPartitionSupplyMessage<K, V> extends GridCacheMessage<K, V> } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtPartitionSupplyMessage.class, this, "size", size(), http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java index 0b7d366..9d1ab03 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsFullMessage.java @@ -185,6 +185,11 @@ public class GridDhtPartitionsFullMessage<K, V> extends GridDhtPartitionsAbstrac } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtPartitionsFullMessage.class, this, "partCnt", parts != null ? parts.size() : 0, "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java index 9610b3d..0bfdc1c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleMessage.java @@ -150,6 +150,11 @@ public class GridDhtPartitionsSingleMessage<K, V> extends GridDhtPartitionsAbstr } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtPartitionsSingleMessage.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java index 0f2a950..abf4d94 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsSingleRequest.java @@ -80,6 +80,11 @@ public class GridDhtPartitionsSingleRequest<K, V> extends GridDhtPartitionsAbstr } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridDhtPartitionsSingleRequest.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java index 520ad1c..e561fd7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetRequest.java @@ -433,6 +433,12 @@ public class GridNearGetRequest<K, V> extends GridCacheMessage<K, V> implements return 49; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearGetRequest.class, this); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java index 6d29f8d..8847aed 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetResponse.java @@ -339,6 +339,11 @@ public class GridNearGetResponse<K, V> extends GridCacheMessage<K, V> implements } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearGetResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java index 7c65762..248b21b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockRequest.java @@ -531,6 +531,11 @@ public class GridNearLockRequest<K, V> extends GridDistributedLockRequest<K, V> } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearLockRequest.class, this, "filter", Arrays.toString(filter), "super", super.toString()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java index 3036e8a..a4a4840 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockResponse.java @@ -292,6 +292,11 @@ public class GridNearLockResponse<K, V> extends GridDistributedLockResponse<K, V } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearLockResponse.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java index b0e86fd..e567872 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishRequest.java @@ -278,6 +278,11 @@ public class GridNearTxFinishRequest<K, V> extends GridDistributedTxFinishReques } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return GridToStringBuilder.toString(GridNearTxFinishRequest.class, this, "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java index a00b595..2798e7b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishResponse.java @@ -197,6 +197,11 @@ public class GridNearTxFinishResponse<K, V> extends GridDistributedTxFinishRespo } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearTxFinishResponse.class, this, "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java index 77d28e6..6016553 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareRequest.java @@ -424,6 +424,11 @@ public class GridNearTxPrepareRequest<K, V> extends GridDistributedTxPrepareRequ } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearTxPrepareRequest.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java index d359cbf..6b93c70 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxPrepareResponse.java @@ -436,6 +436,11 @@ public class GridNearTxPrepareResponse<K, V> extends GridDistributedTxPrepareRes } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearTxPrepareResponse.class, this, "super", super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java index e762625..91c944d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearUnlockRequest.java @@ -82,6 +82,11 @@ public class GridNearUnlockRequest<K, V> extends GridDistributedUnlockRequest<K, } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridNearUnlockRequest.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java index f0ba13c..c330d58 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java @@ -752,6 +752,11 @@ public class GridCacheQueryRequest<K, V> extends GridCacheMessage<K, V> implemen } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheQueryRequest.class, this, super.toString()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java index 37bc1ae..1667090 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryResponse.java @@ -327,6 +327,11 @@ public class GridCacheQueryResponse<K, V> extends GridCacheMessage<K, V> impleme } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheQueryResponse.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java index 4114443..ac7213a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java @@ -344,6 +344,11 @@ public class GridCacheVersion extends MessageAdapter implements Comparable<GridC } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridCacheVersion.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java index b979578..08175c3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java @@ -135,6 +135,11 @@ public class GridClockDeltaSnapshotMessage extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridClockDeltaSnapshotMessage.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java index e98f5c6..86fab7e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java @@ -176,6 +176,11 @@ public class GridClockDeltaVersion extends MessageAdapter implements Comparable< } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridClockDeltaVersion.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java index 4418cd7..0b999b1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java @@ -226,6 +226,11 @@ public class GridContinuousMessage extends MessageAdapter { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(GridContinuousMessage.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java index 405b875..453ab43 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadRequest.java @@ -442,4 +442,9 @@ public class GridDataLoadRequest extends MessageAdapter { @Override public byte directType() { return 62; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java index df4b332..19a599c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoadResponse.java @@ -158,4 +158,9 @@ public class GridDataLoadResponse extends MessageAdapter { @Override public byte directType() { return 63; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java index 9b7fcdd..6f8000f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java @@ -184,4 +184,9 @@ public class IgfsAckMessage extends IgfsCommunicationMessage { @Override public byte directType() { return 64; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java index e681ed6..514eab3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java @@ -249,6 +249,11 @@ public final class IgfsBlockKey extends MessageAdapter implements Externalizable } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(IgfsBlockKey.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java index 1c141e9..7f054e8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java @@ -165,4 +165,9 @@ public class IgfsBlocksMessage extends IgfsCommunicationMessage { @Override public byte directType() { return 66; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java index 4278c41..5f2a801 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java @@ -71,4 +71,9 @@ public abstract class IgfsCommunicationMessage extends MessageAdapter { return true; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java index 7e5a690..3f0828c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java @@ -176,6 +176,11 @@ public class IgfsDeleteMessage extends IgfsCommunicationMessage { } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(IgfsDeleteMessage.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java index e83705f..2d4bd91 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java @@ -368,6 +368,11 @@ public class IgfsFileAffinityRange extends MessageAdapter implements Externaliza } /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } + + /** {@inheritDoc} */ @Override public String toString() { return S.toString(IgfsFileAffinityRange.class, this); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java index 4f09056..a23cca2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java @@ -146,4 +146,9 @@ public class IgfsFragmentizerRequest extends IgfsCommunicationMessage { @Override public byte directType() { return 69; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d85b5133/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java index a08b1b5..a2a0151 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java @@ -108,4 +108,9 @@ public class IgfsFragmentizerResponse extends IgfsCommunicationMessage { @Override public byte directType() { return 70; } + + /** {@inheritDoc} */ + @Override public byte fieldsCount() { + return 0; // TODO: implement. + } }
