diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-21 21:16:13 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-21 21:16:13 -0700 |
| commit | e24b25de784daf42a15daf573249d608ebc2b44a (patch) | |
| tree | 53418a50125f664565572aea8e7fa10950c90a12 /weed/server | |
| parent | 4f02f7121d232507bbbba825fa241bc8d5e630ff (diff) | |
| download | seaweedfs-e24b25de784daf42a15daf573249d608ebc2b44a.tar.xz seaweedfs-e24b25de784daf42a15daf573249d608ebc2b44a.zip | |
async meta caching: can stream updates now
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/filer_grpc_server_listen.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/server/filer_grpc_server_listen.go b/weed/server/filer_grpc_server_listen.go index 6dd423007..1da257202 100644 --- a/weed/server/filer_grpc_server_listen.go +++ b/weed/server/filer_grpc_server_listen.go @@ -26,7 +26,7 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest, lastReadTime = time.Unix(0, req.SinceNs) } - eachEventNotificationFn := func(dirPath string, eventNotification *filer_pb.EventNotification) error { + eachEventNotificationFn := func(dirPath string, eventNotification *filer_pb.EventNotification, tsNs int64) error { // get complete path to the file or directory var entryName string @@ -50,6 +50,7 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest, message := &filer_pb.SubscribeMetadataResponse{ Directory: dirPath, EventNotification: eventNotification, + TsNs: tsNs, } if err := stream.Send(message); err != nil { glog.V(0).Infof("=> client %v: %+v", clientName, err) @@ -70,7 +71,7 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest, return fmt.Errorf("unexpected unmarshal filer_pb.SubscribeMetadataResponse: %v", err) } - if err := eachEventNotificationFn(event.Directory, event.EventNotification); err != nil { + if err := eachEventNotificationFn(event.Directory, event.EventNotification, event.TsNs); err != nil { return err } |