IGNITE-1281 - Fixed afterMessageRead() for hierarchical classes.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/37538fce Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/37538fce Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/37538fce Branch: refs/heads/ignite-1281 Commit: 37538fcec769f5188e7d8cf5b105fdd384010fa2 Parents: d150191 Author: Alexey Goncharuk <[email protected]> Authored: Mon Aug 24 14:25:22 2015 -0700 Committer: Alexey Goncharuk <[email protected]> Committed: Mon Aug 24 14:25:22 2015 -0700 ---------------------------------------------------------------------- .../java/org/apache/ignite/codegen/MessageCodeGenerator.java | 6 +++++- .../org/apache/ignite/internal/GridJobCancelRequest.java | 2 +- .../org/apache/ignite/internal/GridJobExecuteRequest.java | 2 +- .../org/apache/ignite/internal/GridJobExecuteResponse.java | 2 +- .../org/apache/ignite/internal/GridJobSiblingsRequest.java | 2 +- .../org/apache/ignite/internal/GridJobSiblingsResponse.java | 2 +- .../org/apache/ignite/internal/GridTaskCancelRequest.java | 2 +- .../org/apache/ignite/internal/GridTaskSessionRequest.java | 2 +- .../ignite/internal/direct/DirectByteBufferStream.java | 2 +- .../apache/ignite/internal/direct/DirectMessageReader.java | 5 +++-- .../internal/managers/checkpoint/GridCheckpointRequest.java | 2 +- .../internal/managers/communication/GridIoManager.java | 2 +- .../internal/managers/communication/GridIoMessage.java | 2 +- .../internal/managers/communication/GridIoUserMessage.java | 2 +- .../internal/managers/deployment/GridDeploymentInfoBean.java | 2 +- .../internal/managers/deployment/GridDeploymentRequest.java | 2 +- .../internal/managers/deployment/GridDeploymentResponse.java | 2 +- .../managers/eventstorage/GridEventStorageMessage.java | 2 +- .../processors/affinity/AffinityTopologyVersion.java | 2 +- .../internal/processors/cache/CacheEntryInfoCollection.java | 2 +- .../processors/cache/CacheEntryPredicateAdapter.java | 2 +- .../processors/cache/CacheEntryPredicateContainsValue.java | 2 +- .../processors/cache/CacheEntrySerializablePredicate.java | 2 +- .../ignite/internal/processors/cache/CacheEvictionEntry.java | 2 +- .../internal/processors/cache/CacheInvokeDirectResult.java | 2 +- .../ignite/internal/processors/cache/CacheObjectAdapter.java | 2 +- .../internal/processors/cache/CacheObjectByteArrayImpl.java | 2 +- .../ignite/internal/processors/cache/GridCacheEntryInfo.java | 2 +- .../internal/processors/cache/GridCacheEvictionRequest.java | 2 +- .../internal/processors/cache/GridCacheEvictionResponse.java | 2 +- .../ignite/internal/processors/cache/GridCacheMessage.java | 2 +- .../ignite/internal/processors/cache/GridCacheReturn.java | 2 +- .../cache/distributed/GridCacheTtlUpdateRequest.java | 2 +- .../cache/distributed/GridCacheTxRecoveryRequest.java | 2 +- .../cache/distributed/GridCacheTxRecoveryResponse.java | 2 +- .../cache/distributed/GridDistributedBaseMessage.java | 2 +- .../cache/distributed/GridDistributedLockRequest.java | 2 +- .../cache/distributed/GridDistributedLockResponse.java | 2 +- .../cache/distributed/GridDistributedTxFinishRequest.java | 2 +- .../cache/distributed/GridDistributedTxFinishResponse.java | 2 +- .../cache/distributed/GridDistributedTxPrepareRequest.java | 2 +- .../cache/distributed/GridDistributedTxPrepareResponse.java | 2 +- .../cache/distributed/GridDistributedUnlockRequest.java | 2 +- .../distributed/dht/GridDhtAffinityAssignmentRequest.java | 2 +- .../distributed/dht/GridDhtAffinityAssignmentResponse.java | 2 +- .../processors/cache/distributed/dht/GridDhtLockRequest.java | 2 +- .../cache/distributed/dht/GridDhtLockResponse.java | 2 +- .../cache/distributed/dht/GridDhtTxFinishRequest.java | 2 +- .../cache/distributed/dht/GridDhtTxFinishResponse.java | 2 +- .../cache/distributed/dht/GridDhtTxPrepareRequest.java | 2 +- .../cache/distributed/dht/GridDhtTxPrepareResponse.java | 2 +- .../cache/distributed/dht/GridDhtUnlockRequest.java | 2 +- .../dht/atomic/GridDhtAtomicDeferredUpdateResponse.java | 2 +- .../distributed/dht/atomic/GridDhtAtomicUpdateRequest.java | 2 +- .../distributed/dht/atomic/GridDhtAtomicUpdateResponse.java | 2 +- .../distributed/dht/atomic/GridNearAtomicUpdateRequest.java | 2 +- .../distributed/dht/atomic/GridNearAtomicUpdateResponse.java | 2 +- .../distributed/dht/preloader/GridDhtForceKeysRequest.java | 2 +- .../distributed/dht/preloader/GridDhtForceKeysResponse.java | 2 +- .../dht/preloader/GridDhtPartitionDemandMessage.java | 2 +- .../dht/preloader/GridDhtPartitionExchangeId.java | 2 +- .../dht/preloader/GridDhtPartitionSupplyMessage.java | 2 +- .../dht/preloader/GridDhtPartitionsAbstractMessage.java | 2 +- .../dht/preloader/GridDhtPartitionsFullMessage.java | 2 +- .../dht/preloader/GridDhtPartitionsSingleMessage.java | 2 +- .../dht/preloader/GridDhtPartitionsSingleRequest.java | 2 +- .../cache/distributed/near/CacheVersionedValue.java | 2 +- .../cache/distributed/near/GridNearGetRequest.java | 2 +- .../cache/distributed/near/GridNearGetResponse.java | 2 +- .../cache/distributed/near/GridNearLockRequest.java | 2 +- .../cache/distributed/near/GridNearLockResponse.java | 2 +- .../cache/distributed/near/GridNearTxFinishRequest.java | 2 +- .../cache/distributed/near/GridNearTxFinishResponse.java | 2 +- .../cache/distributed/near/GridNearTxPrepareRequest.java | 2 +- .../cache/distributed/near/GridNearTxPrepareResponse.java | 2 +- .../cache/distributed/near/GridNearUnlockRequest.java | 2 +- .../processors/cache/query/GridCacheQueryRequest.java | 2 +- .../processors/cache/query/GridCacheQueryResponse.java | 2 +- .../internal/processors/cache/query/GridCacheSqlQuery.java | 2 +- .../cache/query/continuous/CacheContinuousQueryEntry.java | 2 +- .../processors/cache/transactions/IgniteTxEntry.java | 2 +- .../internal/processors/cache/transactions/IgniteTxKey.java | 2 +- .../processors/cache/transactions/TxEntryValueHolder.java | 2 +- .../processors/cache/version/GridCacheRawVersionedEntry.java | 2 +- .../internal/processors/cache/version/GridCacheVersion.java | 2 +- .../processors/cache/version/GridCacheVersionEx.java | 2 +- .../processors/clock/GridClockDeltaSnapshotMessage.java | 2 +- .../internal/processors/clock/GridClockDeltaVersion.java | 2 +- .../processors/continuous/GridContinuousMessage.java | 2 +- .../internal/processors/datastreamer/DataStreamerEntry.java | 2 +- .../processors/datastreamer/DataStreamerRequest.java | 2 +- .../processors/datastreamer/DataStreamerResponse.java | 2 +- .../ignite/internal/processors/igfs/IgfsAckMessage.java | 2 +- .../apache/ignite/internal/processors/igfs/IgfsBlockKey.java | 2 +- .../ignite/internal/processors/igfs/IgfsBlocksMessage.java | 2 +- .../internal/processors/igfs/IgfsCommunicationMessage.java | 2 +- .../ignite/internal/processors/igfs/IgfsDeleteMessage.java | 2 +- .../internal/processors/igfs/IgfsFileAffinityRange.java | 2 +- .../internal/processors/igfs/IgfsFragmentizerRequest.java | 2 +- .../internal/processors/igfs/IgfsFragmentizerResponse.java | 2 +- .../ignite/internal/processors/igfs/IgfsSyncMessage.java | 2 +- .../query/h2/twostep/messages/GridQueryCancelRequest.java | 2 +- .../query/h2/twostep/messages/GridQueryFailResponse.java | 2 +- .../query/h2/twostep/messages/GridQueryNextPageRequest.java | 2 +- .../query/h2/twostep/messages/GridQueryNextPageResponse.java | 2 +- .../query/h2/twostep/messages/GridQueryRequest.java | 2 +- .../processors/rest/handlers/task/GridTaskResultRequest.java | 2 +- .../rest/handlers/task/GridTaskResultResponse.java | 2 +- .../org/apache/ignite/internal/util/GridByteArrayList.java | 2 +- .../java/org/apache/ignite/internal/util/GridLongList.java | 2 +- .../apache/ignite/internal/util/nio/GridDirectParser.java | 2 +- .../plugin/extensions/communication/MessageFormatter.java | 3 ++- .../plugin/extensions/communication/MessageReader.java | 3 ++- .../main/java/org/apache/ignite/spi/IgniteSpiAdapter.java | 2 +- .../ignite/spi/collision/jobstealing/JobStealingRequest.java | 2 +- .../ignite/spi/communication/tcp/TcpCommunicationSpi.java | 8 ++++---- .../org/apache/ignite/testframework/GridSpiTestContext.java | 2 +- 117 files changed, 128 insertions(+), 121 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/codegen/src/main/java/org/apache/ignite/codegen/MessageCodeGenerator.java ---------------------------------------------------------------------- diff --git a/modules/codegen/src/main/java/org/apache/ignite/codegen/MessageCodeGenerator.java b/modules/codegen/src/main/java/org/apache/ignite/codegen/MessageCodeGenerator.java index 8305297..37e484e 100644 --- a/modules/codegen/src/main/java/org/apache/ignite/codegen/MessageCodeGenerator.java +++ b/modules/codegen/src/main/java/org/apache/ignite/codegen/MessageCodeGenerator.java @@ -142,6 +142,8 @@ public class MessageCodeGenerator { MessageCodeGenerator gen = new MessageCodeGenerator(srcDir); + gen.generateAll(true); + // gen.generateAndWrite(DataStreamerEntry.class); // gen.generateAndWrite(GridDistributedLockRequest.class); @@ -341,6 +343,8 @@ public class MessageCodeGenerator { if (cls.isAnnotationPresent(IgniteCodeGeneratingFail.class)) throw new IllegalStateException("@IgniteCodeGeneratingFail is provided for class: " + cls.getName()); + boolean abs = Modifier.isAbstract(cls.getModifiers()); + write.clear(); read.clear(); @@ -376,7 +380,7 @@ public class MessageCodeGenerator { indent--; finish(write, false); - finish(read, true); + finish(read, !abs); } /** http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 f6a8e5a..49f8c7b 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 @@ -178,7 +178,7 @@ public class GridJobCancelRequest implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 9a27b88..83a52ce 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 @@ -738,7 +738,7 @@ public class GridJobExecuteRequest implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 6465328..b863993 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 @@ -329,7 +329,7 @@ public class GridJobExecuteResponse implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 6f72b1d..4198d46 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 @@ -138,7 +138,7 @@ public class GridJobSiblingsRequest implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 db32b6d..9b4d566 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 @@ -117,7 +117,7 @@ public class GridJobSiblingsResponse implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 db464c7..cabfea5 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 @@ -101,7 +101,7 @@ public class GridTaskCancelRequest implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 97f5a53..ee6bbf3 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 @@ -166,7 +166,7 @@ public class GridTaskSessionRequest implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectByteBufferStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectByteBufferStream.java b/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectByteBufferStream.java index 120350b..02b6be9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectByteBufferStream.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectByteBufferStream.java @@ -945,7 +945,7 @@ public class DirectByteBufferStream { msg = type == Byte.MIN_VALUE ? null : msgFactory.create(type); if (msg != null) - reader = msgFormatter.reader(msgFactory); + reader = msgFormatter.reader(msgFactory, msg.getClass()); msgTypeDone = true; } http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectMessageReader.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectMessageReader.java b/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectMessageReader.java index d7d1c7d..91fb43f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectMessageReader.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/direct/DirectMessageReader.java @@ -55,8 +55,9 @@ public class DirectMessageReader implements MessageReader { return true; } - /** {@inheritDoc} */ - @Override public boolean afterMessageRead() { + /** {@inheritDoc} + * @param msgCls*/ + @Override public boolean afterMessageRead(Class<? extends Message> msgCls) { return true; } http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 527acf3..0b5ffae 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 @@ -152,7 +152,7 @@ public class GridCheckpointRequest implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 85e8421..6698f4f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -235,7 +235,7 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa return new DirectMessageWriter(); } - @Override public MessageReader reader(MessageFactory factory) { + @Override public MessageReader reader(MessageFactory factory, Class<? extends Message> msgCls) { return new DirectMessageReader(msgFactory, this); } }; http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 20ee953..c57e78f 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 @@ -302,7 +302,7 @@ public class GridIoMessage implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 2b41113..affa70f 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 @@ -331,7 +331,7 @@ public class GridIoUserMessage implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 dd2c60a..d916840 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 @@ -237,7 +237,7 @@ public class GridDeploymentInfoBean implements Message, GridDeploymentInfo, Exte } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 ec8efd8..ab8b4f6 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 @@ -252,7 +252,7 @@ public class GridDeploymentRequest implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 4b50960..99b7b11 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 @@ -174,7 +174,7 @@ public class GridDeploymentResponse implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 5c2f5d6..e12cbee 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 @@ -417,7 +417,7 @@ public class GridEventStorageMessage implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/AffinityTopologyVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/AffinityTopologyVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/AffinityTopologyVersion.java index 8ace630..4d64d6a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/AffinityTopologyVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/AffinityTopologyVersion.java @@ -177,7 +177,7 @@ public class AffinityTopologyVersion implements Comparable<AffinityTopologyVersi } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryInfoCollection.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryInfoCollection.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryInfoCollection.java index 0dcf0df..65dba59 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryInfoCollection.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryInfoCollection.java @@ -96,7 +96,7 @@ public class CacheEntryInfoCollection implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java index 36a4099..c5b20b4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateAdapter.java @@ -64,7 +64,7 @@ public abstract class CacheEntryPredicateAdapter implements CacheEntryPredicate if (!reader.beforeMessageRead()) return false; - return reader.afterMessageRead(); + return true; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateContainsValue.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateContainsValue.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateContainsValue.java index ab5cb93..3a74e83 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateContainsValue.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntryPredicateContainsValue.java @@ -118,7 +118,7 @@ public class CacheEntryPredicateContainsValue extends CacheEntryPredicateAdapter } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntrySerializablePredicate.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntrySerializablePredicate.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntrySerializablePredicate.java index caa8ee9..539455c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntrySerializablePredicate.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEntrySerializablePredicate.java @@ -137,7 +137,7 @@ public class CacheEntrySerializablePredicate implements CacheEntryPredicate { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictionEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictionEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictionEntry.java index cb9a76e..86e263f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictionEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheEvictionEntry.java @@ -172,7 +172,7 @@ public class CacheEvictionEntry implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeDirectResult.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeDirectResult.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeDirectResult.java index eee0474..f00f435 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeDirectResult.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeDirectResult.java @@ -198,7 +198,7 @@ public class CacheInvokeDirectResult implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectAdapter.java index 66fc6ca..173483d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectAdapter.java @@ -80,7 +80,7 @@ public abstract class CacheObjectAdapter implements CacheObject, Externalizable } - return reader.afterMessageRead(); + return true; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectByteArrayImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectByteArrayImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectByteArrayImpl.java index 7327ec2..b4b680f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectByteArrayImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheObjectByteArrayImpl.java @@ -126,7 +126,7 @@ public class CacheObjectByteArrayImpl implements CacheObject, Externalizable { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEntryInfo.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEntryInfo.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEntryInfo.java index 360f475..7673f78 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEntryInfo.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheEntryInfo.java @@ -317,7 +317,7 @@ public class GridCacheEntryInfo implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 ffa5897..b799198 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 @@ -220,7 +220,7 @@ public class GridCacheEvictionRequest extends GridCacheMessage implements GridCa } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 ddcec58..ab2c0e7 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 @@ -198,7 +198,7 @@ public class GridCacheEvictionResponse extends GridCacheMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java index 7c7ab5f..8ebce35 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMessage.java @@ -635,7 +635,7 @@ public abstract class GridCacheMessage implements Message { } - return reader.afterMessageRead(); + return true; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java index f599a9a..cee0eac 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java @@ -425,7 +425,7 @@ public class GridCacheReturn implements Externalizable, Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 ec57953..c192699 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 @@ -304,7 +304,7 @@ public class GridCacheTtlUpdateRequest extends GridCacheMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryRequest.java index 1908d57..f7474fa 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryRequest.java @@ -241,7 +241,7 @@ public class GridCacheTxRecoveryRequest extends GridDistributedBaseMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryResponse.java index 159510c..658896e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryResponse.java @@ -162,7 +162,7 @@ public class GridCacheTxRecoveryResponse extends GridDistributedBaseMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java index a5516af..7b84f32 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedBaseMessage.java @@ -275,7 +275,7 @@ public abstract class GridDistributedBaseMessage extends GridCacheMessage implem } - return reader.afterMessageRead(); + return true; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 56be859..093d123 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 @@ -525,7 +525,7 @@ public class GridDistributedLockRequest extends GridDistributedBaseMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 12a22f2..337eb49 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 @@ -303,7 +303,7 @@ public class GridDistributedLockResponse extends GridDistributedBaseMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 5a4796f..1901f7a 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 @@ -408,7 +408,7 @@ public class GridDistributedTxFinishRequest extends GridDistributedBaseMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 a08430d..4641822 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 @@ -134,7 +134,7 @@ public class GridDistributedTxFinishResponse extends GridCacheMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 9940f5e..b3f85e0 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 @@ -575,7 +575,7 @@ public class GridDistributedTxPrepareRequest extends GridDistributedBaseMessage } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 5d65146..19a36fe 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 @@ -151,7 +151,7 @@ public class GridDistributedTxPrepareResponse extends GridDistributedBaseMessage } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 ac8239d..d581dae 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 @@ -138,7 +138,7 @@ public class GridDistributedUnlockRequest extends GridDistributedBaseMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 4310297..352dd8c 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 @@ -125,7 +125,7 @@ public class GridDhtAffinityAssignmentRequest extends GridCacheMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 18f338a..a1cf52a 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 @@ -199,7 +199,7 @@ public class GridDhtAffinityAssignmentResponse extends GridCacheMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 de953dc..8064f1d 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 @@ -508,7 +508,7 @@ public class GridDhtLockRequest extends GridDistributedLockRequest { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 265cb9b..55abb08 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 @@ -268,7 +268,7 @@ public class GridDhtLockResponse extends GridDistributedLockResponse { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 f74e075..b35c822 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 @@ -385,7 +385,7 @@ public class GridDhtTxFinishRequest extends GridDistributedTxFinishRequest { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 a96ea2b..658b4b2 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 @@ -115,7 +115,7 @@ public class GridDhtTxFinishResponse extends GridDistributedTxFinishResponse { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 20b22d3..fa2272b 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 @@ -533,7 +533,7 @@ public class GridDhtTxPrepareRequest extends GridDistributedTxPrepareRequest { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 321039d..441c0f8 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 @@ -345,7 +345,7 @@ public class GridDhtTxPrepareResponse extends GridDistributedTxPrepareResponse { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 2c895a7..4a4b361 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 @@ -142,7 +142,7 @@ public class GridDhtUnlockRequest extends GridDistributedUnlockRequest { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 d4f8a13..29e19d2 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 @@ -119,7 +119,7 @@ public class GridDhtAtomicDeferredUpdateResponse extends GridCacheMessage implem } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 e75c42b..8eee045 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 @@ -884,7 +884,7 @@ public class GridDhtAtomicUpdateRequest extends GridCacheMessage implements Grid } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 18ecaa3..bfc90d2 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 @@ -262,7 +262,7 @@ public class GridDhtAtomicUpdateResponse extends GridCacheMessage implements Gri } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 b3960a7..37bac29 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 @@ -921,7 +921,7 @@ public class GridNearAtomicUpdateRequest extends GridCacheMessage implements Gri } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 c278815..13f8d19 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 @@ -602,7 +602,7 @@ public class GridNearAtomicUpdateResponse extends GridCacheMessage implements Gr } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 8aef5c5..bd76ecc 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 @@ -242,7 +242,7 @@ public class GridDhtForceKeysRequest extends GridCacheMessage implements GridCac } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 10256c5..75f9b44 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 @@ -288,7 +288,7 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 45ba653..798d5f7 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 @@ -308,7 +308,7 @@ public class GridDhtPartitionDemandMessage extends GridCacheMessage { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 9cb5fab..f304d6b 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 @@ -217,7 +217,7 @@ public class GridDhtPartitionExchangeId implements Message, Comparable<GridDhtPa } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 3d88a60..7c4d1fc 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 @@ -374,7 +374,7 @@ public class GridDhtPartitionSupplyMessage extends GridCacheMessage implements G } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java index 6e6741b..5a8616d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java @@ -140,7 +140,7 @@ abstract class GridDhtPartitionsAbstractMessage extends GridCacheMessage { } - return reader.afterMessageRead(); + return true; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 9eb77df..1e4709a 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 @@ -180,7 +180,7 @@ public class GridDhtPartitionsFullMessage extends GridDhtPartitionsAbstractMessa } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 0a17930..89f4c6c 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 @@ -170,7 +170,7 @@ public class GridDhtPartitionsSingleMessage extends GridDhtPartitionsAbstractMes } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 dcb53d7..e868779 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 @@ -71,7 +71,7 @@ public class GridDhtPartitionsSingleRequest extends GridDhtPartitionsAbstractMes if (!super.readFrom(buf, reader)) return false; - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/CacheVersionedValue.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/CacheVersionedValue.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/CacheVersionedValue.java index 65d1b15..75941e6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/CacheVersionedValue.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/CacheVersionedValue.java @@ -149,7 +149,7 @@ public class CacheVersionedValue implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 544b13a..146eba4 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 @@ -461,7 +461,7 @@ public class GridNearGetRequest extends GridCacheMessage implements GridCacheDep } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 73d0ea1..e649939 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 @@ -331,7 +331,7 @@ public class GridNearGetResponse extends GridCacheMessage implements GridCacheDe } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 4b19951..5d2bb67 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 @@ -577,7 +577,7 @@ public class GridNearLockRequest extends GridDistributedLockRequest { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 c2e89ec..7ff5276 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 @@ -307,7 +307,7 @@ public class GridNearLockResponse extends GridDistributedLockResponse { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 ca79a1b..c2e6f62 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 @@ -271,7 +271,7 @@ public class GridNearTxFinishRequest extends GridDistributedTxFinishRequest { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 2565e4d..c7dc487 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 @@ -188,7 +188,7 @@ public class GridNearTxFinishResponse extends GridDistributedTxFinishResponse { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 9cdae50..7c88a2c 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 @@ -470,7 +470,7 @@ public class GridNearTxPrepareRequest extends GridDistributedTxPrepareRequest { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 b887f0c..650ac68 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 @@ -514,7 +514,7 @@ public class GridNearTxPrepareResponse extends GridDistributedTxPrepareResponse } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 c79bd66..366b337 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 @@ -73,7 +73,7 @@ public class GridNearUnlockRequest extends GridDistributedUnlockRequest { if (!super.readFrom(buf, reader)) return false; - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 77d9c4c..9793858 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 @@ -732,7 +732,7 @@ public class GridCacheQueryRequest extends GridCacheMessage implements GridCache } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/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 05a0c0d..bc7180e 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 @@ -318,7 +318,7 @@ public class GridCacheQueryResponse extends GridCacheMessage implements GridCach } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheSqlQuery.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheSqlQuery.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheSqlQuery.java index b74393e..d63331c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheSqlQuery.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheSqlQuery.java @@ -205,7 +205,7 @@ public class GridCacheSqlQuery implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java index 0905e25..7670745 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java @@ -279,7 +279,7 @@ public class CacheContinuousQueryEntry implements GridCacheDeployable, Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java index 40756d7..c94e3dd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxEntry.java @@ -987,7 +987,7 @@ public class IgniteTxEntry implements GridPeerDeployAware, Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/37538fce/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxKey.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxKey.java index fae01ee..17ec239 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxKey.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxKey.java @@ -167,7 +167,7 @@ public class IgniteTxKey implements Message { } - return reader.afterMessageRead(); + return reader.afterMessageRead(null); } /** {@inheritDoc} */
