cleanup code

Signed-off-by: tmanninger <t.manninger@ixolit.com>
opensearch-project · Sep 27, 2024 · 732d091 · 732d091
1 parent f7b4ddd
commit 732d091
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/server/src/main/java/org/opensearch/http/AbstractHttpServerTransport.java b/server/src/main/java/org/opensearch/http/AbstractHttpServerTransport.java
@@ -259,10 +259,8 @@ protected void doStop() {
                 }
             }
             final long startTimeMillis = System.currentTimeMillis();
-            boolean closedAll = false;
             while (System.currentTimeMillis() - startTimeMillis < gracefulShutdownMillis) {
                 if (httpChannels.isEmpty()) {
-                    closedAll = true;
                     break;
                 }
                 try {
@@ -272,7 +270,7 @@ protected void doStop() {
                 }
             }
 
-            if (!closedAll) {
+            if (!httpChannels.isEmpty()) {
                 logger.info("Timeout reached, {} connections not closed gracefully.", httpChannels.size());
             } else {
                 logger.info("Closed all connections gracefully.");