Merge pull request #13 from eatkins/max-socket-length

Add maxSocketLength to native api

jni/org_scalasbt_ipcsocket_JNIUnixDomainSocketLibraryProvider.c

@@ -127,3 +127,10 @@ Java_org_scalasbt_ipcsocket_JNIUnixDomainSocketLibraryProvider_errString(
   const char *err = strerror(code);
   return (*env)->NewStringUTF(env, err);
 }
+
+JNIEXPORT jint JNICALL
+Java_org_scalasbt_ipcsocket_JNIUnixDomainSocketLibraryProvider_maxSocketLength(
+    UNUSED JNIEnv *env, UNUSED jobject object) {
+  struct sockaddr_un un;
+  return sizeof(un.sun_path);
+}

src/main/java/org/scalasbt/ipcsocket/JNIUnixDomainSocketLibraryProvider.java

@@ -70,6 +70,8 @@ private int returnOrThrow(int result, int threshold) throws NativeErrorException
 
   native int shutdownNative(int fd, int how);
 
+  public native int maxSocketLength();
+
   native String errString(int error);
 
   static {

src/main/java/org/scalasbt/ipcsocket/UnixDomainSocketLibrary.java

@@ -267,4 +267,9 @@ public int shutdown(int fd, int how) throws NativeErrorException {
       throw new NativeErrorException(e.getErrorCode(), e.getMessage());
     }
   }
+
+  @Override
+  public int maxSocketLength() {
+    return new UnixDomainSocketLibrary.SockaddrUn().sunPath.length;
+  }
 }

src/main/java/org/scalasbt/ipcsocket/UnixDomainSocketLibraryProvider.java

@@ -19,9 +19,15 @@ public interface UnixDomainSocketLibraryProvider {
 
   int shutdown(int fd, int how) throws NativeErrorException;
 
+  int maxSocketLength();
+
   static UnixDomainSocketLibraryProvider get(boolean useJNI) {
     return useJNI
         ? JNIUnixDomainSocketLibraryProvider.instance()
         : JNAUnixDomainSocketLibraryProvider.instance();
   }
+
+  static int maxSocketLength(boolean useJNI) {
+    return get(useJNI).maxSocketLength();
+  }
 }

src/test/java/org/scalasbt/ipcsocket/UnixSocketLengthTest.java

@@ -0,0 +1,26 @@
+package org.scalasbt.ipcsocket;
+
+import org.junit.Test;
+import static org.junit.Assert.*;
+
+public class UnixSocketLengthTest {
+  final boolean isWin = System.getProperty("os.name", "").toLowerCase().startsWith("win");
+  final boolean isLinux = System.getProperty("os.name", "").toLowerCase().startsWith("linux");
+
+  @Test
+  public void testJNIMaxSocketLength() {
+    if (!isWin) {
+      int length = UnixDomainSocketLibraryProvider.maxSocketLength(true);
+      int expectedLength = isLinux ? 108 : 104;
+      assert (length == expectedLength);
+    }
+  }
+
+  @Test
+  public void testJNAMaxSocketLength() {
+    if (!isWin) {
+      int length = UnixDomainSocketLibraryProvider.maxSocketLength(false);
+      assert (length == 104);
+    }
+  }
+}