do not forget to vacuum if cluster changes

This commit is contained in:
Chris Lu 2016-05-09 09:58:06 -07:00
parent e8193ec201
commit 3626ec5cf7

View file

@ -20,8 +20,8 @@ func (t *Topology) StartRefreshWritableVolumes(garbageThreshold string) {
}()
go func(garbageThreshold string) {
c := time.Tick(15 * time.Minute)
if t.IsLeader() {
for _ = range c {
for _ = range c {
if t.IsLeader() {
t.Vacuum(garbageThreshold)
}
}