From cc815d4e7620022c7849a1ea1787f11e3b250c9d Mon Sep 17 00:00:00 2001 From: Shivansh Arora Date: Tue, 3 Sep 2024 20:04:25 +0530 Subject: [PATCH] Release latch listeners in case of no-op RoutingTableService Signed-off-by: Shivansh Arora --- .../routing/remote/NoopRemoteRoutingTableService.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server/src/main/java/org/opensearch/cluster/routing/remote/NoopRemoteRoutingTableService.java b/server/src/main/java/org/opensearch/cluster/routing/remote/NoopRemoteRoutingTableService.java index 17687199c39d6..4eb641bf3a0d7 100644 --- a/server/src/main/java/org/opensearch/cluster/routing/remote/NoopRemoteRoutingTableService.java +++ b/server/src/main/java/org/opensearch/cluster/routing/remote/NoopRemoteRoutingTableService.java @@ -43,7 +43,7 @@ public void getAsyncIndexRoutingWriteAction( IndexRoutingTable indexRouting, LatchedActionListener latchedActionListener ) { - // noop + latchedActionListener.onResponse(null); } @Override @@ -54,7 +54,7 @@ public void getAsyncIndexRoutingDiffWriteAction( StringKeyDiffProvider routingTableDiff, LatchedActionListener latchedActionListener ) { - // noop + latchedActionListener.onResponse(null); } @Override @@ -73,7 +73,7 @@ public void getAsyncIndexRoutingReadAction( String uploadedFilename, LatchedActionListener latchedActionListener ) { - // noop + latchedActionListener.onResponse(null); } @Override @@ -82,7 +82,7 @@ public void getAsyncIndexRoutingTableDiffReadAction( String uploadedFilename, LatchedActionListener> latchedActionListener ) { - // noop + latchedActionListener.onResponse(null); } @Override