ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # ignite-648: fix async support
Date Wed, 13 May 2015 18:53:35 GMT
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 <ashutak@gridgain.com>
Authored: Wed May 13 21:54:03 2015 +0300
Committer: Artem Shutak <ashutak@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} */


Mime
View raw message