| commit | fd1d87b997c02e511731fcfd0c49d1ce5d0af2e6 | [log] [tgz] |
|---|---|---|
| author | Evgenii Zhuravlev <ezhuravlev@gridgain.com> | Mon May 29 16:46:11 2017 +0300 |
| committer | Anton Vinogradov <av@apache.org> | Tue May 30 16:10:13 2017 +0300 |
| tree | 6d7851ac1afe7b3bade0064df59d036e01a4bbb5 | |
| parent | 8237ac6f6b8071dcb18b2a05a429e94cba22e71d [diff] |
IGNITE-5299 Don't set IgniteLock as broken if lock is failoverSafe
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheLockImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheLockImpl.java index 0192354..7bf55a3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheLockImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/GridCacheLockImpl.java
@@ -1151,10 +1151,10 @@ try { if (nodeId.equals(sync.getOwnerNode())) { - sync.setBroken(true); - - if (!sync.failoverSafe) + if (!sync.failoverSafe) { + sync.setBroken(true); sync.interruptAll(); + } } // Try to notify any waiting threads. @@ -1173,7 +1173,9 @@ return; } - sync.setBroken(true); + if (!sync.failoverSafe) { + sync.setBroken(true); + } sync.interruptAll();