You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2015/04/11 18:53:38 UTC
[03/11] incubator-ignite git commit: # ignite-sprint-3 added
ignoreInterrupts for GridDhtColocatedLockFuture (like in
GridDhtColocatedLockFuture)
# ignite-sprint-3 added ignoreInterrupts for GridDhtColocatedLockFuture (like in GridDhtColocatedLockFuture)
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d333feb6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d333feb6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d333feb6
Branch: refs/heads/ignite-721
Commit: d333feb6bf4a540b63027fe3a67fc2d795c3ed7d
Parents: 8cf590e
Author: sboikov <se...@inria.fr>
Authored: Sat Apr 11 12:30:10 2015 +0300
Committer: sboikov <se...@inria.fr>
Committed: Sat Apr 11 12:30:10 2015 +0300
----------------------------------------------------------------------
.../internal/processors/cache/local/GridLocalLockFuture.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d333feb6/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/GridLocalLockFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/GridLocalLockFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/GridLocalLockFuture.java
index a6aac64..340eb07 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/GridLocalLockFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/GridLocalLockFuture.java
@@ -111,6 +111,8 @@ public final class GridLocalLockFuture<K, V> extends GridFutureAdapter<Boolean>
this.filter = filter;
this.tx = tx;
+ ignoreInterrupts(true);
+
threadId = tx == null ? Thread.currentThread().getId() : tx.threadId();
lockVer = tx != null ? tx.xidVersion() : cctx.versions().next();