aboutsummaryrefslogtreecommitdiff
path: root/weed/filer
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-09-05 22:52:15 -0700
committerChris Lu <chris.lu@gmail.com>2020-09-05 22:52:15 -0700
commitbba90ff3c822914a8a2da4369e65756ff366cef2 (patch)
tree9c17056bd283dacee098e5eb927b4a96bec5775f /weed/filer
parent71b0e256c79149cff7be56f0962339def20b7979 (diff)
downloadseaweedfs-bba90ff3c822914a8a2da4369e65756ff366cef2.tar.xz
seaweedfs-bba90ff3c822914a8a2da4369e65756ff366cef2.zip
read filer signature
Diffstat (limited to 'weed/filer')
-rw-r--r--weed/filer/meta_aggregator.go10
1 files changed, 10 insertions, 0 deletions
diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go
index 506f03e4c..f8459e724 100644
--- a/weed/filer/meta_aggregator.go
+++ b/weed/filer/meta_aggregator.go
@@ -47,6 +47,16 @@ func (ma *MetaAggregator) StartLoopSubscribe(f *Filer, self string) {
func (ma *MetaAggregator) subscribeToOneFiler(f *Filer, self string, filer string) {
+ /*
+ Each filer reads the "filer.store.id", which is the store's signature when filer starts.
+
+ When reading from other filers' local meta changes:
+ * if the received change does not contain signature from self, apply the change to current filer store.
+
+ Upon connecting to other filers, need to remember their signature and their offsets.
+
+ */
+
var maybeReplicateMetadataChange func(*filer_pb.SubscribeMetadataResponse)
lastPersistTime := time.Now()
changesSinceLastPersist := 0