topologyVersion was not initialized for GridDhtAtomicSingleUpdateRequest.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7d0cc2c4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7d0cc2c4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7d0cc2c4 Branch: refs/heads/ignite-5075 Commit: 7d0cc2c4df9dca67a981cb1770bb13092535eb9a Parents: 6579197 Author: sboikov <sboi...@gridgain.com> Authored: Thu May 4 11:23:41 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu May 4 11:23:41 2017 +0300 ---------------------------------------------------------------------- .../atomic/GridDhtAtomicAbstractUpdateRequest.java | 15 +++++++++++++++ .../dht/atomic/GridDhtAtomicUpdateRequest.java | 7 ++----- 2 files changed, 17 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7d0cc2c4/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicAbstractUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicAbstractUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicAbstractUpdateRequest.java index 4ff8484..6fb7df6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicAbstractUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicAbstractUpdateRequest.java @@ -138,6 +138,15 @@ public abstract class GridDhtAtomicAbstractUpdateRequest extends GridCacheMessag setFlag(true, DHT_ATOMIC_KEEP_BINARY_FLAG_MASK); } + /** {@inheritDoc} */ + @Override public final AffinityTopologyVersion topologyVersion() { + return topVer; + } + + /** + * @param nearNodeId Near node ID. + * @param nearFutId Future ID on near node. + */ void nearReplyInfo(UUID nearNodeId, long nearFutId) { assert nearNodeId != null; @@ -145,10 +154,16 @@ public abstract class GridDhtAtomicAbstractUpdateRequest extends GridCacheMessag this.nearFutId = nearFutId; } + /** + * @return {@code True} if backups should reply immediately. + */ boolean replyWithoutDelay() { return isFlag(DHT_ATOMIC_REPLY_WITHOUT_DELAY); } + /** + * @param replyWithoutDelay {@code True} if backups should reply immediately. + */ void replyWithoutDelay(boolean replyWithoutDelay) { setFlag(replyWithoutDelay, DHT_ATOMIC_REPLY_WITHOUT_DELAY); } http://git-wip-us.apache.org/repos/asf/ignite/blob/7d0cc2c4/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 54b2ae7..6f3f530 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 @@ -143,6 +143,8 @@ public class GridDhtAtomicUpdateRequest extends GridDhtAtomicAbstractUpdateReque * @param invokeArgs Optional arguments for entry processor. * @param syncMode Cache write synchronization mode. * @param topVer Topology version. + * @param keepBinary Keep binary flag. + * @param skipStore Skip store flag. * @param forceTransformBackups Force transform backups flag. * @param subjId Subject ID. * @param taskNameHash Task name hash code. @@ -333,11 +335,6 @@ public class GridDhtAtomicUpdateRequest extends GridDhtAtomicAbstractUpdateReque } /** {@inheritDoc} */ - @Override public AffinityTopologyVersion topologyVersion() { - return topVer; - } - - /** {@inheritDoc} */ @Override public int size() { return keys.size(); }