From ab25523e84d7e00347a2255921564ca50ea4f554 Mon Sep 17 00:00:00 2001 From: zhangxu Date: Sat, 18 Jan 2025 11:21:42 +0800 Subject: [PATCH] fix ut --- pkg/txn/client/client_test.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/pkg/txn/client/client_test.go b/pkg/txn/client/client_test.go index a061f02ce3a61..5818c64ce0a84 100644 --- a/pkg/txn/client/client_test.go +++ b/pkg/txn/client/client_test.go @@ -251,3 +251,16 @@ func TestOpenTxnWithWaitPausedDisabled(t *testing.T) { require.Error(t, c.openTxn(op)) } + +func TestWaitAbortMarked(t *testing.T) { + c := make(chan struct{}) + tc := &txnClient{} + tc.mu.waitMarkAllActiveAbortedC = c + tc.mu.state = normal + tc.mu.activeTxns = map[string]*txnOperator{} + go func() { + close(c) + }() + op := &txnOperator{} + require.NoError(t, tc.openTxn(op)) +}