diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-31 22:51:41 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-31 22:51:41 -0700 |
| commit | 303bd067b568dc4834753fe54b17365757ef5406 (patch) | |
| tree | 3ff9d718226a07f647076ed675513ce4450593ba /weed/mount/weedfs_rename.go | |
| parent | 5fbe437ee946ddd5287c78a4fadbdaacf0773bd6 (diff) | |
| download | seaweedfs-303bd067b568dc4834753fe54b17365757ef5406.tar.xz seaweedfs-303bd067b568dc4834753fe54b17365757ef5406.zip | |
Revert "rename: delete source entry metadata only, skipping hard links"
This reverts commit 03466f955e7907f5e7442dd3e60c45a3ab261ea3.
fix https://github.com/seaweedfs/seaweedfs/issues/3386
Diffstat (limited to 'weed/mount/weedfs_rename.go')
| -rw-r--r-- | weed/mount/weedfs_rename.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mount/weedfs_rename.go b/weed/mount/weedfs_rename.go index fc2243aac..42dcf348d 100644 --- a/weed/mount/weedfs_rename.go +++ b/weed/mount/weedfs_rename.go @@ -223,7 +223,7 @@ func (wfs *WFS) handleRenameResponse(ctx context.Context, resp *filer_pb.StreamR if resp.EventNotification.NewEntry != nil { // with new entry, the old entry name also exists. This is the first step to create new entry newEntry := filer.FromPbEntry(resp.EventNotification.NewParentPath, resp.EventNotification.NewEntry) - if err := wfs.metaCache.AtomicUpdateEntryFromFiler(ctx, "", newEntry, false); err != nil { + if err := wfs.metaCache.AtomicUpdateEntryFromFiler(ctx, "", newEntry); err != nil { return err } @@ -248,7 +248,7 @@ func (wfs *WFS) handleRenameResponse(ctx context.Context, resp *filer_pb.StreamR } else if resp.EventNotification.OldEntry != nil { // without new entry, only old entry name exists. This is the second step to delete old entry - if err := wfs.metaCache.AtomicUpdateEntryFromFiler(ctx, util.NewFullPath(resp.Directory, resp.EventNotification.OldEntry.Name), nil, resp.EventNotification.DeleteChunks); err != nil { + if err := wfs.metaCache.AtomicUpdateEntryFromFiler(ctx, util.NewFullPath(resp.Directory, resp.EventNotification.OldEntry.Name), nil); err != nil { return err } } |