test(ragdoll-wal): 补充单segment文件中blcokIdx达到wal blockIdx上限时开始循环测试case

Trinoooo · Feb 18, 2024 · 74aa252 · 74aa252
1 parent aae4a5f
commit 74aa252
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git 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
@@ -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))