[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 · Dec 12, 2022 · 9917aac · 9917aac
1 parent bdbb118
commit 9917aac
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java b/...broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java
@@ -64,6 +64,7 @@ public long getIndex() {
         for (BrokerEntryMetadataInterceptor interceptor : brokerEntryMetadataInterceptors) {
             if (interceptor instanceof AppendIndexMetadataInterceptor) {
                 index = ((AppendIndexMetadataInterceptor) interceptor).getIndex();
+                break;
             }
         }
         return index;
@@ -89,6 +90,7 @@ public void onManagedLedgerPropertiesInitialize(Map<String, String> propertiesMa
                 if (interceptor instanceof AppendIndexMetadataInterceptor) {
                   ((AppendIndexMetadataInterceptor) interceptor)
                           .recoveryIndexGenerator(Long.parseLong(propertiesMap.get(INDEX)));
+                  break;
                 }
             }
         }
@@ -117,6 +119,7 @@ public CompletableFuture<Void> onManagedLedgerLastLedgerInitialize(String name,
                                             ((AppendIndexMetadataInterceptor) interceptor)
                                                     .recoveryIndexGenerator(brokerEntryMetadata.getIndex());
                                         }
+                                        break;
                                     }
                                 }
                             }
@@ -144,6 +147,7 @@ public void onUpdateManagedLedgerInfo(Map<String, String> propertiesMap) {
         for (BrokerEntryMetadataInterceptor interceptor : brokerEntryMetadataInterceptors) {
             if (interceptor instanceof AppendIndexMetadataInterceptor) {
                 propertiesMap.put(INDEX, String.valueOf(((AppendIndexMetadataInterceptor) interceptor).getIndex()));
+                break;
             }
         }
     }