diff options
| author | Max Denushev <mdenushev@ya.ru> | 2024-09-25 02:15:54 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-09-24 16:15:54 -0700 |
| commit | d056c0ddf2b7e34a5c7e8fdfe829e5c74e65a068 (patch) | |
| tree | fffe7a06af9a4dee525c40cdcf1db02f5190bddd /weed/shell/command_volume_fsck.go | |
| parent | c96b2ce8e55e84fe46219886f15deb186653c39a (diff) | |
| download | seaweedfs-d056c0ddf2b7e34a5c7e8fdfe829e5c74e65a068.tar.xz seaweedfs-d056c0ddf2b7e34a5c7e8fdfe829e5c74e65a068.zip | |
fix(volume): don't persist RO state in specific cases (#6058)
* fix(volume): don't persist RO state in specific cases
* fix(volume): writable always persist
Diffstat (limited to 'weed/shell/command_volume_fsck.go')
| -rw-r--r-- | weed/shell/command_volume_fsck.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/shell/command_volume_fsck.go b/weed/shell/command_volume_fsck.go index acb0ee5ad..f40702335 100644 --- a/weed/shell/command_volume_fsck.go +++ b/weed/shell/command_volume_fsck.go @@ -359,12 +359,12 @@ func (c *commandVolumeFsck) findExtraChunksInVolumeServers(dataNodeVolumeIdToVIn needleVID := needle.VolumeId(volumeId) if isReadOnlyReplicas[volumeId] { - err := markVolumeWritable(c.env.option.GrpcDialOption, needleVID, server, true) + err := markVolumeWritable(c.env.option.GrpcDialOption, needleVID, server, true, false) if err != nil { return fmt.Errorf("mark volume %d read/write: %v", volumeId, err) } fmt.Fprintf(c.writer, "temporarily marked %d on server %v writable for forced purge\n", volumeId, server) - defer markVolumeWritable(c.env.option.GrpcDialOption, needleVID, server, false) + defer markVolumeWritable(c.env.option.GrpcDialOption, needleVID, server, false, false) fmt.Fprintf(c.writer, "marked %d on server %v writable for forced purge\n", volumeId, server) } |