Add debugging print statements

Author: sarahchen6

src/main/java/com/timgroup/statsd/NonBlockingStatsDClientBuilder.java

@@ -385,16 +385,21 @@ protected static Callable<SocketAddress> staticUnixResolution(
                         // Use reflection to avoid compiling Java 16+ classes in incompatible versions
                         Class<?> unixDomainSocketAddressClass = Class.forName("java.net.UnixDomainSocketAddress");
                         Method ofMethod = unixDomainSocketAddressClass.getMethod("of", String.class);
-                        // return type SocketAddress instead of UnixSocketAddress for compatibility with 
-                        //the native SocketChannels in Unix*ClientChannel.java
+                        // return type SocketAddress for compatibility with UnixStreamClientChannel.java
                         socketAddress = (SocketAddress) ofMethod.invoke(null, path);
+                        System.out.println("========== Native UDS socket address: " + socketAddress);
+                        System.out.println("========== Native UDS socket address type: " + socketAddress.getClass().getName());
                     } catch (Exception e) {
                         throw new StatsDClientException("Failed to create UnixSocketAddress for native UDS implementation", e);
                     }
                 } else {
                     socketAddress = new UnixSocketAddress(path);
+                    System.out.println("========== JNR socket address: " + socketAddress);
+                    System.out.println("========== JNR socket address type: " + socketAddress.getClass().getName());
                 }
-                return new UnixSocketAddressWithTransport(socketAddress, transportType);
+                UnixSocketAddressWithTransport result = new UnixSocketAddressWithTransport(socketAddress, transportType);
+                System.out.println("========== Final result type: " + result.getClass().getName());
+                return result;
             }
         };
     }

src/main/java/com/timgroup/statsd/UnixStreamClientChannel.java

@@ -32,6 +32,8 @@ public class UnixStreamClientChannel implements ClientChannel {
     UnixStreamClientChannel(SocketAddress address, int timeout, int connectionTimeout, int bufferSize) throws IOException {
         this.delegate = null;
         this.address = address;
+        System.out.println("========== Constructor address: " + address);
+        System.out.println("========== Constructor address type: " + address.getClass().getName());
         this.timeout = timeout;
         this.connectionTimeout = connectionTimeout;
         this.bufferSize = bufferSize;
@@ -142,6 +144,8 @@ private void connect() throws IOException {
                     channel.socket().setSoTimeout(connectionTimeout);
                 }
                 try {
+                    System.out.println("========== Native UDS connect address: " + address);
+                    System.out.println("========== Native UDS connect address type: " + address.getClass().getName());
                     Method connectMethod = SocketChannel.class.getMethod("connect", SocketAddress.class);
                     boolean connected = (boolean) connectMethod.invoke(channel, address);
                     // socketchannel is failing to connect here :(
@@ -153,6 +157,7 @@ private void connect() throws IOException {
                             throw new IOException("Connection failed");
                         }
                     }
+                    System.out.println("========== Connection successful");
                     channel.socket().setSoTimeout(Math.max(timeout, 0));
                     if (bufferSize > 0) {
                         channel.socket().setSendBufferSize(bufferSize);
@@ -191,6 +196,9 @@ private void connect() throws IOException {
                 unixAddress = new UnixSocketAddress(address.toString());
             }
 
+            System.out.println("========== JNR connect address: " + unixAddress);
+            System.out.println("========== JNR connect address type: " + unixAddress.getClass().getName());
+
             if (!channel.connect(unixAddress)) {
                 if (connectionTimeout > 0 && System.nanoTime() > deadline) {
                     throw new IOException("Connection timed out");

src/test/java/com/timgroup/statsd/UnixStreamSocketDummyStatsDServer.java

@@ -22,7 +22,10 @@ public class UnixStreamSocketDummyStatsDServer extends DummyStatsDServer {
     public UnixStreamSocketDummyStatsDServer(String socketPath) throws IOException {
         server = UnixServerSocketChannel.open();
         server.configureBlocking(true);
-        server.socket().bind(new UnixSocketAddress(socketPath));
+        UnixSocketAddress address = new UnixSocketAddress(socketPath);
+        System.out.println("========== Server bind address: " + address);
+        System.out.println("========== Server bind address type: " + address.getClass().getName());
+        server.socket().bind(address);
         this.listen();
     }
 
@@ -38,6 +41,8 @@ protected void receive(ByteBuffer packet) throws IOException {
 
     @Override
     protected void listen() {
+        System.out.println("========== Server local address: " + server.getLocalSocketAddress());
+        System.out.println("========== Server local address type: " + server.getLocalSocketAddress().getClass().getName());
         logger.info("Listening on " + server.getLocalSocketAddress());
         Thread thread = new Thread(new Runnable() {
             @Override
@@ -52,6 +57,8 @@ public void run() {
                             if (clientChannel != null) {
                                 clientChannel.configureBlocking(true);
                                 try {
+                                    System.out.println("========== Client remote address: " + clientChannel.getRemoteSocketAddress());
+                                    System.out.println("========== Client remote address type: " + clientChannel.getRemoteSocketAddress().getClass().getName());
                                     logger.info("Accepted connection from " + clientChannel.getRemoteSocketAddress());
                                 } catch (Exception e) {
                                     logger.warning("Failed to get remote socket address");