aboutsummaryrefslogtreecommitdiff
path: root/weed/filer2/filer_notify.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filer2/filer_notify.go')
-rw-r--r--weed/filer2/filer_notify.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/filer2/filer_notify.go b/weed/filer2/filer_notify.go
index 7fc64a1be..b8fe1dbfb 100644
--- a/weed/filer2/filer_notify.go
+++ b/weed/filer2/filer_notify.go
@@ -6,7 +6,7 @@ import (
"github.com/chrislusf/seaweedfs/weed/glog"
)
-func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry) {
+func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry, deleteChunks bool) {
var key string
if oldEntry != nil {
key = string(oldEntry.FullPath)
@@ -23,13 +23,13 @@ func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry) {
notification.Queue.SendMessage(
key,
&filer_pb.EventNotification{
- OldEntry: toProtoEntry(oldEntry),
- NewEntry: toProtoEntry(newEntry),
+ OldEntry: toProtoEntry(oldEntry),
+ NewEntry: toProtoEntry(newEntry),
+ DeleteChunks: deleteChunks,
},
)
}
-
}
func toProtoEntry(entry *Entry) *filer_pb.Entry {