[fix] mesh remote 问题修复 (#899)

* [fix] mesh remote 问题修复 * [fix] mesh remote 问题修复
XiaoMi · Nov 9, 2024 · eabc7e3 · eabc7e3
1 parent b9f950b
commit eabc7e3
Show file tree

Hide file tree

Showing 4 changed files with 26 additions and 25 deletions.
diff --git a/jcommon/pom.xml b/jcommon/pom.xml
@@ -250,24 +250,25 @@
                 </executions>
             </plugin>
 
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-gpg-plugin</artifactId>
-                <version>1.6</version>
-                <executions>
-                    <execution>
-                        <id>sign-artifacts</id>
-                        <phase>verify</phase>
-                        <goals>
-                            <goal>sign</goal>
-                        </goals>
-                        <configuration>
-                            <executable>gpg</executable>
-<!--                            <keyname>your-gpg-key</keyname>-->
-                        </configuration>
-                    </execution>
-                </executions>
-            </plugin>
+<!--            <plugin>-->
+<!--                <groupId>org.apache.maven.plugins</groupId>-->
+<!--                <artifactId>maven-gpg-plugin</artifactId>-->
+<!--                <version>1.6</version>-->
+<!--                <executions>-->
+<!--                    <execution>-->
+<!--                        <id>sign-artifacts</id>-->
+<!--                        <phase>verify</phase>-->
+<!--                        <goals>-->
+<!--                            <goal>sign</goal>-->
+<!--                        </goals>-->
+<!--                        <configuration>-->
+<!--                            <executable>gpg</executable>-->
+<!--&lt;!&ndash;                            <keyname>your-gpg-key</keyname>&ndash;&gt;-->
+<!--                        </configuration>-->
+<!--                    </execution>-->
+<!--                </executions>-->
+<!--            </plugin>-->
+
         </plugins>
     </build>
 

diff --git a/jcommon/rcurve/src/main/java/com/xiaomi/data/push/common/NetUtils.java b/jcommon/rcurve/src/main/java/com/xiaomi/data/push/common/NetUtils.java
@@ -13,10 +13,10 @@
  */
 public class NetUtils {
 
-    public static EventLoopGroup getEventLoopGroup() {
-//        if (CommonUtils.isMac() && CommonUtils.isArch64()) {
-//            return new NioEventLoopGroup();
-//        }
+    public static EventLoopGroup getEventLoopGroup(boolean remote) {
+        if (remote) {
+            return new NioEventLoopGroup();
+        }
         if (CommonUtils.isWindows()) {
             return new NioEventLoopGroup();
         }

diff --git a/jcommon/rcurve/src/main/java/com/xiaomi/data/push/uds/UdsClient.java b/jcommon/rcurve/src/main/java/com/xiaomi/data/push/uds/UdsClient.java
@@ -95,7 +95,7 @@ public UdsClient(String id) {
 
 
     private EventLoopGroup getEventLoopGroup() {
-        return NetUtils.getEventLoopGroup();
+        return NetUtils.getEventLoopGroup(this.remote);
     }
 
 

diff --git a/jcommon/rcurve/src/main/java/com/xiaomi/data/push/uds/UdsServer.java b/jcommon/rcurve/src/main/java/com/xiaomi/data/push/uds/UdsServer.java
@@ -109,8 +109,8 @@ public void start(String path) {
         this.path = path;
         delPath();
         boolean mac = CommonUtils.isMac();
-        EventLoopGroup bossGroup = NetUtils.getEventLoopGroup();
-        EventLoopGroup workerGroup = NetUtils.getEventLoopGroup();
+        EventLoopGroup bossGroup = NetUtils.getEventLoopGroup(this.remote);
+        EventLoopGroup workerGroup = NetUtils.getEventLoopGroup(this.remote);
         try {
             ServerBootstrap b = new ServerBootstrap();
             b.group(bossGroup, workerGroup)
-Original file line number
+Diff line change
@@ Expand Up / @@ -95,7 +95,7 @@ public UdsClient(String id) { @@
         private EventLoopGroup getEventLoopGroup() {
-            return NetUtils.getEventLoopGroup();
+            return NetUtils.getEventLoopGroup(this.remote);
         }
@@ Expand Down @@