[Driver/Java] Do not re-resolve control/endpoint addresses if the corresponding endpoint is not active.

In case of an endpoint being closed (e.g. publication is removed) all outstanding re-resolution requests should be ignored.

Author: vyazelenko

aeron-driver/src/main/java/io/aeron/driver/DriverConductor.java

@@ -439,10 +439,20 @@ void onPublicationError(
     void onReResolveEndpoint(
         final String endpoint, final SendChannelEndpoint channelEndpoint, final InetSocketAddress address)
     {
+        if (!channelEndpoint.isActive())
+        {
+            return;
+        }
+
         executeAsyncTask(
             () -> UdpChannel.resolve(endpoint, ENDPOINT_PARAM_NAME, true, nameResolver),
             (asyncResult) ->
             {
+                if (!channelEndpoint.isActive())
+                {
+                    return;
+                }
+
                 try
                 {
                     final InetSocketAddress newAddress = asyncResult.get();
@@ -468,10 +478,20 @@ void onReResolveControl(
         final ReceiveChannelEndpoint channelEndpoint,
         final InetSocketAddress address)
     {
+        if (!channelEndpoint.isActive())
+        {
+            return;
+        }
+
         executeAsyncTask(
             () -> UdpChannel.resolve(control, MDC_CONTROL_PARAM_NAME, true, nameResolver),
             (asyncResult) ->
             {
+                if (!channelEndpoint.isActive())
+                {
+                    return;
+                }
+
                 try
                 {
                     final InetSocketAddress newAddress = asyncResult.get();

aeron-driver/src/main/java/io/aeron/driver/media/ReceiveChannelEndpoint.java

@@ -288,6 +288,16 @@ public void closeIndicators()
         }
     }
 
+    /**
+     * Checks if an endpoint is still active, i.e. not being closed.
+     *
+     * @return {@code true} if active.
+     */
+    public boolean isActive()
+    {
+        return !statusIndicator.isClosed() && ChannelEndpointStatus.ACTIVE == statusIndicator.get();
+    }
+
     /**
      * Close transports for {@link MultiRcvDestination} if present.
      *

aeron-driver/src/main/java/io/aeron/driver/media/SendChannelEndpoint.java

@@ -225,6 +225,16 @@ public void closeIndicators()
         CloseHelper.close(mdcDestinationsCounter);
     }
 
+    /**
+     * Checks if an endpoint is still active, i.e. not being closed.
+     *
+     * @return {@code true} if active.
+     */
+    public boolean isActive()
+    {
+        return !statusIndicator.isClosed() && ChannelEndpointStatus.ACTIVE == statusIndicator.get();
+    }
+
     /**
      * Called by to determine if the channel endpoint should be closed.
      *