From ce99a7fe8a278b85ea016fdeea998e6e33e4cc73 Mon Sep 17 00:00:00 2001
From: hardyfish <85128645+hardyfish@users.noreply.github.com>
Date: Sun, 5 Mar 2023 11:21:44 +0800
Subject: [PATCH] [ISSUE #6246] Optimize AcceptSocketService#run

---
 .../java/org/apache/rocketmq/store/ha/DefaultHAService.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java b/store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java
index 98deb233f3..75e0afa4e8 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java
@@ -342,7 +342,7 @@ public class DefaultHAService implements HAService {
 
                     if (selected != null) {
                         for (SelectionKey k : selected) {
-                            if ((k.readyOps() & SelectionKey.OP_ACCEPT) != 0) {
+                            if (k.isAcceptable()) {
                                 SocketChannel sc = ((ServerSocketChannel) k.channel()).accept();
 
                                 if (sc != null) {