From 217a8f86af9462da7426d239f0a25a400491bec0 Mon Sep 17 00:00:00 2001
From: mxsm <mxsm@apache.org>
Date: Sun, 24 Nov 2024 22:23:43 +0800
Subject: [PATCH] =?UTF-8?q?[ISSUE=20#1279]=E2=9A=A1=EF=B8=8FOptimize=20nam?=
 =?UTF-8?q?e=20server=20DefaultRequestProcessor#get=5Fall=5Ftopic=5Flist?=
 =?UTF-8?q?=5Ffrom=5Fnameserver?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rocketmq-namesrv/src/route/route_info_manager.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/rocketmq-namesrv/src/route/route_info_manager.rs b/rocketmq-namesrv/src/route/route_info_manager.rs
index ade1849a..7b9d6bfe 100644
--- a/rocketmq-namesrv/src/route/route_info_manager.rs
+++ b/rocketmq-namesrv/src/route/route_info_manager.rs
@@ -721,12 +721,13 @@ impl RouteInfoManager {
     }
 
     pub(crate) fn get_all_topic_list(&self) -> TopicList {
+        let lock = self.lock.read();
         let topics = self
             .topic_queue_table
             .keys()
             .cloned()
             .collect::<Vec<CheetahString>>();
-
+        drop(lock);
         TopicList {
             topic_list: topics,
             broker_addr: None,