diff options
| author | chrislu <chris.lu@gmail.com> | 2023-01-10 01:35:10 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-01-10 01:35:10 -0800 |
| commit | 86657ed3a808541c23ccb4486e8defee44963306 (patch) | |
| tree | 49f6e9d596f2d1471ba6ee69065432bc06cf44f0 | |
| parent | 28fe5789444b8c6d9dc7c8276599423c30af81b8 (diff) | |
| download | seaweedfs-86657ed3a808541c23ccb4486e8defee44963306.tar.xz seaweedfs-86657ed3a808541c23ccb4486e8defee44963306.zip | |
avoid repeatedly adding manifest chunks
| -rw-r--r-- | weed/mount/weedfs_file_sync.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/mount/weedfs_file_sync.go b/weed/mount/weedfs_file_sync.go index ac18e05ea..e830a4210 100644 --- a/weed/mount/weedfs_file_sync.go +++ b/weed/mount/weedfs_file_sync.go @@ -152,13 +152,14 @@ func (wfs *WFS) doFlush(fh *FileHandle, uid, gid uint32) fuse.Status { manifestChunks, nonManifestChunks := filer.SeparateManifestChunks(entry.GetChunks()) chunks, _ := filer.CompactFileChunks(wfs.LookupFn(), nonManifestChunks) + fh.entryChunkGroup.SetChunks(chunks) + chunks, manifestErr := filer.MaybeManifestize(wfs.saveDataAsChunk(fileFullPath), chunks) if manifestErr != nil { // not good, but should be ok glog.V(0).Infof("MaybeManifestize: %v", manifestErr) } entry.Chunks = append(chunks, manifestChunks...) - fh.entryChunkGroup.SetChunks(entry.Chunks) wfs.mapPbIdFromLocalToFiler(request.Entry) defer wfs.mapPbIdFromFilerToLocal(request.Entry) |