ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject [25/36] ignite git commit: IGNITE-426 Fixed tests.
Date Wed, 04 Nov 2015 14:11:08 GMT
IGNITE-426 Fixed tests.


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

Branch: refs/heads/ignite-462-2
Commit: 4ab5d50833de25a3568b21fea207b3523a56b8ed
Parents: c3b28ee
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Tue Nov 3 15:31:05 2015 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Wed Nov 4 17:02:50 2015 +0300

----------------------------------------------------------------------
 .../processors/continuous/GridContinuousProcessor.java | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/4ab5d508/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
index 9a8ced3..db9b714 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java
@@ -889,10 +889,17 @@ public class GridContinuousProcessor extends GridProcessorAdapter {
             }
         }
 
-        if (ctx.cache() != null && ctx.cache().internalCache(hnd.cacheName()) !=
null) {
-            Map<Integer, Long> idx = ctx.cache().internalCache(hnd.cacheName()).context().topology().updateCounters();
+        try {
+            if (ctx.cache() != null && ctx.cache().internalCache(hnd.cacheName())
!= null) {
+                Map<Integer, Long> idx = ctx.cache().internalCache(hnd.cacheName())
+                    .context().topology().updateCounters();
 
-            req.addUpdateIdxs(idx);
+                req.addUpdateIdxs(idx);
+            }
+        }
+        catch (Exception e) {
+            if (log.isDebugEnabled())
+                log.warning("Failed to load partition counters.", e);
         }
 
         if (err != null)


Mime
View raw message