(ignite) branch master updated: IGNITE-22216 Remove unused check for allPages in GridCacheQueryManager#runAll (#11356)

[timoninmaxim]

This is an automated email from the ASF dual-hosted git repository.

timoninmaxim 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 91521a6b58c IGNITE-22216 Remove unused check for allPages in 
GridCacheQueryManager#runAll (#11356)
91521a6b58c is described below

commit 91521a6b58c658f587a104aaf4ed2e182c8728ff
Author: oleg-vlsk <153691984+oleg-v...@users.noreply.github.com>
AuthorDate: Fri Jul 5 19:46:50 2024 +1000

    IGNITE-22216 Remove unused check for allPages in 
GridCacheQueryManager#runAll (#11356)
---
 .../processors/cache/query/GridCacheQueryManager.java       | 13 +------------
 1 file changed, 1 insertion(+), 12 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
index ef6686253f6..48a0aaa2006 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
@@ -1162,13 +1162,10 @@ public abstract class GridCacheQueryManager<K, V> 
extends GridCacheManagerAdapte
 
                 int cnt = 0;
 
-                boolean stop = false;
                 boolean pageSent = false;
 
                 Collection<Object> data = new ArrayList<>(pageSize);
 
-                AffinityTopologyVersion topVer = 
cctx.affinity().affinityTopologyVersion();
-
                 final boolean statsEnabled = cctx.statisticsEnabled();
 
                 final boolean readEvt = 
cctx.events().isRecordable(EVT_CACHE_QUERY_OBJECT_READ);
@@ -1289,20 +1286,12 @@ public abstract class GridCacheQueryManager<K, V> 
extends GridCacheManagerAdapte
 
                             onPageReady(loc, qryInfo, res.metadata(), data, 
finished, null);
 
-                            pageSent = true;
-
                             res.onPageSend();
 
                             if (!finished)
                                 rmvIter = false;
 
-                            if (!qryInfo.allPages())
-                                return;
-
-                            data = new ArrayList<>(pageSize);
-
-                            if (stop)
-                                break; // while
+                            return;
                         }
                     }
                 }