Skip to content

Commit 96ff926

Browse files
lzj47010suxb201
authored andcommitted
fix: ensure synchronous data forwarding for RDB base files in AOF loading
1 parent 1a78b85 commit 96ff926

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

internal/reader/parsing_aof.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -727,7 +727,12 @@ func (aofInfo *INFO) ParsingSingleAppendOnlyFile(ctx context.Context, FileName s
727727
log.Infof("Reading RDB Base File on AOF loading...")
728728
rdbOpt := RdbReaderOptions{Filepath: AOFFilepath}
729729
ldRDB := NewRDBReader(&rdbOpt)
730-
ldRDB.StartRead(ctx)
730+
rdbChrs := ldRDB.StartRead(ctx)
731+
for _, chr := range rdbChrs {
732+
for e := range chr {
733+
aofInfo.ch <- e
734+
}
735+
}
731736
return AOFOk
732737
}
733738
// load single aof file

0 commit comments

Comments
 (0)