IGNITE-22671 Fix dns_failure ducktape test compilation for jdk11

Author: timoninmaxim

modules/ducktests/src/main/java/java/net/BlockingDnsInet4AddressImpl.java

@@ -14,46 +14,75 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package java.net;
+package org.apache.ignite.internal.ducktest.tests.dns_failure_test;
+
+import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.internal.util.typedef.internal.U;
+import org.apache.ignite.startup.cmdline.CommandLineStartup;
+import sun.net.spi.nameservice.NameService;
 
 import java.io.File;
 import java.io.FileNotFoundException;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
 import java.text.SimpleDateFormat;
 import java.util.Arrays;
 import java.util.Date;
+import java.util.List;
 import java.util.Scanner;
 
 /** */
-public class DnsBlocker {
+public class DnsBlocker implements NameService {
     /** */
     private static final String BLOCK_DNS_FILE = "/tmp/block_dns";
 
     /** */
-    public static final DnsBlocker INSTANCE = new DnsBlocker();
+    private final InetAddress loopback;
 
-    /** */
-    private DnsBlocker() {
-        // No-op.
-    }
+    /** Original NameService to use after unblock. */
+    private final NameService orig;
 
     /**
-     * Check and block hostname resolve request if needed.
-     * @param impl Implementation.
-     * @param hostname Hostname.
+     * @param orig Original NameService to use after unblock.
      */
-    public void onHostResolve(InetAddressImpl impl, String hostname) throws UnknownHostException {
-        if (!impl.loopbackAddress().getHostAddress().equals(hostname))
+    private DnsBlocker(NameService orig) {
+        loopback = InetAddress.getLoopbackAddress();
+        this.orig = orig;
+    }
+
+    /** Installs DnsBlocker as main NameService to JVM. */
+    private static void install() throws IgniteCheckedException {
+        List<NameService> nameSrvc = U.staticField(InetAddress.class, "nameServices");
+
+        NameService ns = new DnsBlocker(nameSrvc.get(0));
+
+        // Put the blocking name service ahead.
+        nameSrvc.add(0, ns);
+
+        System.out.println("Installed DnsBlocker as main NameService to JVM [ns=" + nameSrvc.size() + ']');
+    }
+
+    /** */
+    public static void main(String[] args) throws Exception {
+        install();
+
+        CommandLineStartup.main(args);
+    }
+
+    /** */
+    @Override public InetAddress[] lookupAllHostAddr(String hostname) throws UnknownHostException {
+        if (!loopback.getHostAddress().equals(hostname))
             check(hostname);
+
+        return orig.lookupAllHostAddr(hostname);
     }
 
-    /**
-     * Check and block address resolve request if needed.
-     * @param impl Implementation.
-     * @param addr Address.
-     */
-    public void onAddrResolve(InetAddressImpl impl, byte[] addr) throws UnknownHostException {
-        if (!Arrays.equals(impl.loopbackAddress().getAddress(), addr))
+    /** */
+    @Override public String getHostByAddr(byte[] addr) throws UnknownHostException {
+        if (!Arrays.equals(loopback.getAddress(), addr))
             check(InetAddress.getByAddress(addr).toString());
+
+        return orig.getHostByAddr(addr);
     }
 
     /** */

modules/ducktests/src/main/java/java/net/BlockingDnsInet6AddressImpl.java

@@ -27,6 +27,6 @@ class IgniteService(IgniteAwareService):
     APP_SERVICE_CLASS = "org.apache.ignite.startup.cmdline.CommandLineStartup"
 
     def __init__(self, context, config, num_nodes, jvm_opts=None, merge_with_default=True, startup_timeout_sec=60,
-                 shutdown_timeout_sec=60, modules=None):
-        super().__init__(context, config, num_nodes, startup_timeout_sec, shutdown_timeout_sec, self.APP_SERVICE_CLASS,
+                 shutdown_timeout_sec=60, modules=None, main_java_class=APP_SERVICE_CLASS):
+        super().__init__(context, config, num_nodes, startup_timeout_sec, shutdown_timeout_sec, main_java_class,
                          modules, jvm_opts=jvm_opts, merge_with_default=merge_with_default)

modules/ducktests/src/main/java/java/net/DnsBlocker.java renamed to modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/dns_failure_test/DnsBlocker.java

@@ -300,6 +300,9 @@ def _runcmd(self, cmd):
         if proc.returncode != 0:
             raise RuntimeError("Command '%s' returned non-zero exit status %d: %s" % (cmd, proc.returncode, stdout))
 
+    def envs(self):
+        return {"MAIN_CLASS": self.service.main_java_class}
+
 
 class IgniteNodeSpec(IgniteSpec):
     """
@@ -356,6 +359,3 @@ def command(self, node):
     def config_file_path(self):
         return self.service.config_file if self.service.config.service_type == IgniteServiceType.NODE \
             else self.service.thin_client_config_file
-
-    def envs(self):
-        return {**super().envs(), **{"MAIN_CLASS": self.service.main_java_class}}

modules/ducktests/tests/ignitetest/services/ignite.py

@@ -110,19 +110,8 @@ def __prepare_service(self, ignite_config, num_nodes=1):
             self.test_context,
             ignite_config,
             startup_timeout_sec=120,
-            num_nodes=num_nodes)
-
-        bootclasspath = list(map(lambda lib: os.path.join(lib, "classes"), ignite.spec._module_libs("ducktests")))
-
-        # Note: Support of impl.prefix property was removed since java 18.
-        ignite.spec.jvm_opts.append("-Dimpl.prefix=BlockingDns")
-
-        java_version = ignite.java_version()
-
-        if java_major_version(java_version) > 8:
-            ignite.spec.jvm_opts.append("\"--patch-module java.base=" + ":".join(bootclasspath) + "\"")
-        else:
-            ignite.spec.jvm_opts.append("-Xbootclasspath/a:" + ":".join(bootclasspath))
+            num_nodes=num_nodes,
+            main_java_class="org.apache.ignite.internal.ducktest.tests.dns_failure_test.DnsBlocker")
 
         return ignite