HA unknown protocol cannot pass anymore for domain sockets

eclipse-vertx · May 10, 2023 · 01e75f5 · 01e75f5
1 parent 8dc34aa
commit 01e75f5
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/pom.xml b/pom.xml
@@ -120,6 +120,7 @@
       <groupId>io.netty</groupId>
       <artifactId>netty-transport-native-kqueue</artifactId>
       <optional>true</optional>
+      <classifier>osx-aarch_64</classifier>
     </dependency>
 
     <!-- Jackson -->

diff --git a/src/test/java/io/vertx/core/http/HttpTest.java b/src/test/java/io/vertx/core/http/HttpTest.java
@@ -6378,6 +6378,7 @@ public void testHAProxyProtocolVersion1TCP6() throws Exception {
 
   @Test
   public void testHAProxyProtocolVersion1Unknown() throws Exception {
+    Assume.assumeTrue(testAddress.isInetSocket());
     Buffer header = HAProxy.createVersion1UnknownProtocolHeader();
     testHAProxyProtocolAccepted(header, null, testAddress);
   }
@@ -6408,6 +6409,7 @@ public void testHAProxyProtocolVersion2UnixSocket() throws Exception {
 
   @Test
   public void testHAProxyProtocolVersion2Unknown() throws Exception {
+    Assume.assumeTrue(testAddress.isInetSocket());
     Buffer header = HAProxy.createVersion2UnknownProtocolHeader();
     testHAProxyProtocolAccepted(header, null, testAddress);
   }

diff --git a/src/test/java/io/vertx/core/net/NetTest.java b/src/test/java/io/vertx/core/net/NetTest.java
@@ -4206,6 +4206,7 @@ public void testHAProxyProtocolIdleTimeoutNotHappened() throws Exception {
 
   @Test
   public void testHAProxyProtocolConnectSSL() throws Exception {
+    Assume.assumeTrue(testAddress.isInetSocket());
     waitFor(2);
     SocketAddress remote = SocketAddress.inetSocketAddress(56324, "192.168.0.1");
     SocketAddress local = SocketAddress.inetSocketAddress(443, "192.168.0.11");
@@ -4267,6 +4268,7 @@ public void testHAProxyProtocolVersion1TCP6() throws Exception {
 
   @Test
   public void testHAProxyProtocolVersion1Unknown() throws Exception {
+    Assume.assumeTrue(testAddress.isInetSocket());
     Buffer header = HAProxy.createVersion1UnknownProtocolHeader();
     testHAProxyProtocolAccepted(header, null, testAddress);
   }
@@ -4297,6 +4299,7 @@ public void testHAProxyProtocolVersion2UnixSocket() throws Exception {
 
   @Test
   public void testHAProxyProtocolVersion2Unknown() throws Exception {
+    Assume.assumeTrue(testAddress.isInetSocket());
     Buffer header = HAProxy.createVersion2UnknownProtocolHeader();
     testHAProxyProtocolAccepted(header, null, testAddress);
   }