(pulsar) branch branch-3.0 updated: [improve][broker]Reuse method getAvailableBrokersAsync (#23099)

[technoboy]

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

technoboy pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 2add3abbe7d [improve][broker]Reuse method getAvailableBrokersAsync 
(#23099)
2add3abbe7d is described below

commit 2add3abbe7ddb4443b245f85b1c4cae0e2d30915
Author: crossoverJie <crossover...@gmail.com>
AuthorDate: Wed Jul 31 14:10:40 2024 +0800

    [improve][broker]Reuse method getAvailableBrokersAsync (#23099)
---
 .../apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
index b5c4de9e5a2..72300f3d857 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
@@ -366,8 +366,7 @@ public class ModularLoadManagerImpl implements 
ModularLoadManager {
     @Override
     public Set<String> getAvailableBrokers() {
         try {
-            return new 
HashSet<>(brokersData.listLocks(LoadManager.LOADBALANCE_BROKERS_ROOT)
-                    .get(conf.getMetadataStoreOperationTimeoutSeconds(), 
TimeUnit.SECONDS));
+            return 
getAvailableBrokersAsync().get(conf.getMetadataStoreOperationTimeoutSeconds(), 
TimeUnit.SECONDS);
         } catch (Exception e) {
             log.warn("Error when trying to get active brokers", e);
             return loadData.getBrokerData().keySet();