[pulsar] branch master updated: [fix] [doc] Fix outdated java-doc of rate limiter (#19014)

[zike]

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

zike 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 81971e2d91a [fix] [doc] Fix outdated java-doc of rate limiter (#19014)
81971e2d91a is described below

commit 81971e2d91a18ac7aac245c36ce082cd3b8176ad
Author: fengyubiao <yubiao.f...@streamnative.io>
AuthorDate: Tue Apr 11 14:50:08 2023 +0800

    [fix] [doc] Fix outdated java-doc of rate limiter (#19014)
    
    ### Motivation
    After PR #8611, the acquiring permits can be larger than configured 
msg-rate if used by subscribing. But doc was not updated in time.
    
    ### Modifications
    
    fix the outdated doc
---
 .../apache/pulsar/broker/service/persistent/DispatchRateLimiter.java    | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
index 5b8987580c4..b1e48035484 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java
@@ -99,10 +99,8 @@ public class DispatchRateLimiter {
      */
     public boolean tryDispatchPermit(long msgPermits, long bytePermits) {
         boolean acquiredMsgPermit = msgPermits <= 0 || 
dispatchRateLimiterOnMessage == null
-        // acquiring permits must be < configured msg-rate;
                 || dispatchRateLimiterOnMessage.tryAcquire(msgPermits);
         boolean acquiredBytePermit = bytePermits <= 0 || 
dispatchRateLimiterOnByte == null
-        // acquiring permits must be < configured msg-rate;
                 || dispatchRateLimiterOnByte.tryAcquire(bytePermits);
         return acquiredMsgPermit && acquiredBytePermit;
     }