[fix] mesh remote 问题修复

XiaoMi · Nov 9, 2024 · b7409fc · b7409fc
1 parent 1f1fcd3
commit b7409fc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
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 @@