JNA 5.8.0

JerryShea · JerryShea · commit 0638a3ac7aef · 2021-06-22T09:43:01.000+10:00
diff --git a/affinity/pom.xml b/affinity/pom.xml
@@ -128,6 +128,7 @@
             </build>
         </profile>
     </profiles>
+
     <build>
         <plugins>
             <plugin>
diff --git a/affinity/src/main/java/net/openhft/affinity/impl/LinuxHelper.java b/affinity/src/main/java/net/openhft/affinity/impl/LinuxHelper.java
@@ -158,7 +158,7 @@ public static int syscall(int number, Object... args) {
     }
 
     interface CLibrary extends Library {
-        CLibrary INSTANCE = (CLibrary) Native.loadLibrary(LIBRARY_NAME, CLibrary.class);
+        CLibrary INSTANCE = Native.load(LIBRARY_NAME, CLibrary.class);
 
         int sched_setaffinity(final int pid,
                               final int cpusetsize,
diff --git a/affinity/src/main/java/net/openhft/affinity/impl/OSXJNAAffinity.java b/affinity/src/main/java/net/openhft/affinity/impl/OSXJNAAffinity.java
@@ -72,8 +72,7 @@ public int getThreadId() {
     }
 
     interface CLibrary extends Library {
-        CLibrary INSTANCE = (CLibrary)
-                Native.loadLibrary("libpthread.dylib", CLibrary.class);
+        CLibrary INSTANCE = Native.load("libpthread.dylib", CLibrary.class);
 
         int pthread_self() throws LastErrorException;
     }
diff --git a/affinity/src/main/java/net/openhft/affinity/impl/PosixJNAAffinity.java b/affinity/src/main/java/net/openhft/affinity/impl/PosixJNAAffinity.java
@@ -191,8 +191,7 @@ public int getThreadId() {
      * @author BegemoT
      */
     interface CLibrary extends Library {
-        CLibrary INSTANCE = (CLibrary)
-                Native.loadLibrary(LIBRARY_NAME, CLibrary.class);
+        CLibrary INSTANCE = Native.load(LIBRARY_NAME, CLibrary.class);
 
         int sched_setaffinity(final int pid,
                               final int cpusetsize,
diff --git a/affinity/src/main/java/net/openhft/affinity/impl/SolarisJNAAffinity.java b/affinity/src/main/java/net/openhft/affinity/impl/SolarisJNAAffinity.java
@@ -72,8 +72,7 @@ public int getThreadId() {
     }
 
     interface CLibrary extends Library {
-        CLibrary INSTANCE = (CLibrary)
-                Native.loadLibrary("c", CLibrary.class);
+        CLibrary INSTANCE = Native.load("c", CLibrary.class);
 
         int pthread_self() throws LastErrorException;
     }
diff --git a/affinity/src/main/java/net/openhft/affinity/impl/WindowsJNAAffinity.java b/affinity/src/main/java/net/openhft/affinity/impl/WindowsJNAAffinity.java
@@ -17,12 +17,10 @@
 
 package net.openhft.affinity.impl;
 
-import com.sun.jna.LastErrorException;
-import com.sun.jna.Library;
-import com.sun.jna.Native;
-import com.sun.jna.PointerType;
+import com.sun.jna.*;
 import com.sun.jna.platform.win32.Kernel32;
 import com.sun.jna.platform.win32.WinDef;
+import com.sun.jna.platform.win32.WinNT;
 import com.sun.jna.ptr.LongByReference;
 import net.openhft.affinity.IAffinity;
 import org.jetbrains.annotations.Nullable;
@@ -86,7 +84,7 @@ public void setAffinity(final BitSet affinity) {
 
         int pid = getTid();
         try {
-            lib.SetThreadAffinityMask(pid, aff);
+            lib.SetThreadAffinityMask(handle(pid), aff);
         } catch (LastErrorException e) {
             throw new IllegalStateException("SetThreadAffinityMask((" + pid + ") , &(" + affinity + ") ) errorNo=" + e.getErrorCode(), e);
         }
@@ -104,7 +102,7 @@ private BitSet getAffinity0() {
         final LongByReference cpuset2 = new LongByReference(0);
         try {
 
-            final int ret = lib.GetProcessAffinityMask(-1, cpuset1, cpuset2);
+            final int ret = lib.GetProcessAffinityMask(handle(-1), cpuset1, cpuset2);
             // Successful result is positive, according to the docs
             // https://msdn.microsoft.com/en-us/library/windows/desktop/ms683213%28v=vs.85%29.aspx
             if (ret <= 0) {
@@ -120,6 +118,10 @@ private BitSet getAffinity0() {
         return null;
     }
 
+    private WinNT.HANDLE handle(int pid) {
+        return new WinNT.HANDLE(new Pointer(pid));
+    }
+
     public int getTid() {
         final CLibrary lib = CLibrary.INSTANCE;
 
@@ -152,11 +154,11 @@ public int getThreadId() {
      * @author BegemoT
      */
     private interface CLibrary extends Library {
-        CLibrary INSTANCE = (CLibrary) Native.loadLibrary("kernel32", CLibrary.class);
+        CLibrary INSTANCE = Native.load("kernel32", CLibrary.class);
 
-        int GetProcessAffinityMask(final int pid, final PointerType lpProcessAffinityMask, final PointerType lpSystemAffinityMask) throws LastErrorException;
+        int GetProcessAffinityMask(final WinNT.HANDLE pid, final PointerType lpProcessAffinityMask, final PointerType lpSystemAffinityMask) throws LastErrorException;
 
-        void SetThreadAffinityMask(final int pid, final WinDef.DWORD lpProcessAffinityMask) throws LastErrorException;
+        void SetThreadAffinityMask(final WinNT.HANDLE pid, final WinDef.DWORD lpProcessAffinityMask) throws LastErrorException;
 
         int GetCurrentThread() throws LastErrorException;
     }

Original file line number	Diff line number	Diff line change
`@@ -158,7 +158,7 @@ public static int syscall(int number, Object... args) {`
`158`	`158`	`}`
`159`	`159`
`160`	`160`	`interface CLibrary extends Library {`
`161`		`- CLibrary INSTANCE = (CLibrary) Native.loadLibrary(LIBRARY_NAME, CLibrary.class);`
	`161`	`+ CLibrary INSTANCE = Native.load(LIBRARY_NAME, CLibrary.class);`
`162`	`162`
`163`	`163`	`int sched_setaffinity(final int pid,`
`164`	`164`	`final int cpusetsize,`
Original file line number	Diff line number	Diff line change
`@@ -72,8 +72,7 @@ public int getThreadId() {`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`interface CLibrary extends Library {`
`75`		`- CLibrary INSTANCE = (CLibrary)`
`76`		`- Native.loadLibrary("libpthread.dylib", CLibrary.class);`
	`75`	`+ CLibrary INSTANCE = Native.load("libpthread.dylib", CLibrary.class);`
`77`	`76`
`78`	`77`	`int pthread_self() throws LastErrorException;`
`79`	`78`	`}`