You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/09/08 14:45:47 UTC
[05/50] ignite git commit: wip
wip
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fdae22b0
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fdae22b0
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fdae22b0
Branch: refs/heads/ignite-3199-1
Commit: fdae22b01c6ef44f09a41a6e5417debe58e6ff92
Parents: ae4a4a1
Author: Pavel Tupitsyn <pt...@apache.org>
Authored: Mon Sep 5 16:37:18 2016 +0300
Committer: Pavel Tupitsyn <pt...@apache.org>
Committed: Mon Sep 5 16:37:18 2016 +0300
----------------------------------------------------------------------
.../internal/processors/platform/cache/PlatformCache.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fdae22b0/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
index 4bf82e8..e4bf9ab 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
@@ -51,6 +51,8 @@ import org.apache.ignite.internal.processors.platform.utils.PlatformUtils;
import org.apache.ignite.internal.processors.platform.utils.PlatformWriterClosure;
import org.apache.ignite.internal.processors.platform.websession.LockEntryProcessor;
import org.apache.ignite.internal.processors.platform.websession.LockInfo;
+import org.apache.ignite.internal.processors.platform.websession.SessionStateData;
+import org.apache.ignite.internal.processors.platform.websession.SetAndUnlockEntryProcessor;
import org.apache.ignite.internal.processors.platform.websession.UnlockEntryProcessor;
import org.apache.ignite.internal.util.GridConcurrentFactory;
import org.apache.ignite.internal.util.future.IgniteFutureImpl;
@@ -486,7 +488,11 @@ public class PlatformCache extends PlatformAbstractTarget {
}
case OP_INVOKE_INTERNAL_SESSION_SET_AND_UNLOCK:
- break;
+ SessionStateData data = (SessionStateData)args[1];
+
+ cache.invoke(key, new SetAndUnlockEntryProcessor(), data);
+
+ return FALSE;
}
return writeResult(mem, null);