diff options
| author | Guo Lei <guol-fnst@fujitsu.com> | 2022-12-28 17:36:44 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-12-28 01:36:44 -0800 |
| commit | d8cfa1552b4958a6d803184eb423a29c1f18aeaf (patch) | |
| tree | 60a100d069d65fe19391376ab83416556f63fce1 /weed/topology/topology.go | |
| parent | 84492976c914cab5d084f4e242733906c20a3cc5 (diff) | |
| download | seaweedfs-d8cfa1552b4958a6d803184eb423a29c1f18aeaf.tar.xz seaweedfs-d8cfa1552b4958a6d803184eb423a29c1f18aeaf.zip | |
support enable/disable vacuum (#4087)
* stop vacuum
* suspend/resume vacuum
* remove unused code
* rename
* rename param
Diffstat (limited to 'weed/topology/topology.go')
| -rw-r--r-- | weed/topology/topology.go | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/weed/topology/topology.go b/weed/topology/topology.go index 6c6fc73a4..671cdf32c 100644 --- a/weed/topology/topology.go +++ b/weed/topology/topology.go @@ -35,6 +35,7 @@ type Topology struct { volumeSizeLimit uint64 replicationAsMin bool + isDisableVacuum bool Sequence sequence.Sequencer @@ -338,3 +339,13 @@ func (t *Topology) DataNodeRegistration(dcName, rackName string, dn *DataNode) { rack.LinkChildNode(dn) glog.Infof("[%s] reLink To topo ", dn.Id()) } + +func (t *Topology) DisableVacuum() { + glog.V(0).Infof("DisableVacuum") + t.isDisableVacuum = true +} + +func (t *Topology) EnableVacuum() { + glog.V(0).Infof("EnableVacuum") + t.isDisableVacuum = false +} |