snapshot(ticdc): fix the data race when log set to debug caused by pr…

…int logs (#11830) (#11835) close #11827
pingcap · Dec 10, 2024 · d8f0a6e · d8f0a6e
1 parent d9d1ae0
commit d8f0a6e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cdc/entry/schema/snapshot.go b/cdc/entry/schema/snapshot.go
@@ -570,6 +570,9 @@ func (s *Snapshot) SchemaCount() (count int) {
 
 // DumpToString dumps the snapshot to a string.
 func (s *Snapshot) DumpToString() string {
+	s.rwlock.RLock()
+	defer s.rwlock.RUnlock()
+
 	schemas := make([]string, 0, s.inner.schemas.Len())
 	s.IterSchemas(func(dbInfo *timodel.DBInfo) {
 		schemas = append(schemas, fmt.Sprintf("%v", dbInfo))