[ISSUE #6246] Optimize AcceptSocketService#run

apache · Mar 5, 2023 · ce99a7f · ce99a7f
1 parent 44a1694
commit ce99a7f
Showing 1 changed file with 1 addition and 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
@@ -342,7 +342,7 @@ public void run() {
 
                     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) {