Merge pull request #24 from dreamlike-ocean/feature-Mutiny

Feature mutiny

Author: dreamlike-ocean

.gitignore

@@ -2,4 +2,6 @@
 /target/
 .idea
 *.log
-*.iml
+*.iml
+*/target
+*/*.iml

README.md

@@ -64,7 +64,7 @@ API仍在变动之中**
 > 注意 jdk版本不能升级也不能降级，Panama api可能不一致
 
 - Maven 3.8.4
-- OpenJDK 20
+- OpenJDK 21
 - Linux >= 5.10
 
 构建非常简单

demo.txt

@@ -1,6 +1 @@
-ateastd
-ddd
-dddddd
-dddddadasd
-dasdawdawdefevadwadmawlkdmdlkwamdm追加写东西追加写东西
-追加写东西追加写东西追加写东西追加写东西追加写东西追加写东西追加写东西追加写东西追加写东西追加写东西
+追加写东西Lazy追加写东西Lazy

example/pom.xml

@@ -13,6 +13,7 @@
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <kotlin.version>1.9.10</kotlin.version>
     </properties>
     <dependencies>
         <dependency>
@@ -25,6 +26,80 @@
             <artifactId>panama-uring-linux-x86_64</artifactId>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>org.jetbrains.kotlin</groupId>
+            <artifactId>kotlin-stdlib-jdk8</artifactId>
+            <version>${kotlin.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.jetbrains.kotlin</groupId>
+            <artifactId>kotlin-test</artifactId>
+            <version>${kotlin.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.jetbrains.kotlin</groupId>
+                <artifactId>kotlin-maven-plugin</artifactId>
+                <version>${kotlin.version}</version>
+                <executions>
+                    <execution>
+                        <id>compile</id>
+                        <phase>compile</phase>
+                        <goals>
+                            <goal>compile</goal>
+                        </goals>
+                        <configuration>
+                            <sourceDirs>
+                                <source>src/main/java</source>
+                                <source>target/generated-sources/annotations</source>
+                            </sourceDirs>
+                        </configuration>
+                    </execution>
+                    <execution>
+                        <id>test-compile</id>
+                        <phase>test-compile</phase>
+                        <goals>
+                            <goal>test-compile</goal>
+                        </goals>
+                    </execution>
+                </executions>
+                <configuration>
+                    <jvmTarget>1.8</jvmTarget>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>default-compile</id>
+                        <phase>none</phase>
+                    </execution>
+                    <execution>
+                        <id>default-testCompile</id>
+                        <phase>none</phase>
+                    </execution>
+                    <execution>
+                        <id>compile</id>
+                        <phase>compile</phase>
+                        <goals>
+                            <goal>compile</goal>
+                        </goals>
+                    </execution>
+                    <execution>
+                        <id>testCompile</id>
+                        <phase>test-compile</phase>
+                        <goals>
+                            <goal>testCompile</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
 </project>

example/src/main/java/iouring/AsyncAcceptEpollExample.java

@@ -22,7 +22,5 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
                     System.out.println("vertx remote:" + ns.remoteAddress().port());
                 });
         EpollAsyncSocket epollAsyncSocket = serverSocket.accept().get();
-
-        System.out.println(epollAsyncSocket);
     }
 }

example/src/main/java/iouring/AsyncSocketExample.java

@@ -7,7 +7,6 @@
 
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Flow;
 import java.util.concurrent.atomic.AtomicInteger;
 
 public class AsyncSocketExample {
@@ -46,19 +45,11 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
             //recv示例
 //            String s = new String(asyncSocket.recvSelected(1024).get());
             byte[] buf = new byte[1024];
-            Integer recvRes = asyncSocket.recv(buf).get();
-            String hello = new String(buf, 0, recvRes);
+            Long recvRes = asyncSocket.recv(buf).get();
+            String hello = new String(buf, 0, recvRes.intValue());
             System.out.println("client recv:" + hello);
             CountDownLatch count = new CountDownLatch(10);
 
-            Flow.Subscription recvMulti = asyncSocket.recvMulti(bytes -> {
-                System.out.println("GET:" + new String(bytes));
-                count.countDown();
-            });
-            recvMulti.request(10);
-            count.await();
-
-            recvMulti.cancel();
             vertx.close();
         } catch (Exception e) {
         }

example/src/main/java/iouring/AsyncWatchServiceExample.java

@@ -17,7 +17,7 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
         var watchService = new AsyncWatchService(ioUringEventLoop);
         int demoFd = watchService.register(Path.of("demo.txt"), inotify_h.IN_MODIFY()).get();
         System.out.println(demoFd);
-        int dirFd = watchService.register(Path.of("/home/dreamlike/uringDemo"), inotify_h.IN_CREATE()).get();
+        int dirFd = watchService.register(Path.of(""), inotify_h.IN_CREATE()).get();
         System.out.println(dirFd);
         System.out.println("select");
         while (true) {

example/src/main/java/iouring/EpollExample.java

@@ -4,6 +4,7 @@
 
 import java.lang.foreign.Arena;
 import java.lang.foreign.MemorySegment;
+import java.lang.foreign.ValueLayout;
 import java.util.ArrayList;
 
 import static top.dreamlike.nativeLib.epoll.epoll_h.EPOLLIN;
@@ -15,7 +16,7 @@
  */
 public class EpollExample {
     public static void main(String[] args) {
-        try (Arena allocator = Arena.openConfined()) {
+        try (Arena allocator = Arena.ofConfined()) {
             MemorySegment memorySegment = allocator.allocate(1024);
             int flags = fcntl(0, F_GETFL(), 0);
             int res = fcntl(0, F_SETFL(), flags | O_NONBLOCK());
@@ -28,6 +29,7 @@ public static void main(String[] args) {
 
             long read = read(0, memorySegment, memorySegment.byteSize());
             System.out.println(read);
+            System.out.println(new String(memorySegment.reinterpret(read).toArray(ValueLayout.JAVA_BYTE)));
         }
 
 

example/src/main/java/iouring/EpollSocketExample.java

@@ -43,7 +43,7 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
             byte[] bytes = new byte[1024];
             //socket read 基于epoll做的 这里简单直接get阻塞到完成
             Integer recvLength = socket.recv(bytes)
-                    .get();
+                    .get().intValue();
             System.out.println(new String(bytes, 0, recvLength));
         }
     }

example/src/main/java/iouring/EventFdExample.java

@@ -12,7 +12,7 @@ public static void main(String[] args) throws InterruptedException {
 
         EpollEventLoop epollEventLoop = new EpollEventLoop();
         epollEventLoop.start();
-        epollEventLoop.registerEvent(eventFd.getFd(), EPOLLIN(), (i) -> {
+        epollEventLoop.registerReadEvent(eventFd.getFd(), EPOLLIN(), (i) -> {
             System.out.println(eventFd.readSync());
         });