From 54ba2c886845f567e72f317053ec1b49ad3d72a1 Mon Sep 17 00:00:00 2001 From: Seyed Mahdi Sadegh Shobeiri <36403983+SmsS4@users.noreply.github.com> Date: Sat, 23 Dec 2023 20:48:16 +0330 Subject: [PATCH] Fix cutoffTimeAgo in findMissingChunksInFiler (#5132) --- weed/shell/command_volume_fsck.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/weed/shell/command_volume_fsck.go b/weed/shell/command_volume_fsck.go index 29c724c49..7a3932aa1 100644 --- a/weed/shell/command_volume_fsck.go +++ b/weed/shell/command_volume_fsck.go @@ -136,7 +136,7 @@ func (c *commandVolumeFsck) Do(args []string, commandEnv *CommandEnv, writer io. return fmt.Errorf("read filer buckets path: %v", err) } - collectCutoffFromAtNs := time.Now().UnixNano() + collectCutoffFromAtNs := time.Now().Add(-*cutoffTimeAgo).UnixNano() // collect each volume file ids for dataNodeId, volumeIdToVInfo := range dataNodeVolumeIdToVInfo { for volumeId, vinfo := range volumeIdToVInfo { @@ -150,8 +150,7 @@ func (c *commandVolumeFsck) Do(args []string, commandEnv *CommandEnv, writer io. delete(volumeIdToVInfo, volumeId) continue } - cutoffFrom := time.Now().Add(-*cutoffTimeAgo).UnixNano() - err = c.collectOneVolumeFileIds(dataNodeId, volumeId, vinfo, uint64(cutoffFrom)) + err = c.collectOneVolumeFileIds(dataNodeId, volumeId, vinfo, uint64(collectCutoffFromAtNs)) if err != nil { return fmt.Errorf("failed to collect file ids from volume %d on %s: %v", volumeId, vinfo.server, err) }