diff options
| -rw-r--r-- | weed/filer/meta_aggregator.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index fb96ee01b..d81645a85 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -100,7 +100,8 @@ func (ma *MetaAggregator) loopSubscribeToOnefiler(f *Filer, self pb.ServerAddres } if err != nil { glog.V(0).Infof("subscribing remote %s meta change: %v", peer, err) - } else if lastTsNs < nextLastTsNs { + } + if lastTsNs < nextLastTsNs { lastTsNs = nextLastTsNs } time.Sleep(1733 * time.Millisecond) |