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:28:02 UTC
[16/27] ignite git commit: Fixed "IGNITE-5214
ConcurrentModificationException with enable DEBUG log level"
Fixed "IGNITE-5214 ConcurrentModificationException with enable DEBUG log level"
Signed-off-by: nikolay_tikhonov <nt...@gridgain.com>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/987c1826
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/987c1826
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/987c1826
Branch: refs/heads/ignite-5232-1.7.2
Commit: 987c182686962673e70398395cb27e94f894713b
Parents: 25c06b5
Author: nikolay_tikhonov <nt...@gridgain.com>
Authored: Mon May 15 11:54:16 2017 +0300
Committer: nikolay_tikhonov <nt...@gridgain.com>
Committed: Mon May 15 11:54:16 2017 +0300
----------------------------------------------------------------------
.../continuous/CacheContinuousQueryHandler.java | 17 +++++++++--------
1 file changed, 9 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/987c1826/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
index 1a6577d..5f00d58 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
@@ -998,6 +998,7 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
synchronized (pendingEvts) {
if (log.isDebugEnabled()) {
+
log.debug("Handling event [lastFiredEvt=" + lastFiredEvt +
", curTop=" + curTop +
", entUpdCnt=" + entry.updateCounter() +
@@ -1126,15 +1127,15 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
break;
}
}
- }
- if (log.isDebugEnabled()) {
- log.debug("Will send to listener the following events [entries=" + entries +
- ", lastFiredEvt=" + lastFiredEvt +
- ", curTop=" + curTop +
- ", entUpdCnt=" + entry.updateCounter() +
- ", partId=" + entry.partition() +
- ", pendingEvts=" + pendingEvts + ']');
+ if (log.isDebugEnabled()) {
+ log.debug("Will send to listener the following events [entries=" + entries +
+ ", lastFiredEvt=" + lastFiredEvt +
+ ", curTop=" + curTop +
+ ", entUpdCnt=" + entry.updateCounter() +
+ ", partId=" + entry.partition() +
+ ", pendingEvts=" + pendingEvts + ']');
+ }
}
return entries;