aboutsummaryrefslogtreecommitdiff
path: root/weed/shell
diff options
context:
space:
mode:
Diffstat (limited to 'weed/shell')
-rw-r--r--weed/shell/command_volume_check_disk.go4
-rw-r--r--weed/shell/command_volume_fix_replication.go4
-rw-r--r--weed/shell/command_volume_fsck.go4
3 files changed, 6 insertions, 6 deletions
diff --git a/weed/shell/command_volume_check_disk.go b/weed/shell/command_volume_check_disk.go
index f1f3a0728..f72dff243 100644
--- a/weed/shell/command_volume_check_disk.go
+++ b/weed/shell/command_volume_check_disk.go
@@ -48,8 +48,8 @@ func (c *commandVolumeCheckDisk) Help() string {
`
}
-func (c *commandVolumeCheckDisk) HasTag(CommandTag) bool {
- return false
+func (c *commandVolumeCheckDisk) HasTag(tag CommandTag) bool {
+ return tag == ResourceHeavy
}
func (c *commandVolumeCheckDisk) getVolumeStatusFileCount(vid uint32, dn *master_pb.DataNodeInfo) (totalFileCount, deletedFileCount uint64) {
diff --git a/weed/shell/command_volume_fix_replication.go b/weed/shell/command_volume_fix_replication.go
index 8337f5368..55c801284 100644
--- a/weed/shell/command_volume_fix_replication.go
+++ b/weed/shell/command_volume_fix_replication.go
@@ -55,8 +55,8 @@ func (c *commandVolumeFixReplication) Help() string {
`
}
-func (c *commandVolumeFixReplication) HasTag(CommandTag) bool {
- return false
+func (c *commandVolumeFixReplication) HasTag(tag CommandTag) bool {
+ return tag == ResourceHeavy
}
func (c *commandVolumeFixReplication) Do(args []string, commandEnv *CommandEnv, writer io.Writer) (err error) {
diff --git a/weed/shell/command_volume_fsck.go b/weed/shell/command_volume_fsck.go
index 89c15a8af..d68ec8de5 100644
--- a/weed/shell/command_volume_fsck.go
+++ b/weed/shell/command_volume_fsck.go
@@ -79,8 +79,8 @@ func (c *commandVolumeFsck) Help() string {
`
}
-func (c *commandVolumeFsck) HasTag(CommandTag) bool {
- return false
+func (c *commandVolumeFsck) HasTag(tag CommandTag) bool {
+ return tag == ResourceHeavy
}
func (c *commandVolumeFsck) Do(args []string, commandEnv *CommandEnv, writer io.Writer) (err error) {