diff options
Diffstat (limited to 'weed/filer2/filer.go')
| -rw-r--r-- | weed/filer2/filer.go | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/weed/filer2/filer.go b/weed/filer2/filer.go index 823371a6b..475e79a17 100644 --- a/weed/filer2/filer.go +++ b/weed/filer2/filer.go @@ -90,6 +90,9 @@ func (f *Filer) CreateEntry(entry *Entry) error { if mkdirErr != nil { return fmt.Errorf("mkdir %s: %v", dirPath, mkdirErr) } + + f.NotifyUpdateEvent(nil, dirEntry) + } else if !dirEntry.IsDirectory() { return fmt.Errorf("%s is a file", dirPath) } @@ -122,6 +125,8 @@ func (f *Filer) CreateEntry(entry *Entry) error { return fmt.Errorf("insert entry %s: %v", entry.FullPath, err) } + f.NotifyUpdateEvent(oldEntry, entry) + f.deleteChunksIfNotNew(oldEntry, entry) return nil @@ -170,6 +175,9 @@ func (f *Filer) DeleteEntryMetaAndData(p FullPath, isRecursive bool, shouldDelet return nil } glog.V(0).Infof("deleting entry %v", p) + + f.NotifyUpdateEvent(entry, nil) + return f.store.DeleteEntry(p) } |