ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [12/42] incubator-ignite git commit: #ignite-743: IsolatedUpdater should wait cache started.
Date Mon, 20 Apr 2015 06:43:34 GMT
#ignite-743: IsolatedUpdater should wait cache started.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/ecf963e4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/ecf963e4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/ecf963e4

Branch: refs/heads/ignite-gg-9613
Commit: ecf963e4de1cc508d213170802515a20d7543396
Parents: 8ee275f
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Wed Apr 15 14:54:48 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Wed Apr 15 14:54:48 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/datastreamer/DataStreamerImpl.java    | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ecf963e4/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
index 83fb3cb..0486bed 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
@@ -1375,6 +1375,13 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K,
V>, Delayed
             Collection<Map.Entry<KeyCacheObject, CacheObject>> entries) {
             IgniteCacheProxyLockFree<KeyCacheObject, CacheObject> proxy = (IgniteCacheProxyLockFree<KeyCacheObject,
CacheObject>)cache;
 
+            try {
+                proxy.context().awaitStarted();
+            }
+            catch (IgniteCheckedException e) {
+                U.convertException(e);
+            }
+
             GridCacheAdapter<KeyCacheObject, CacheObject> internalCache = proxy.context().cache();
 
             if (internalCache.isNear())


Mime
View raw message