Merge pull request #45 from headius/fix_blocking

Fix fcntl binding

src/main/java/jnr/enxio/channels/Native.java

@@ -27,9 +27,11 @@
 import jnr.ffi.annotations.In;
 import jnr.ffi.annotations.Out;
 import jnr.ffi.annotations.Transient;
+import jnr.ffi.annotations.Variadic;
 import jnr.ffi.types.size_t;
 import jnr.ffi.types.ssize_t;
 import jnr.ffi.Platform;
+import jnr.ffi.types.u_int64_t;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -46,7 +48,8 @@ public static interface LibC {
         public @ssize_t int read(int fd, @Out byte[] data, @size_t long size);
         public @ssize_t int write(int fd, @In ByteBuffer data, @size_t long size);
         public @ssize_t int write(int fd, @In byte[] data, @size_t long size);
-        public int fcntl(int fd, int cmd, int data);
+        @Variadic(fixedCount = 2)
+        public int fcntl(int fd, int cmd, @u_int64_t int data);
         public int poll(@In @Out ByteBuffer pfds, int nfds, int timeout);
         public int poll(@In @Out Pointer pfds, int nfds, int timeout);
         public int kqueue();
@@ -155,6 +158,12 @@ public static void setBlocking(int fd, boolean block) {
 
         libc().fcntl(fd, LibC.F_SETFL, flags);
     }
+
+    public static boolean getBlocking(int fd) {
+        int flags = libc().fcntl(fd, LibC.F_GETFL, 0);
+
+        return !((flags & LibC.O_NONBLOCK) == LibC.O_NONBLOCK);
+    }
 
     public static int shutdown(int fd, int how) {
         return libc().shutdown(fd, how);

src/test/java/jnr/enxio/channels/NativeTest.java

@@ -1,12 +1,14 @@
 package jnr.enxio.channels;
 
+import org.junit.Assert;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;
 
 import java.io.FileDescriptor;
 import java.io.FileOutputStream;
 import java.lang.reflect.Field;
+import java.nio.channels.Pipe;
 
 public class NativeTest {
     @Rule
@@ -23,4 +25,20 @@ public void closeThrowsOnNativeError() throws Exception {
         expectedEx.expect(NativeException.class);
         Native.close(fd);
     }
+
+    @Test
+    public void setBlocking() throws Exception {
+        Pipe pipe = Pipe.open();
+        Pipe.SinkChannel sink = pipe.sink();
+//        sink.getClass().getModule().addOpens("sun.nio.ch", NativeTest.class.getModule());
+        Field fd1 = sink.getClass().getDeclaredField("fd");
+        fd1.setAccessible(true);
+        FileDescriptor descriptor = (FileDescriptor) fd1.get(sink);
+        Field fdField = descriptor.getClass().getDeclaredField("fd");
+        fdField.setAccessible(true);
+        int fd = (int)(Integer)fdField.get(descriptor);
+        Assert.assertEquals(true, Native.getBlocking(fd));
+        Native.setBlocking(fd, false);
+        Assert.assertEquals(false, Native.getBlocking(fd));
+    }
 }