You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by av...@apache.org on 2017/05/31 12:27:59 UTC

[13/27] ignite git commit: IGNITE-4939 Receive event before cache initialized fix

IGNITE-4939 Receive event before cache initialized fix


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

Branch: refs/heads/ignite-5232-1.7.2
Commit: 45b4d6316145d0b4b46713409f5e8fbe55ff4c41
Parents: f66c23c
Author: Evgenii Zhuravlev <ez...@gridgain.com>
Authored: Thu May 4 12:11:37 2017 +0300
Committer: Evgenii Zhuravlev <ez...@gridgain.com>
Committed: Thu May 4 12:13:22 2017 +0300

----------------------------------------------------------------------
 .../ignite/internal/processors/cache/GridCacheProcessor.java     | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/45b4d631/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
index 5a54e53..ccd7ae0 100755
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
@@ -3352,9 +3352,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
      */
     @SuppressWarnings("unchecked")
     public <K, V> IgniteCacheProxy<K, V> safeJcache(String name, int id) {
-        assert name != null;
-
-        IgniteCacheProxy<K, V> cache = (IgniteCacheProxy<K, V>)jCacheProxies.get(name);
+        IgniteCacheProxy<K, V> cache = (IgniteCacheProxy<K, V>)jCacheProxies.get(maskNull(name));
 
         if (cache == null)
             if (cacheDescriptor(id) != null && CU.isSystemCache(name))