From 98b1af0b1c4b6e3d6c7497c2e40fa732c0684e9e Mon Sep 17 00:00:00 2001 From: Craig Perkins Date: Mon, 3 Apr 2023 09:11:15 -0400 Subject: [PATCH] Update java docstrings Signed-off-by: Craig Perkins --- .../org/opensearch/transport/TransportService.java | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/opensearch/transport/TransportService.java b/server/src/main/java/org/opensearch/transport/TransportService.java index d3c159db1d41f..2d1103a9a6685 100644 --- a/server/src/main/java/org/opensearch/transport/TransportService.java +++ b/server/src/main/java/org/opensearch/transport/TransportService.java @@ -470,7 +470,7 @@ public void connectToNode(final DiscoveryNode node, ConnectionProfile connection } /** - * Connect to the specified node with the given connection profile. + * Connect to the specified node as an extension with the given connection profile. * The ActionListener will be called on the calling thread or the generic thread pool. * * @param node the node to connect to @@ -488,7 +488,12 @@ public void connectToNodeAsExtension( listener.onResponse(null); return; } - connectionManager.connectToNode(node, connectionProfile, connectionValidatorForExtension(node, extensionUniqueId), listener); + connectionManager.connectToNode( + node, + connectionProfile, + connectionValidatorForExtensionConnectingToNode(node, extensionUniqueId), + listener + ); } public void connectToExtensionNode(final DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener listener) { @@ -514,7 +519,10 @@ public ConnectionManager.ConnectionValidator connectionValidator(DiscoveryNode n }; } - public ConnectionManager.ConnectionValidator connectionValidatorForExtension(DiscoveryNode node, String extensionUniqueId) { + public ConnectionManager.ConnectionValidator connectionValidatorForExtensionConnectingToNode( + DiscoveryNode node, + String extensionUniqueId + ) { return (newConnection, actualProfile, listener) -> { // We don't validate cluster names to allow for CCS connections. threadPool.getThreadContext().putHeader("extension_unique_id", extensionUniqueId);