diff options
| author | Seyed Mahdi Sadegh Shobeiri <36403983+SmsS4@users.noreply.github.com> | 2023-12-23 20:48:16 +0330 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-12-23 09:18:16 -0800 |
| commit | 54ba2c886845f567e72f317053ec1b49ad3d72a1 (patch) | |
| tree | f46e07cd0168f8f23109d6b118c9b5cb6352ed31 | |
| parent | 03c4b2e9880765746bd47520d613515336a3f679 (diff) | |
| download | seaweedfs-54ba2c886845f567e72f317053ec1b49ad3d72a1.tar.xz seaweedfs-54ba2c886845f567e72f317053ec1b49ad3d72a1.zip | |
Fix cutoffTimeAgo in findMissingChunksInFiler (#5132)
| -rw-r--r-- | weed/shell/command_volume_fsck.go | 5 |
1 files 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) } |