From 067eb15e707378c10b5d897c39bb681110ab268a Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Thu, 1 Jul 2021 01:24:07 -0700 Subject: [PATCH] remove debug messages --- weed/server/filer_grpc_server_sub_meta.go | 15 +-------------- 1 file changed, 1 insertion(+), 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)