mysql(ticdc): fix the data race in the conflict detector (#10630) (#1…

…0642) close #10621
pingcap · Apr 16, 2024 · 3c4a12d · 3c4a12d
1 parent 0d6a661
commit 3c4a12d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/causality/internal/node.go b/pkg/causality/internal/node.go
@@ -160,6 +160,8 @@ func (n *Node) Remove() {
 // It must be called if a node is no longer used.
 // We are using sync.Pool to lessen the burden of GC.
 func (n *Node) Free() {
+	n.mu.Lock()
+	defer n.mu.Unlock()
 	if n.id == invalidNodeID {
 		panic("double free")
 	}