diff options
| author | chrislu <chris.lu@gmail.com> | 2022-10-24 16:50:39 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-10-24 16:50:39 -0700 |
| commit | 377870f4a93ea6d9d27cb2684bc22321ad788a6b (patch) | |
| tree | e22e5286e84dd2e3bd6abaed006b1a43eb03fc97 /weed/shell/command_volume_fsck.go | |
| parent | d5364218b2d87b7bf91d9a7732efb7dac62b0b9b (diff) | |
| download | seaweedfs-377870f4a93ea6d9d27cb2684bc22321ad788a6b.tar.xz seaweedfs-377870f4a93ea6d9d27cb2684bc22321ad788a6b.zip | |
keep system log data
Diffstat (limited to 'weed/shell/command_volume_fsck.go')
| -rw-r--r-- | weed/shell/command_volume_fsck.go | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/weed/shell/command_volume_fsck.go b/weed/shell/command_volume_fsck.go index 1750ae94c..de1f5d969 100644 --- a/weed/shell/command_volume_fsck.go +++ b/weed/shell/command_volume_fsck.go @@ -134,14 +134,10 @@ func (c *commandVolumeFsck) Do(args []string, commandEnv *CommandEnv, writer io. delete(volumeIdToVInfo, volumeId) continue } - // or skip /topics/.system/log without collection name - if (*c.collection != "" && vinfo.collection != *c.collection) || vinfo.collection == "" { + if *c.collection != "" && vinfo.collection != *c.collection { delete(volumeIdToVInfo, volumeId) continue } - if *c.volumeId > 0 && *c.collection == "" { - *c.collection = vinfo.collection - } cutoffFrom := time.Now().Add(-*cutoffTimeAgo).UnixNano() err = c.collectOneVolumeFileIds(dataNodeId, volumeId, vinfo, uint64(cutoffFrom)) if err != nil { @@ -548,7 +544,7 @@ func (c *commandVolumeFsck) oneVolumeFileIdsSubtractFilerFileIds(dataNodeId stri return } - voluemAddr := pb.NewServerAddressWithGrpcPort(dataNodeId, 0) + volumeAddr := pb.NewServerAddressWithGrpcPort(dataNodeId, 0) if err = c.readFilerFileIdFile(volumeId, func(nId types.NeedleId, itemPath util.FullPath) { inUseCount++ if *c.verifyNeedle { @@ -557,7 +553,7 @@ func (c *commandVolumeFsck) oneVolumeFileIdsSubtractFilerFileIds(dataNodeId stri if v.Size > newSize { v.Size = newSize } - if _, err := readSourceNeedleBlob(c.env.option.GrpcDialOption, voluemAddr, volumeId, *v); err != nil { + if _, err := readSourceNeedleBlob(c.env.option.GrpcDialOption, volumeAddr, volumeId, *v); err != nil { fmt.Fprintf(c.writer, "failed to read file %s NeedleBlob %+v: %+v", itemPath, nId, err) if *c.forcePurging { return |