[pulsar] branch master updated: [cleanup] [broker] when serverCnx.disabledAutoRead(), use same code (#15181)

[ji...@apache.org]

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

jianghaiting pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 5d563ac47aa [cleanup] [broker] when serverCnx.disabledAutoRead(), use same code (#15181)
5d563ac47aa is described below

commit 5d563ac47aa79634334cf899ab42040570d46f77
Author: fengyubiao <yu...@streamnative.io>
AuthorDate: Tue Jun 21 11:52:59 2022 +0800

    [cleanup] [broker] when serverCnx.disabledAutoRead(), use same code (#15181)
    
    Co-authored-by: fengyubiao <fe...@github.com>
---
 .../src/main/java/org/apache/pulsar/broker/service/ServerCnx.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
index 5edca60de94..5fc899dc5e9 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -2647,8 +2647,7 @@ public class ServerCnx extends PulsarHandler implements TransportCnx {
         if (++pendingSendRequest == maxPendingSendRequests || isPublishRateExceeded) {
             // When the quota of pending send requests is reached, stop reading from socket to cause backpressure on
             // client connection, possibly shared between multiple producers
-            ctx.channel().config().setAutoRead(false);
-            recordRateLimitMetrics(producers);
+            disableCnxAutoRead();
             autoReadDisabledRateLimiting = isPublishRateExceeded;
             throttledConnections.inc();
         }