[pulsar] branch master updated: [improve][broker] Fast return when AppendIndexMetadataInterceptor is matched. (#18884)

[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 9917aac2dfd [improve][broker] Fast return when 
AppendIndexMetadataInterceptor is matched. (#18884)
9917aac2dfd is described below

commit 9917aac2dfda8d3db64903a1cc5d951b21bc7d8a
Author: lixinyang <84127069+nicklee...@users.noreply.github.com>
AuthorDate: Mon Dec 12 21:27:41 2022 +0800

    [improve][broker] Fast return when AppendIndexMetadataInterceptor is 
matched. (#18884)
    
    ### Motivation
    
    Optimize the method, fast return when AppendIndexMetadataInterceptor is 
matched.
    
    ### Modifications
    
    1. Fast return when when AppendIndexMetadataInterceptor is matched.
---
 .../apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java
index bcc4a0754ad..e3b94ec94a4 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java
@@ -64,6 +64,7 @@ public class ManagedLedgerInterceptorImpl implements 
ManagedLedgerInterceptor {
         for (BrokerEntryMetadataInterceptor interceptor : 
brokerEntryMetadataInterceptors) {
             if (interceptor instanceof AppendIndexMetadataInterceptor) {
                 index = ((AppendIndexMetadataInterceptor) 
interceptor).getIndex();
+                break;
             }
         }
         return index;
@@ -89,6 +90,7 @@ public class ManagedLedgerInterceptorImpl implements 
ManagedLedgerInterceptor {
                 if (interceptor instanceof AppendIndexMetadataInterceptor) {
                   ((AppendIndexMetadataInterceptor) interceptor)
                           
.recoveryIndexGenerator(Long.parseLong(propertiesMap.get(INDEX)));
+                  break;
                 }
             }
         }
@@ -117,6 +119,7 @@ public class ManagedLedgerInterceptorImpl implements 
ManagedLedgerInterceptor {
                                             ((AppendIndexMetadataInterceptor) 
interceptor)
                                                     
.recoveryIndexGenerator(brokerEntryMetadata.getIndex());
                                         }
+                                        break;
                                     }
                                 }
                             }
@@ -144,6 +147,7 @@ public class ManagedLedgerInterceptorImpl implements 
ManagedLedgerInterceptor {
         for (BrokerEntryMetadataInterceptor interceptor : 
brokerEntryMetadataInterceptors) {
             if (interceptor instanceof AppendIndexMetadataInterceptor) {
                 propertiesMap.put(INDEX, 
String.valueOf(((AppendIndexMetadataInterceptor) interceptor).getIndex()));
+                break;
             }
         }
     }