mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2026-10-08 07:17:48 +02:00
skip resource heavy commands from running on master nodes
This commit is contained in:
1 parent
ec30a504ba
commit
6564ceda91
4 files changed
+10
-6
No files matched your search
@@ -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) {
|
||||
|
||||
@@ -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) {
|
||||
|
||||
@@ -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) {
|
||||
|
||||
Reference in new issue
Block a user