mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2025-08-01 17:46:55 +08:00
clean up chunks in manifest
This commit is contained in:
parent
64926d2345
commit
44057a4de1
@ -45,6 +45,7 @@ func ResolveChunkManifest(lookupFileIdFn LookupFileIdFunctionType, chunks []*fil
|
|||||||
}
|
}
|
||||||
manifestChunks = append(manifestChunks, chunk)
|
manifestChunks = append(manifestChunks, chunk)
|
||||||
// recursive
|
// recursive
|
||||||
|
filer_pb.AfterEntryDeserialization(m.Chunks)
|
||||||
dchunks, mchunks, subErr := ResolveChunkManifest(lookupFileIdFn, m.Chunks)
|
dchunks, mchunks, subErr := ResolveChunkManifest(lookupFileIdFn, m.Chunks)
|
||||||
if subErr != nil {
|
if subErr != nil {
|
||||||
return chunks, nil, subErr
|
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) {
|
func mergeIntoManifest(saveFunc SaveDataAsChunkFunctionType, dataChunks []*filer_pb.FileChunk) (manifestChunk *filer_pb.FileChunk, err error) {
|
||||||
|
|
||||||
|
filer_pb.BeforeEntrySerialization(dataChunks)
|
||||||
|
|
||||||
// create and serialize the manifest
|
// create and serialize the manifest
|
||||||
data, serErr := proto.Marshal(&filer_pb.FileChunkManifest{
|
data, serErr := proto.Marshal(&filer_pb.FileChunkManifest{
|
||||||
Chunks: dataChunks,
|
Chunks: dataChunks,
|
||||||
|
Loading…
Reference in New Issue
Block a user