You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by il...@apache.org on 2020/06/02 16:14:04 UTC
[ignite] branch master updated: IGNITE-5214 Prevent concurrent
access to pendingEvts when debug is on - Fixes #7874.
This is an automated email from the ASF dual-hosted git repository.
ilyak pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 8e5f779 IGNITE-5214 Prevent concurrent access to pendingEvts when debug is on - Fixes #7874.
8e5f779 is described below
commit 8e5f7797320a309ef84e7e9c2e9f43a94226ba30
Author: Ilya Kasnacheev <il...@gmail.com>
AuthorDate: Tue Jun 2 19:13:35 2020 +0300
IGNITE-5214 Prevent concurrent access to pendingEvts when debug is on - Fixes #7874.
Signed-off-by: Ilya Kasnacheev <il...@gmail.com>
---
.../CacheContinuousQueryPartitionRecovery.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java
index ac319b4..ed96727 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java
@@ -251,15 +251,15 @@ class CacheContinuousQueryPartitionRecovery {
if (skippedFiltered)
pendingEvts.headMap(lastFiredEvt).clear();
}
- }
- 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;