[ISSUE #4072] fix totalPollingNum count error (#4073)

Signed-off-by: zhangyang <Git_Yang@163.com>
2026-09-24 16:04:00 +08:00 · 2022-05-06 09:28:25 +08:00
parent d937c1d615
commit e55db10c60
1 changed files with 1 additions and 0 deletions
@@ -176,6 +176,7 @@ public class PopMessageProcessor implements NettyRequestProcessor {
        PopRequest popRequest = remotingCommands.pollFirst();
        //clean inactive channel
        while (popRequest != null && !popRequest.getChannel().isActive()) {
+            totalPollingNum.decrementAndGet();
            popRequest = remotingCommands.pollFirst();
        }