test: fix race condition in handler tests

Add sync.RWMutex to mockTCCFenceStore to protect concurrent access
to mock functions from multiple goroutines. This fixes race conditions
detected by go test -race.

The race detector identified concurrent reads/writes to the mock's
function fields when goroutines in traversalCleanChannel tests
accessed the mock simultaneously.

Author: WangzJi

pkg/rm/tcc/fence/handler/tcc_fence_wrapper_handler_test.go

@@ -21,6 +21,7 @@ import (
 	"context"
 	"database/sql"
 	"errors"
+	"sync"
 	"testing"
 	"time"
 
@@ -36,6 +37,7 @@ import (
 
 // mockTCCFenceStore is a mock implementation of TCCFenceStore for testing
 type mockTCCFenceStore struct {
+	mu                               sync.RWMutex
 	insertFunc                       func(tx *sql.Tx, tccFenceDo *model.TCCFenceDO) error
 	queryFunc                        func(tx *sql.Tx, xid string, branchId int64) (*model.TCCFenceDO, error)
 	updateFunc                       func(tx *sql.Tx, xid string, branchId int64, oldStatus enum.FenceStatus, newStatus enum.FenceStatus) error
@@ -46,48 +48,62 @@ type mockTCCFenceStore struct {
 }
 
 func (m *mockTCCFenceStore) InsertTCCFenceDO(tx *sql.Tx, tccFenceDo *model.TCCFenceDO) error {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
 	if m.insertFunc != nil {
 		return m.insertFunc(tx, tccFenceDo)
 	}
 	return nil
 }
 
 func (m *mockTCCFenceStore) QueryTCCFenceDO(tx *sql.Tx, xid string, branchId int64) (*model.TCCFenceDO, error) {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
 	if m.queryFunc != nil {
 		return m.queryFunc(tx, xid, branchId)
 	}
 	return nil, nil
 }
 
 func (m *mockTCCFenceStore) UpdateTCCFenceDO(tx *sql.Tx, xid string, branchId int64, oldStatus enum.FenceStatus, newStatus enum.FenceStatus) error {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
 	if m.updateFunc != nil {
 		return m.updateFunc(tx, xid, branchId, oldStatus, newStatus)
 	}
 	return nil
 }
 
 func (m *mockTCCFenceStore) DeleteTCCFenceDO(tx *sql.Tx, xid string, branchId int64) error {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
 	if m.deleteFunc != nil {
 		return m.deleteFunc(tx, xid, branchId)
 	}
 	return nil
 }
 
 func (m *mockTCCFenceStore) DeleteMultipleTCCFenceLogIdentity(tx *sql.Tx, identity []model.FenceLogIdentity) error {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
 	if m.deleteMultipleFunc != nil {
 		return m.deleteMultipleFunc(tx, identity)
 	}
 	return nil
 }
 
 func (m *mockTCCFenceStore) DeleteTCCFenceDOByMdfDate(tx *sql.Tx, datetime time.Time, limit int32) (int64, error) {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
 	if m.deleteTCCFenceDOByMdfDateFunc != nil {
 		return m.deleteTCCFenceDOByMdfDateFunc(tx, datetime, limit)
 	}
 	return 0, nil
 }
 
 func (m *mockTCCFenceStore) QueryTCCFenceLogIdentityByMdDate(tx *sql.Tx, datetime time.Time) ([]model.FenceLogIdentity, error) {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
 	if m.queryTCCFenceLogIdentityByMdDate != nil {
 		return m.queryTCCFenceLogIdentityByMdDate(tx, datetime)
 	}