diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-07-01 01:24:07 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-07-01 01:24:07 -0700 |
| commit | 067eb15e707378c10b5d897c39bb681110ab268a (patch) | |
| tree | 5c4c809f301b62d22d73af537da69e18ec4048be | |
| parent | b6240903986b9069b31a94df5e11594a1d1f2504 (diff) | |
| download | seaweedfs-067eb15e707378c10b5d897c39bb681110ab268a.tar.xz seaweedfs-067eb15e707378c10b5d897c39bb681110ab268a.zip | |
remove debug messages
| -rw-r--r-- | weed/server/filer_grpc_server_sub_meta.go | 15 |
1 files changed, 1 insertions, 14 deletions
diff --git a/weed/server/filer_grpc_server_sub_meta.go b/weed/server/filer_grpc_server_sub_meta.go index e79406bbe..18505a95f 100644 --- a/weed/server/filer_grpc_server_sub_meta.go +++ b/weed/server/filer_grpc_server_sub_meta.go @@ -25,20 +25,7 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest, lastReadTime := time.Unix(0, req.SinceNs) glog.V(0).Infof(" %v starts to subscribe %s from %+v", clientName, req.PathPrefix, lastReadTime) - t := fs.eachEventNotificationFn(req, stream, clientName, req.Signature) - - eachEventNotificationFn := func(dirPath string, eventNotification *filer_pb.EventNotification, tsNs int64) error { - found := false - for _, sig := range eventNotification.Signatures { - if req.Signature == sig { - found = true - } - } - if !found { - glog.V(0).Infof("fresh message for %s(%d) %s %s", clientName, req.Signature, dirPath, eventNotification.String()) - } - return t(dirPath, eventNotification, tsNs) - } + eachEventNotificationFn := fs.eachEventNotificationFn(req, stream, clientName, req.Signature) eachLogEntryFn := eachLogEntryFn(eachEventNotificationFn) |
