Draft - io_uring - GSoC 2020

common/src/main/java/io/netty/util/internal/PlatformDependent.java

@@ -471,6 +471,18 @@ public static <K, V> ConcurrentMap<K, V> newConcurrentHashMap(Map<? extends K, ?
         return new ConcurrentHashMap<K, V>(map);
     }
 
+    public static void loadFence() {
+        PlatformDependent0.loadFence();
+    }
+
+    public static void storeFence() {
+        PlatformDependent0.storeFence();
+    }
+
+    public static void fullFence() {
+        PlatformDependent0.fullFence();
+    }
+
     /**
      * Try to deallocate the specified direct {@link ByteBuffer}. Please note this method does nothing if
      * the current platform does not support this operation or the specified buffer is not a direct buffer.

common/src/main/java/io/netty/util/internal/PlatformDependent0.java

@@ -597,6 +597,18 @@ static void putObject(Object o, long offset, Object x) {
         UNSAFE.putObject(o, offset, x);
     }
 
+    static void loadFence() {
+        UNSAFE.loadFence();
+    }
+
+    static void storeFence() {
+        UNSAFE.storeFence();
+    }
+
+    static void fullFence() {
+        UNSAFE.fullFence();
+    }
+
     static void copyMemory(long srcAddr, long dstAddr, long length) {
         // Manual safe-point polling is only needed prior Java9:
         // See https://bugs.openjdk.java.net/browse/JDK-8149596

pom.xml

@@ -419,6 +419,7 @@
     <module>transport-blockhound-tests</module>
     <module>microbench</module>
     <module>bom</module>
+    <module>transport-native-io_uring</module>
   </modules>
 
   <dependencyManagement>

transport-native-epoll/src/main/c/netty_epoll_native.c

@@ -565,7 +565,7 @@ static JNINativeMethod* createDynamicMethodsTable(const char* packagePrefix) {
     }
     memset(dynamicMethods, 0, size);
     memcpy(dynamicMethods, fixed_method_table, sizeof(fixed_method_table));
-    
+
     JNINativeMethod* dynamicMethod = &dynamicMethods[fixed_method_table_size];
     NETTY_PREPEND(packagePrefix, "io/netty/channel/epoll/NativeDatagramPacketArray$NativeDatagramPacket;II)I", dynamicTypeName, error);
     NETTY_PREPEND("(IZ[L", dynamicTypeName,  dynamicMethod->signature, error);