Don't set IgniteLock as broken if lock is failoverSafe
@@ -1151,11 +1151,11 @@ public final class GridCacheLockImpl implements GridCacheLockEx, IgniteChangeGlo
try {
if (nodeId.equals(sync.getOwnerNode())) {
+ if (!sync.failoverSafe) {
sync.setBroken(true);
-
- if (!sync.failoverSafe)
sync.interruptAll();
}
+ }
// Try to notify any waiting threads.
sync.release(0);
@@ -1173,7 +1173,9 @@ public final class GridCacheLockImpl implements GridCacheLockEx, IgniteChangeGlo
return;
}
+ if (!sync.failoverSafe) {
sync.setBroken(true);
+ }
sync.interruptAll();
