You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/01/09 11:40:52 UTC
ignite git commit: Try fix hang in
GridDhtPartitionTopologyImpl.waitForRent on node stop.
Repository: ignite
Updated Branches:
refs/heads/ignite-3477 d44df8fb0 -> 620b81521
Try fix hang in GridDhtPartitionTopologyImpl.waitForRent on node stop.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/620b8152
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/620b8152
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/620b8152
Branch: refs/heads/ignite-3477
Commit: 620b81521f57e46d4fc4432e29e7e3ad39c919e3
Parents: d44df8f
Author: sboikov <sb...@gridgain.com>
Authored: Mon Jan 9 14:40:07 2017 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Mon Jan 9 14:40:07 2017 +0300
----------------------------------------------------------------------
.../processors/cache/distributed/dht/GridDhtLocalPartition.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/620b8152/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 6bddb6b..1b913a3 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
@@ -914,6 +914,8 @@ public class GridDhtLocalPartition implements Comparable<GridDhtLocalPartition>,
if (log.isDebugEnabled())
log.debug("Failed to clear cache entry for evicted partition: " + cached.partition());
+ rent.onDone(e);
+
throw e;
}
catch (IgniteCheckedException e) {
@@ -969,6 +971,8 @@ public class GridDhtLocalPartition implements Comparable<GridDhtLocalPartition>,
if (log.isDebugEnabled())
log.debug("Failed to get iterator for evicted partition: " + id);
+ rent.onDone(e);
+
throw e;
}
catch (IgniteCheckedException e) {