ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-3479
Date Thu, 28 Sep 2017 11:19:35 GMT
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 <sboikov@gridgain.com>
Authored: Thu Sep 28 14:19:31 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
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);
 


Mime
View raw message