ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [03/50] [abbrv] ignite git commit: IGNITE-3477 - Reverted partition evict
Date Fri, 14 Apr 2017 06:28:25 GMT
IGNITE-3477 - Reverted partition evict


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2a6afe52
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2a6afe52
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2a6afe52

Branch: refs/heads/master
Commit: 2a6afe5286b105e5e45097391f78e85ec2cd1fde
Parents: b62d446
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Tue Apr 11 15:09:32 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Committed: Tue Apr 11 15:09:32 2017 +0300

----------------------------------------------------------------------
 .../cache/distributed/dht/GridDhtLocalPartition.java          | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/2a6afe52/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
index e8489e2..dbd1948 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
@@ -458,7 +458,12 @@ public class GridDhtLocalPartition extends GridCacheConcurrentMapImpl
implements
                 if (reservations == 0 && shouldBeRenting)
                     rent(true);
 
-                tryEvictAsync(false);
+                try {
+                    tryEvict();
+                }
+                catch (NodeStoppingException ignore) {
+                    // Node is stopping.
+                }
 
                 break;
             }


Mime
View raw message