diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-04-01 10:17:09 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-04-01 10:17:09 +0500 |
| commit | 3817e05dd043f024854b2c9acae6daecf2ff14b8 (patch) | |
| tree | 8a5de1b2c5dc079882e3e1e46ef241a0ac81ca87 /weed/shell/command_volume_fsck.go | |
| parent | 3cedb21bb728add11978d6cf45e7c2d8a2e94d12 (diff) | |
| download | seaweedfs-3817e05dd043f024854b2c9acae6daecf2ff14b8.tar.xz seaweedfs-3817e05dd043f024854b2c9acae6daecf2ff14b8.zip | |
fix collect filer files
Diffstat (limited to 'weed/shell/command_volume_fsck.go')
| -rw-r--r-- | weed/shell/command_volume_fsck.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/weed/shell/command_volume_fsck.go b/weed/shell/command_volume_fsck.go index d02033aa3..557c1e18e 100644 --- a/weed/shell/command_volume_fsck.go +++ b/weed/shell/command_volume_fsck.go @@ -165,13 +165,14 @@ func (c *commandVolumeFsck) collectFilerFileIdAndPaths(dataNodeVolumeIdToVInfo m files := make(map[uint32]*os.File) for _, volumeIdToServer := range dataNodeVolumeIdToVInfo { for vid := range volumeIdToServer { + if _, ok := files[vid]; ok { + continue + } dst, openErr := os.OpenFile(getFilerFileIdFile(tempFolder, vid), os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0644) if openErr != nil { return fmt.Errorf("failed to create file %s: %v", getFilerFileIdFile(tempFolder, vid), openErr) } - if _, ok := volumeIdToServer[vid]; !ok { - files[vid] = dst - } + files[vid] = dst } } defer func() { |