set send timeout to 100ms, fix resist_dsd_timeout test

Author: xvello

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

@@ -22,6 +22,7 @@
 import java.util.concurrent.TimeUnit;
 import jnr.unixsocket.UnixSocketAddress;
 import jnr.unixsocket.UnixDatagramChannel;
+import jnr.unixsocket.UnixSocketOptions;
 
 
 /**
@@ -318,6 +319,7 @@ public NonBlockingStatsDClient(final String prefix,  final int queueSize, String
             final SocketAddress address = addressLookup.call();
             if (address instanceof UnixSocketAddress) {
                 clientChannel = UnixDatagramChannel.open();
+                clientChannel.setOption(UnixSocketOptions.SO_SNDTIMEO, Integer.valueOf(100));
             } else{
                 clientChannel = DatagramChannel.open();
             }

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

@@ -32,7 +32,7 @@ public void start() throws IOException {
         socketFile.deleteOnExit();
 
         server = new DummyStatsDServer(socketFile.toString());
-        client = new NonBlockingStatsDClient("my.prefix", socketFile.toString(), 0, null, this);
+        client = new NonBlockingStatsDClient("my.prefix", socketFile.toString(), 0, 1, null, this);
     }
 
     @After
@@ -103,9 +103,9 @@ public void resist_dsd_timeout() throws Exception {
         server.freeze();
         while(lastException.getMessage() == null) {
             client.gauge("mycount", 20);
-            Thread.sleep(1);  // We need to fill the buffer, setting a shorter sleep
+            Thread.sleep(10);  // We need to fill the buffer, setting a shorter sleep
         }
-        assertThat(lastException.getMessage(), containsString("No buffer space available"));
+        assertThat(lastException.getMessage(), containsString("Resource temporarily unavailable"));
 
         // Make sure we recover after we resume listening
         server.clear();