diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-09-05 22:52:15 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-09-05 22:52:15 -0700 |
| commit | bba90ff3c822914a8a2da4369e65756ff366cef2 (patch) | |
| tree | 9c17056bd283dacee098e5eb927b4a96bec5775f /weed/filer | |
| parent | 71b0e256c79149cff7be56f0962339def20b7979 (diff) | |
| download | seaweedfs-bba90ff3c822914a8a2da4369e65756ff366cef2.tar.xz seaweedfs-bba90ff3c822914a8a2da4369e65756ff366cef2.zip | |
read filer signature
Diffstat (limited to 'weed/filer')
| -rw-r--r-- | weed/filer/meta_aggregator.go | 10 |
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 |
