diff options
| author | 2026-03-08 03:46:13 +0800 | |
|---|---|---|
| committer | 2026-03-08 03:46:13 +0800 | |
| commit | 4043486a652566923b27d1a90eedcdc8d9b0b3ea (patch) | |
| tree | f43cbaae89ffebe95f973b6de142e0f1a0e091b6 /format/pack/ingest/scan.go | |
| parent | format/pack/ingest: Thin pack fixing progress (diff) | |
| signature | No signature | |
*: Reformat v0.1.75
Diffstat (limited to 'format/pack/ingest/scan.go')
| -rw-r--r-- | format/pack/ingest/scan.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/format/pack/ingest/scan.go b/format/pack/ingest/scan.go index 94251cb9..2fa88b51 100644 --- a/format/pack/ingest/scan.go +++ b/format/pack/ingest/scan.go @@ -22,10 +22,12 @@ func streamPackAndScan(state *ingestState) error { ) utils.WriteProgressf(state.opts.Progress, "validating pack header...\r") + err = readAndValidatePackHeader(state) if err != nil { return err } + utils.WriteProgressf(state.opts.Progress, "validating pack header: done.\n") state.records = make([]objectRecord, 0, state.objectCountHeader) @@ -36,7 +38,7 @@ func streamPackAndScan(state *ingestState) error { step := progressStep(total) utils.WriteProgressf(state.opts.Progress, "receiving objects: 0%% (0/%d)\r", total) - for i := uint32(0); i < total; i++ { + for i := range total { nextOffset, err := scanOneEntry(state, state.stream.consumed) if err != nil { return err |
