From b252c04f6b257b32fc6457b7f58cc1bef91eb8d5 Mon Sep 17 00:00:00 2001
From: Runxi Yu
Date: Sun, 8 Mar 2026 02:26:02 +0800
Subject: format/pack/ingest: Looks like that's not actually the consumed we
 want

---
 format/pack/ingest/entry.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

(limited to 'format/pack/ingest/entry.go')

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,
-- 
cgit v1.3.1-10-gc9f91