This is an automated email from the ASF dual-hosted git repository. dsmiley pushed a commit to branch branch_9x in repository https://gitbox.apache.org/repos/asf/solr.git
commit f54d272b4d35dd130817598b41adf7c5211a7856 Author: David Smiley <[email protected]> AuthorDate: Tue Sep 8 11:35:32 2026 -0400 DistributedUpdateProcessor: expose isLeader, setupRequest (#4878) (cherry picked from commit 3e12f16c15ed637fb539214ddb9ce41130c699b2) (cherry picked from commit 21e8d021e780b764d8b3668f43bf98247f29ebf2) --- .../solr/update/processor/DistributedUpdateProcessor.java | 11 +++++++---- .../solr/update/processor/DistributedZkUpdateProcessor.java | 2 +- 2 files changed, 8 insertions(+), 5 deletions(-) diff --git a/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java b/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java index 3485e3d9e17..5ebb1d0f3dd 100644 --- a/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java +++ b/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java @@ -214,7 +214,7 @@ public class DistributedUpdateProcessor extends UpdateRequestProcessor { return Replica.Type.NRT; } - boolean isLeader() { + public boolean isLeader() { return isLeader; } @@ -995,9 +995,12 @@ public class DistributedUpdateProcessor extends UpdateRequestProcessor { } } - // internal helper method to setup request by processors who use this class. - // NOTE: not called by this class! - void setupRequest(UpdateCommand cmd) { + /** + * Set up / initialize. Exposed for other processors to determine {@link #isLeader()} afterward. + * + * @lucene.internal + */ + public void setupRequest(UpdateCommand cmd) { isLeader = getNonZkLeaderAssumption(req); } diff --git a/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java b/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java index 39724447530..19c04ed8aad 100644 --- a/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java +++ b/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java @@ -678,7 +678,7 @@ public class DistributedZkUpdateProcessor extends DistributedUpdateProcessor { } @Override - void setupRequest(UpdateCommand cmd) { + public void setupRequest(UpdateCommand cmd) { zkCheck(cmd); if (cmd instanceof AddUpdateCommand) { AddUpdateCommand acmd = (AddUpdateCommand) cmd;
