|
@ -100,7 +100,8 @@ func (ma *MetaAggregator) loopSubscribeToOnefiler(f *Filer, self pb.ServerAddres |
|
|
} |
|
|
} |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
glog.V(0).Infof("subscribing remote %s meta change: %v", peer, err) |
|
|
glog.V(0).Infof("subscribing remote %s meta change: %v", peer, err) |
|
|
} else if lastTsNs < nextLastTsNs { |
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
if lastTsNs < nextLastTsNs { |
|
|
lastTsNs = nextLastTsNs |
|
|
lastTsNs = nextLastTsNs |
|
|
} |
|
|
} |
|
|
time.Sleep(1733 * time.Millisecond) |
|
|
time.Sleep(1733 * time.Millisecond) |
|
|