fix ut

matrixorigin · Jan 18, 2025 · ab25523 · ab25523
1 parent a29f44d
commit ab25523
Showing 1 changed file with 13 additions and 0 deletions.
diff --git 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))
+}