fix test

apache · Feb 4, 2024 · 35ba3c8 · 35ba3c8
1 parent fe00da5
commit 35ba3c8
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 13 deletions.
diff --git a/test/src/test/java/org/apache/seata/core/rpc/netty/mockserver/MockServerTest.java b/test/src/test/java/org/apache/seata/core/rpc/netty/mockserver/MockServerTest.java
@@ -32,9 +32,22 @@ public class MockServerTest {
 
     static String RESOURCE_ID = "mock-action";
 
+    private static volatile boolean inited = false;
+
     @BeforeAll
     public static void before() {
-        MockServer.start();
+        startMockServer();
+    }
+
+    public static void startMockServer() {
+        if (!inited) {
+            synchronized (MockServerTest.class) {
+                if (!inited) {
+                    MockServer.start();
+                    inited = true;
+                }
+            }
+        }
     }
 
     @Test

diff --git a/test/src/test/java/org/apache/seata/core/rpc/netty/mockserver/RmClientTest.java b/test/src/test/java/org/apache/seata/core/rpc/netty/mockserver/RmClientTest.java
@@ -45,15 +45,10 @@ public class RmClientTest {
 
     protected static final Logger LOGGER = LoggerFactory.getLogger(RmClientTest.class);
 
-    @BeforeAll
-    public static void before() {
-        MockServer.start();
-    }
-
-
 
     @Test
     public void testRm() throws TransactionException {
+        MockServerTest.startMockServer();
         String resourceId = "mock-action";
         String xid = "1111";
 

diff --git a/test/src/test/java/org/apache/seata/core/rpc/netty/mockserver/TmClientTest.java b/test/src/test/java/org/apache/seata/core/rpc/netty/mockserver/TmClientTest.java
@@ -40,15 +40,10 @@ public class TmClientTest {
 
     protected static final Logger LOGGER = LoggerFactory.getLogger(TmClientTest.class);
 
-    @BeforeAll
-    public static void before() {
-        MockServer.start();
-    }
-
 
     @Test
     public void testTm() throws Exception {
-
+        MockServerTest.startMockServer();
         TransactionManager tm = getTm();
 
         //globalBegin:TYPE_GLOBAL_BEGIN = 1 , TYPE_GLOBAL_BEGIN_RESULT = 2