lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-19 14:39:24 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add notification log

Browse Source
This commit is contained in:
Chris Lu
2018-09-16 11:20:36 -07:00
parent 5c6e3f457f
commit 70e67b7c6d
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
weed/filer2/filer_notify.go
View File

@@ -3,6 +3,7 @@ package filer2
import ( import (
"github.com/chrislusf/seaweedfs/weed/notification" "github.com/chrislusf/seaweedfs/weed/notification"
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
"github.com/chrislusf/seaweedfs/weed/glog"
) )
func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry) { func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry) {
@@ -17,6 +18,8 @@ func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry) {
if notification.Queue != nil { if notification.Queue != nil {
glog.V(3).Infof("notifying entry update %v", key)
notification.Queue.SendMessage( notification.Queue.SendMessage(
key, key,
&filer_pb.EventNotification{ &filer_pb.EventNotification{