diff options
| author | 2026-01-30 17:27:10 +0100 | |
|---|---|---|
| committer | 2026-01-30 17:27:10 +0100 | |
| commit | c1f17baa57bad0f61e639fc39c8cd5e4872142f6 (patch) | |
| tree | 715935cbfee3358c6e23008680d80473e4a21061 /packed_write_pack.go | |
| parent | README: Update packfile/thin/delta related feature items (diff) | |
| signature | No signature | |
packed, delta: Some improvements for base selection
* sort objects by type then size to improve window quality
* prune bad candidates with size ratio checks
* have objects are preferred
Diffstat (limited to 'packed_write_pack.go')
| -rw-r--r-- | packed_write_pack.go | 66 |
1 files changed, 58 insertions, 8 deletions
diff --git a/packed_write_pack.go b/packed_write_pack.go index 504c1087..2d3eb4f6 100644 --- a/packed_write_pack.go +++ b/packed_write_pack.go @@ -5,6 +5,7 @@ import ( "encoding/binary" "hash" "io" + "sort" "codeberg.org/lindenii/furgit/internal/zlib" ) @@ -310,7 +311,12 @@ func (repo *Repository) packWrite(w io.Writer, objects []Hash, opts packWriteOpt return Hash{}, ErrInvalidObject } - pw, err := newPackWriter(w, repo.hashAlgo, uint32(len(objects))) + objInfos, err := repo.packBuildObjectList(objects, opts.EnableDeltas) + if err != nil { + return Hash{}, err + } + + pw, err := newPackWriter(w, repo.hashAlgo, uint32(len(objInfos))) if err != nil { return Hash{}, err } @@ -335,15 +341,16 @@ func (repo *Repository) packWrite(w io.Writer, objects []Hash, opts packWriteOpt } } - for _, id := range objects { - ty, body, err := repo.ReadObjectTypeRaw(id) + for _, info := range objInfos { + ty, body, err := repo.ReadObjectTypeRaw(info.id) if err != nil { return Hash{}, err } obj := &objectToPack{ - id: id, + id: info.id, ty: ty, body: body, + size: info.size, inPack: true, } startOffset := pw.bytesWritten @@ -414,16 +421,59 @@ func (repo *Repository) seedDeltaCandidatesFromHaves(ctx *deltaContext, haves [] return err } candidate := &objectToPack{ - id: obj.ID, - ty: ty, - body: body, - inPack: false, + id: obj.ID, + ty: ty, + body: body, + size: len(body), + inPack: false, + preferred: true, } ctx.addCandidate(candidate) } return walk.Err() } +type packObjectInfo struct { + id Hash + ty ObjectType + size int + index int +} + +func (repo *Repository) packBuildObjectList(objects []Hash, enableDeltas bool) ([]packObjectInfo, error) { + if repo == nil { + return nil, ErrInvalidObject + } + infos := make([]packObjectInfo, 0, len(objects)) + for i, id := range objects { + ty, size, err := repo.ReadObjectTypeSize(id) + if err != nil { + return nil, err + } + infos = append(infos, packObjectInfo{ + id: id, + ty: ty, + size: int(size), + index: i, + }) + } + if !enableDeltas { + return infos, nil + } + sort.SliceStable(infos, func(i, j int) bool { + ai := infos[i] + aj := infos[j] + if ai.ty != aj.ty { + return ai.ty < aj.ty + } + if ai.size != aj.size { + return ai.size > aj.size + } + return ai.index < aj.index + }) + return infos, nil +} + type packWriteOptions struct { EnableDeltas bool EnableThinPack bool |
