From d741ed66db44c2058e30c260e2a75eeec7308bd1 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sat, 5 Sep 2020 23:02:52 -0700 Subject: [PATCH] check whether shares the same filer store --- weed/filer/meta_aggregator.go | 22 +++++++++++++++++----- 1 file changed, 17 insertions(+), 5 deletions(-) diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index f8459e724..18049ee04 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -48,14 +48,14 @@ 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. + 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. + 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. + Upon connecting to other filers, need to remember their signature and their offsets. - */ + */ var maybeReplicateMetadataChange func(*filer_pb.SubscribeMetadataResponse) lastPersistTime := time.Now() @@ -139,3 +139,15 @@ func (ma *MetaAggregator) subscribeToOneFiler(f *Filer, self string, filer strin } } } + +func (ma *MetaAggregator) isSameFilerStore(f *Filer, peer string) (isSame bool, err error) { + err = pb.WithFilerClient(peer, ma.grpcDialOption, func(client filer_pb.SeaweedFilerClient) error { + resp, err := client.GetFilerConfiguration(context.Background(), &filer_pb.GetFilerConfigurationRequest{}) + if err != nil { + return err + } + isSame = f.Signature == resp.Signature + return nil + }) + return +}