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 <[email protected]> Authored: Mon Jan 9 14:40:07 2017 +0300 Committer: sboikov <[email protected]> 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) {
