You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/02/03 03:05:23 UTC

[09/44] incubator-ignite git commit: #IGNITE-86: wip

#IGNITE-86:  wip


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

Branch: refs/heads/ignite-82
Commit: 958401d8c3824f8c8d0ef7dbd22c30b7e95ded2e
Parents: 42d94fe
Author: ivasilinets <iv...@gridgain.com>
Authored: Fri Jan 23 15:59:49 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Fri Jan 23 15:59:49 2015 +0300

----------------------------------------------------------------------
 .../kernal/processors/cache/GridCacheDeploymentManager.java     | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/958401d8/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheDeploymentManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheDeploymentManager.java b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheDeploymentManager.java
index 5d9759f..c3578b7 100644
--- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheDeploymentManager.java
+++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/GridCacheDeploymentManager.java
@@ -182,6 +182,11 @@ public class GridCacheDeploymentManager<K, V> extends GridCacheSharedManagerAdap
     public void unwind(GridCacheContext ctx) {
         int cnt = 0;
 
+        //TODO:
+        if (undeploys.get(ctx) == null) {
+            return;
+        }
+
         for (CA c = undeploys.get(ctx).poll(); c != null; c = undeploys.get(ctx).poll()) {
             c.apply();