You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by nt...@apache.org on 2015/11/03 13:31:10 UTC
[2/2] ignite git commit: IGNITE-426 Fixed tests.
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/2d053b25
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2d053b25
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2d053b25
Branch: refs/heads/ignite-426-2-reb
Commit: 2d053b2580173797bae0c8d179824e94314fcb6f
Parents: 5812d0e
Author: nikolay_tikhonov <nt...@gridgain.com>
Authored: Tue Nov 3 15:31:05 2015 +0300
Committer: nikolay_tikhonov <nt...@gridgain.com>
Committed: Tue Nov 3 15:31:05 2015 +0300
----------------------------------------------------------------------
.../processors/continuous/GridContinuousProcessor.java | 13 ++++++++++---
1 file changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2d053b25/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)