You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/05/13 20:53:35 UTC
incubator-ignite git commit: # ignite-648: fix async support
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-648 5206cdac6 -> bb5dfcd78
# ignite-648: fix async support
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/bb5dfcd7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/bb5dfcd7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/bb5dfcd7
Branch: refs/heads/ignite-648
Commit: bb5dfcd78ea2ac8d138585412e9fd163daa86c3e
Parents: 5206cda
Author: Artem Shutak <as...@gridgain.com>
Authored: Wed May 13 21:54:03 2015 +0300
Committer: Artem Shutak <as...@gridgain.com>
Committed: Wed May 13 21:54:03 2015 +0300
----------------------------------------------------------------------
.../multijvm/framework/IgniteCacheProcessProxy.java | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/bb5dfcd7/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java
index 4abceeb..4c0e8d7 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/framework/IgniteCacheProcessProxy.java
@@ -221,8 +221,18 @@ public class IgniteCacheProcessProxy<K, V> implements IgniteCache<K, V> {
});
}
+ /**
+ * Returns cache instance. Method to be called from closure at another JVM.
+ *
+ * @return Cache.
+ */
private IgniteCache<Object, Object> cache() {
- return Ignition.ignite(gridId).cache(cacheName);
+ IgniteCache cache = Ignition.ignite(gridId).cache(cacheName);
+
+ if (isAsync)
+ cache = cache.withAsync();
+
+ return cache;
}
/** {@inheritDoc} */