diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-14 12:27:34 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-14 12:27:34 -0700 |
| commit | fa610745133a344e761fe9efdde3395ea56e28ba (patch) | |
| tree | 3bb70965fec51887aa3f11e5b0bb22cbd45162cb | |
| parent | fbd8f868a124af47d1c91b742d587c4fab6f2a32 (diff) | |
| download | seaweedfs-fa610745133a344e761fe9efdde3395ea56e28ba.tar.xz seaweedfs-fa610745133a344e761fe9efdde3395ea56e28ba.zip | |
add clientId logging
| -rw-r--r-- | weed/filer/filer.go | 2 | ||||
| -rw-r--r-- | weed/filer/meta_aggregator.go | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/weed/filer/filer.go b/weed/filer/filer.go index 86827c50e..15fe69116 100644 --- a/weed/filer/filer.go +++ b/weed/filer/filer.go @@ -79,7 +79,7 @@ func (f *Filer) MaybeBootstrapFromPeers(self pb.ServerAddress, existingNodes []* return } - glog.V(0).Infof("bootstrap from %v", earliestNode.Address) + glog.V(0).Infof("bootstrap from %v clientId:%d", earliestNode.Address, f.UniqueFileId) err = pb.FollowMetadata(pb.ServerAddress(earliestNode.Address), f.GrpcDialOption, "bootstrap", int32(f.UniqueFileId), "/", nil, 0, snapshotTime.UnixNano(), f.Signature, func(resp *filer_pb.SubscribeMetadataResponse) error { return Replay(f.Store, resp) diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index 11f0d9184..beade3201 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -185,7 +185,7 @@ func (ma *MetaAggregator) doSubscribeToOneFiler(f *Filer, self pb.ServerAddress, return nil } - glog.V(4).Infof("subscribing remote %s meta change: %v", peer, time.Unix(0, lastTsNs)) + glog.V(4).Infof("subscribing remote %s meta change: %v, clientId:%d", peer, time.Unix(0, lastTsNs), ma.filer.UniqueFileId) err = pb.WithFilerClient(true, peer, ma.grpcDialOption, func(client filer_pb.SeaweedFilerClient) error { ctx, cancel := context.WithCancel(context.Background()) defer cancel() |