Skip to content

Commit 93a3457

Browse files
committed
Revert visibility modifier of the RestCancellableNodeClient#getNumTasks
Signed-off-by: Sergei Ustimenko <[email protected]>
1 parent d91400a commit 93a3457

File tree

3 files changed

+1
-3
lines changed

3 files changed

+1
-3
lines changed

modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/Netty4HttpChannelsReleaseIntegTests.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,6 @@ public void testAcceptedChannelsGetCleanedUpOnTheNodeShutdown() throws Interrupt
6868

6969
// no channels get closed in this test, hence we expect as many channels as we created in the map
7070
assertEquals("All channels remain open", initialHttpChannels + numChannels, RestCancellableNodeClient.getNumChannels());
71-
assertEquals(0, RestCancellableNodeClient.getNumTasks());
7271
}
7372

7473
/**

plugins/transport-reactor-netty4/src/internalClusterTest/java/org/opensearch/http/reactor/netty4/ReactorNetty4HttpChannelsReleaseIntegTests.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,6 @@ public void testAcceptedChannelsGetCleanedUpOnTheNodeShutdown() throws Interrupt
6868

6969
// no channels get closed in this test, hence we expect as many channels as we created in the map
7070
assertEquals("All channels remain open", initialHttpChannels + numChannels, RestCancellableNodeClient.getNumChannels());
71-
assertEquals(0, RestCancellableNodeClient.getNumTasks());
7271
}
7372

7473
/**

server/src/main/java/org/opensearch/rest/action/RestCancellableNodeClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ public static int getNumChannels() {
8383
/**
8484
* Returns the number of tasks tracked globally.
8585
*/
86-
public static int getNumTasks() {
86+
static int getNumTasks() {
8787
return httpChannels.values().stream().mapToInt(CloseListener::getNumTasks).sum();
8888
}
8989

0 commit comments

Comments
 (0)