Debug

Author: sarahchen6

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

@@ -5,11 +5,11 @@
 import jnr.unixsocket.UnixSocketOptions;
 
 import java.io.IOException;
+import java.lang.reflect.Method;
 import java.net.SocketAddress;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
 import java.nio.channels.SocketChannel;
-import java.lang.reflect.Method;
 
 /**
  * A ClientChannel for Unix domain sockets.

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

@@ -11,7 +11,7 @@
 
 public class UnixDatagramSocketDummyStatsDServer extends DummyStatsDServer {
     private final DatagramChannel server;
-    private volatile boolean running = true;
+    private volatile boolean serverRunning = true;
 
     public UnixDatagramSocketDummyStatsDServer(String socketPath) throws IOException {
         if (ClientChannelUtils.hasNativeUdsSupport()) {
@@ -35,7 +35,7 @@ public UnixDatagramSocketDummyStatsDServer(String socketPath) throws IOException
 
     @Override
     protected boolean isOpen() {
-        return running && server.isOpen();
+        return serverRunning && server.isOpen();
     }
 
     protected void receive(ByteBuffer packet) throws IOException {
@@ -44,12 +44,12 @@ protected void receive(ByteBuffer packet) throws IOException {
 
     @Override
     public void close() throws IOException {
-        running = false;  // Signal the listening thread to stop
+        serverRunning = false;
         try {
             // Give the listening thread a chance to stop
-            Thread.sleep(50);
+            Thread.sleep(1000);
         } catch (InterruptedException e) {
-            // Ignore
+            // ignore
         }
         try {
             server.close();