diff --git a/storage/core/ragdoll/wal/wal.go b/storage/core/ragdoll/wal/wal.go index d9bbc20..86795b6 100644 --- a/storage/core/ragdoll/wal/wal.go +++ b/storage/core/ragdoll/wal/wal.go @@ -427,7 +427,7 @@ func (wal *Log) loadSegments() error { err = activeSegment.open(wal.opts.dataPerm) if err != nil { // todo:调研 损坏恢复 - if errors.Is(err, errs.NewCorruptErr()) { + if errs.GetCode(err) == errs.CorruptErrCode { wal.corrupted = true } return err diff --git a/storage/core/ragdoll/wal/wal_test.go b/storage/core/ragdoll/wal/wal_test.go index 0349918..a604a36 100644 --- a/storage/core/ragdoll/wal/wal_test.go +++ b/storage/core/ragdoll/wal/wal_test.go @@ -575,6 +575,11 @@ func TestLog_Corrupt(t *testing.T) { // TestLog_Sync 同步磁盘 func TestLog_Sync(t *testing.T) { + _, err := os.Create("../../../../test_data/wal/20000000.active") + if err != nil { + t.Error(err) + } + segmentSize := 100 * consts.MB opts := NewOptions(). SetSegmentCapacity(int64(segmentSize))