cleaning up comments/ logs, modified extensionsInitialized to be asyncronous since APIs will be utlizing the extensionsInitializedList to identify the correct node to send requests to. Since arraylists are not thread safe, this is achieved by adding countdown latches

Signed-off-by: Joshua Palis <jpalis@amazon.com>

Author: joshpalis

server/src/main/java/org/opensearch/extensions/ExtensionNamedWriteableRegistry.java

@@ -51,9 +51,6 @@ public ExtensionNamedWriteableRegistry(List<DiscoveryExtension> extensionsInitia
      * Iterates through all discovered extensions, sends transport requests for named writeables and consolidates all entires into a central named writeable registry for extensions.
      */
     public void getNamedWriteables() {
-
-        logger.info("Hit get Named Writeables");
-        logger.info("initialized extensions : " + extensionsInitializedList.toString());
         // Retrieve named writeable registry entries from each extension
         for (DiscoveryNode extensionNode : extensionsInitializedList) {
             try {
@@ -79,7 +76,6 @@ public void getNamedWriteables() {
      */
     private Map<DiscoveryNode, Map<Class, Map<String, ExtensionReader>>> getNamedWriteables(DiscoveryNode extensionNode)
         throws UnknownHostException {
-        logger.info("Inside get named writeables( discovery node)");
         NamedWriteableRegistryResponseHandler namedWriteableRegistryResponseHandler = new NamedWriteableRegistryResponseHandler(
             extensionNode,
             transportService,

server/src/main/java/org/opensearch/extensions/ExtensionsOrchestrator.java

@@ -228,7 +228,7 @@ public void extensionsInitialize() {
     }
 
     private void extensionInitialize(DiscoveryNode extensionNode) {
-
+        final CountDownLatch inProgressLatch = new CountDownLatch(1);
         final TransportResponseHandler<PluginResponse> pluginResponseHandler = new TransportResponseHandler<PluginResponse>() {
 
             @Override
@@ -244,11 +244,13 @@ public void handleResponse(PluginResponse response) {
                         break;
                     }
                 }
+                inProgressLatch.countDown();
             }
 
             @Override
             public void handleException(TransportException exp) {
                 logger.debug(new ParameterizedMessage("Plugin request failed"), exp);
+                inProgressLatch.countDown();
             }
 
             @Override
@@ -265,6 +267,7 @@ public String executor() {
                 new PluginRequest(transportService.getLocalNode(), new ArrayList<DiscoveryExtension>(extensionsList)),
                 pluginResponseHandler
             );
+            inProgressLatch.await(100, TimeUnit.SECONDS);
         } catch (Exception e) {
             logger.error(e.toString());
         }

server/src/main/java/org/opensearch/extensions/NamedWriteableRegistryResponseHandler.java

@@ -104,7 +104,6 @@ public void handleResponse(NamedWriteableRegistryResponse response) {
             Map<String, ExtensionReader> readers = null;
             Class currentCategory = null;
 
-            // Extract response entries and process fully qualified class name into category class instance
             for (Map.Entry<String, Class> entry : response.getRegistry().entrySet()) {
 
                 String name = entry.getKey();