Repository: ignite Updated Branches: refs/heads/ignite-3479 7607029cc -> 6266d76ea
ignite-3479 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6266d76e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6266d76e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6266d76e Branch: refs/heads/ignite-3479 Commit: 6266d76ea08e4e0e558e1b72757690bca7952d38 Parents: 7607029 Author: sboikov <[email protected]> Authored: Thu Sep 28 14:19:31 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Sep 28 14:19:31 2017 +0300 ---------------------------------------------------------------------- .../processors/cache/mvcc/CacheCoordinatorsProcessor.java | 4 +++- .../processors/cache/mvcc/PreviousCoordinatorQueries.java | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/6266d76e/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsProcessor.java index b50b0a4..046032f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsProcessor.java @@ -1087,7 +1087,9 @@ public class CacheCoordinatorsProcessor extends GridProcessorAdapter { for (WaitAckFuture fut : ackFuts.values()) fut.onNodeLeft(nodeId); - prevCrdQueries.onNodeLeft(nodeId); + activeQueries.onNodeFailed(nodeId); + + prevCrdQueries.onNodeFailed(nodeId); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/6266d76e/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/PreviousCoordinatorQueries.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/PreviousCoordinatorQueries.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/PreviousCoordinatorQueries.java index 89d7746..0810b0f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/PreviousCoordinatorQueries.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/PreviousCoordinatorQueries.java @@ -147,7 +147,7 @@ class PreviousCoordinatorQueries { /** * @param nodeId Failed node ID. */ - void onNodeLeft(UUID nodeId) { + void onNodeFailed(UUID nodeId) { synchronized (this) { initDone = waitNodes != null && waitNodes.remove(nodeId);
