Repository: ignite Updated Branches: refs/heads/ignite-6149 5e886653c -> 0feca3163
ignite-6149 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0feca316 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0feca316 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0feca316 Branch: refs/heads/ignite-6149 Commit: 0feca31637feae8ed37dd5d2f53112e3df0c8c00 Parents: 5e88665 Author: sboikov <[email protected]> Authored: Fri Sep 15 12:10:04 2017 +0300 Committer: sboikov <[email protected]> Committed: Fri Sep 15 12:10:36 2017 +0300 ---------------------------------------------------------------------- .../processors/cache/mvcc/CoordinatorFutureResponse.java | 5 +++++ .../processors/cache/mvcc/CoordinatorQueryAckRequest.java | 5 +++++ .../processors/cache/mvcc/CoordinatorQueryVersionRequest.java | 5 +++++ .../processors/cache/mvcc/CoordinatorTxAckRequest.java | 5 +++++ .../processors/cache/mvcc/CoordinatorTxCounterRequest.java | 5 +++++ .../processors/cache/mvcc/CoordinatorWaitTxsRequest.java | 5 +++++ .../processors/cache/mvcc/MvccCoordinatorMessage.java | 2 ++ .../processors/cache/mvcc/MvccCoordinatorVersionResponse.java | 7 ++++++- 8 files changed, 38 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorFutureResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorFutureResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorFutureResponse.java index 4033733..3bea674 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorFutureResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorFutureResponse.java @@ -57,6 +57,11 @@ public class CoordinatorFutureResponse implements MvccCoordinatorMessage { } /** {@inheritDoc} */ + @Override public boolean processedOnCoordinator() { + return false; + } + + /** {@inheritDoc} */ @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryAckRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryAckRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryAckRequest.java index 96c0ee6..bf7eea1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryAckRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryAckRequest.java @@ -52,6 +52,11 @@ public class CoordinatorQueryAckRequest implements MvccCoordinatorMessage { return false; } + /** {@inheritDoc} */ + @Override public boolean processedOnCoordinator() { + return true; + } + /** * @return Counter. */ http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryVersionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryVersionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryVersionRequest.java index f329cd4..7229e3a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryVersionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorQueryVersionRequest.java @@ -52,6 +52,11 @@ public class CoordinatorQueryVersionRequest implements MvccCoordinatorMessage { return true; } + /** {@inheritDoc} */ + @Override public boolean processedOnCoordinator() { + return true; + } + /** * @return Future ID. */ http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxAckRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxAckRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxAckRequest.java index 6256880..cdc9c02 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxAckRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxAckRequest.java @@ -64,6 +64,11 @@ public class CoordinatorTxAckRequest implements MvccCoordinatorMessage { return false; } + /** {@inheritDoc} */ + @Override public boolean processedOnCoordinator() { + return true; + } + /** * @return Future ID. */ http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxCounterRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxCounterRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxCounterRequest.java index 6073042..4b48c12 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxCounterRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorTxCounterRequest.java @@ -60,6 +60,11 @@ public class CoordinatorTxCounterRequest implements MvccCoordinatorMessage { return true; } + /** {@inheritDoc} */ + @Override public boolean processedOnCoordinator() { + return true; + } + /** * @return Future ID. */ http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorWaitTxsRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorWaitTxsRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorWaitTxsRequest.java index e66e2b9..f87a8ff 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorWaitTxsRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CoordinatorWaitTxsRequest.java @@ -71,6 +71,11 @@ public class CoordinatorWaitTxsRequest implements MvccCoordinatorMessage { } /** {@inheritDoc} */ + @Override public boolean processedOnCoordinator() { + return true; + } + + /** {@inheritDoc} */ @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) { writer.setBuffer(buf); http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorMessage.java index ed761ca..1e11ac1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorMessage.java @@ -24,4 +24,6 @@ import org.apache.ignite.plugin.extensions.communication.Message; */ public interface MvccCoordinatorMessage extends Message { public boolean waitForCoordinatorInit(); + + public boolean processedOnCoordinator(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/0feca316/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorVersionResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorVersionResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorVersionResponse.java index 623f897..15c9005 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorVersionResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/MvccCoordinatorVersionResponse.java @@ -57,7 +57,7 @@ public class MvccCoordinatorVersionResponse implements MvccCoordinatorMessage, M * @param cntr Counter. * @param futId Future ID. */ - MvccCoordinatorVersionResponse(long futId, long crdVer, long cntr, GridLongList txs, long cleanupVer) { + public MvccCoordinatorVersionResponse(long futId, long crdVer, long cntr, GridLongList txs, long cleanupVer) { this.futId = futId; this.crdVer = crdVer; this.cntr = cntr; @@ -70,6 +70,11 @@ public class MvccCoordinatorVersionResponse implements MvccCoordinatorMessage, M return false; } + /** {@inheritDoc} */ + @Override public boolean processedOnCoordinator() { + return false; + } + /** * @return Future ID. */
