aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/dir_rename.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-01-10 00:52:16 -0800
committerchrislu <chris.lu@gmail.com>2022-01-10 00:52:16 -0800
commitcbc055dc2b1cfdea16ae557780a9476b566899fe (patch)
treee45b8381abad4b03e6ab5a966f25728b8805daf4 /weed/filesys/dir_rename.go
parent19555385f7b99bce0e1f562f3cd4a4f440dd3d8e (diff)
downloadseaweedfs-cbc055dc2b1cfdea16ae557780a9476b566899fe.tar.xz
seaweedfs-cbc055dc2b1cfdea16ae557780a9476b566899fe.zip
mount: file fsync
fix https://github.com/chrislusf/seaweedfs/issues/2561
Diffstat (limited to 'weed/filesys/dir_rename.go')
-rw-r--r--weed/filesys/dir_rename.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/filesys/dir_rename.go b/weed/filesys/dir_rename.go
index f28c8af92..a18ed8243 100644
--- a/weed/filesys/dir_rename.go
+++ b/weed/filesys/dir_rename.go
@@ -114,7 +114,9 @@ func (dir *Dir) handleRenameResponse(ctx context.Context, resp *filer_pb.StreamR
if existingHandle, found := dir.wfs.handles[inodeId]; found && existingHandle != nil {
glog.V(4).Infof("opened file handle %s => %s", oldPath, newPath)
delete(dir.wfs.handles, inodeId)
+ existingHandle.handle = newPath.AsInode()
existingHandle.f.entry.Name = newName
+ existingHandle.f.id = newPath.AsInode()
dir.wfs.handles[newPath.AsInode()] = existingHandle
}
dir.wfs.handlesLock.Unlock()