mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-06 04:40:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

inner-2140: fix the multi-thread bug for xa

Browse Source 
Signed-off-by: dcy10000 <dcy10000@gmail.com>
(cherry picked from commit cdce285da5)
This commit is contained in:
dcy10000
2023-03-10 16:29:04 +08:00
parent 4799401321
commit a162ac4935
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XAHandler.java
View File

@@ -19,6 +19,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
@@ -29,7 +30,7 @@ public class XAHandler {
private static final String XARECOVER_SQL = "XA RECOVER";
private static final String KILL_SQL = "KILL CONNECTION ";
private static final String[] MYSQL_RECOVER_COLS = new String[]{"formatID", "gtrid_length", "bqual_length", "data"};
private final Map<PhysicalDbInstance, List<Map<String, String>>> results = new HashMap<>(8);
private final Map<PhysicalDbInstance, List<Map<String, String>>> results = new ConcurrentHashMap<>(8);
private final List<SQLJob> sqlJobs = new ArrayList<>();
private final AtomicInteger count = new AtomicInteger();
private final Lock lock;