[ignite] branch master updated: IGNITE-5214 Prevent concurrent access to pendingEvts when debug is on - Fixes #7874.

[ilyak]

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 <ilya.kasnach...@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 <ilya.kasnach...@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;