diff options
| author |  Runxi Yu | 2026-03-08 02:26:02 +0800 |
|---|---|---|
| committer | Runxi Yu | 2026-03-08 02:26:30 +0800 |
| commit | b252c04f6b257b32fc6457b7f58cc1bef91eb8d5 (patch) | |
| tree | e1beaf64eb1ceaede977fa8b6a06eb964eb39ecf /format/pack/ingest/entry.go | |
| parent | receivepack: Flush I/O (diff) | |
| signature | No signature | |
format/pack/ingest: Looks like that's not actually the consumed we want
Diffstat (limited to 'format/pack/ingest/entry.go')
| -rw-r--r-- | format/pack/ingest/entry.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/format/pack/ingest/entry.go b/format/pack/ingest/entry.go index f89ad4c8..5d22ada2 100644 --- a/format/pack/ingest/entry.go +++ b/format/pack/ingest/entry.go @@ -16,11 +16,15 @@ func scanOneEntry(state *ingestState, startOffset uint64) (uint64, error) { return 0, err } - contentLen, consumedInput, oid, err := drainEntryPayload(state, record) + payloadStartConsumed := state.stream.consumed + + contentLen, oid, err := drainEntryPayload(state, record) if err != nil { return 0, err } + consumedInput := state.stream.consumed - payloadStartConsumed + if contentLen != record.declaredSize { return 0, &MalformedPackEntryError{ Offset: startOffset, |