aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2024-04-28 12:21:57 +0500
committerGitHub <noreply@github.com>2024-04-28 00:21:57 -0700
commit6f9267ebdfa3aeeec2cebdf26399f67ead099298 (patch)
treefc4a07b8ac370defef8769084d1deac31ae7f7a8
parent3d3ee04eb9d801efa618bc986941138dbc424b44 (diff)
downloadseaweedfs-6f9267ebdfa3aeeec2cebdf26399f67ead099298.tar.xz
seaweedfs-6f9267ebdfa3aeeec2cebdf26399f67ead099298.zip
fix: skip file size checking for volume with TTL (#5541)
fix: skip file size checking for volume with tll https://github.com/seaweedfs/seaweedfs/issues/5508
-rw-r--r--weed/storage/volume_checking.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/storage/volume_checking.go b/weed/storage/volume_checking.go
index 4d51e081f..0c5f154e8 100644
--- a/weed/storage/volume_checking.go
+++ b/weed/storage/volume_checking.go
@@ -109,6 +109,9 @@ func verifyNeedleIntegrity(datFile backend.BackendStorageFile, v needle.Version,
return 0, fmt.Errorf("verifyNeedleIntegrity check %s entry offset %d size %d: %v", datFile.Name(), offset, size, err)
}
n.AppendAtNs = util.BytesToUint64(bytes)
+ if n.HasTtl() {
+ return n.AppendAtNs, nil
+ }
fileTailOffset := offset + needle.GetActualSize(size, v)
fileSize, _, err := datFile.GetStat()
if err != nil {