diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-20 22:01:39 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-20 22:01:39 -0700 |
| commit | 44057a4de18e4fdc9b9249d76ba8208654b507ee (patch) | |
| tree | 6c8b4b71a8e0fca5091b9012ceb1340fa8ff1567 | |
| parent | 64926d2345204e7100240f4d598641b4ecc10ee6 (diff) | |
| download | seaweedfs-44057a4de18e4fdc9b9249d76ba8208654b507ee.tar.xz seaweedfs-44057a4de18e4fdc9b9249d76ba8208654b507ee.zip | |
clean up chunks in manifest
| -rw-r--r-- | weed/filer2/filechunk_manifest.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/filer2/filechunk_manifest.go b/weed/filer2/filechunk_manifest.go index e7b4df1fe..62d2c6e7f 100644 --- a/weed/filer2/filechunk_manifest.go +++ b/weed/filer2/filechunk_manifest.go @@ -45,6 +45,7 @@ func ResolveChunkManifest(lookupFileIdFn LookupFileIdFunctionType, chunks []*fil } manifestChunks = append(manifestChunks, chunk) // recursive + filer_pb.AfterEntryDeserialization(m.Chunks) dchunks, mchunks, subErr := ResolveChunkManifest(lookupFileIdFn, m.Chunks) if subErr != nil { return chunks, nil, subErr @@ -107,6 +108,8 @@ func doMaybeManifestize(saveFunc SaveDataAsChunkFunctionType, inputChunks []*fil func mergeIntoManifest(saveFunc SaveDataAsChunkFunctionType, dataChunks []*filer_pb.FileChunk) (manifestChunk *filer_pb.FileChunk, err error) { + filer_pb.BeforeEntrySerialization(dataChunks) + // create and serialize the manifest data, serErr := proto.Marshal(&filer_pb.FileChunkManifest{ Chunks: dataChunks, |