format/pack/ingest: Improve trailer stuff

1 files changed, 4 insertions, 4 deletions

diff --git a/format/pack/ingest/thin_fix.go b/format/pack/ingest/thin_fix.go
index 436d5c88..249fe136 100644
--- a/format/pack/ingest/thin_fix.go
+++ b/format/pack/ingest/thin_fix.go
@@ -37,7 +37,7 @@ func maybeFixThin(state *ingestState) error {
 	if err := state.packFile.Truncate(newEnd); err != nil {
 		return err
 	}
-	state.stream.offset = uint64(newEnd)
+	state.stream.consumed = uint64(newEnd)
 
 	baseIDs := unresolvedThinBaseIDs(state)
 	for _, id := range baseIDs {
@@ -60,7 +60,7 @@ func maybeFixThin(state *ingestState) error {
 
 // appendBaseObject appends one base object as a new packed non-delta entry.
 func appendBaseObject(state *ingestState, id objectid.ObjectID, realType objecttype.Type, content []byte) (int, error) {
-	start := state.stream.offset
+	start := state.stream.consumed
 	header := encodePackEntryHeader(realType, int64(len(content)))
 	if _, err := state.packFile.WriteAt(header, int64(start)); err != nil {
 		return 0, err
@@ -80,7 +80,7 @@ func appendBaseObject(state *ingestState, id objectid.ObjectID, realType objectt
 
 	packedLen := uint64(len(header)) + uint64(counting.n)
 	end := start + packedLen
-	state.stream.offset = end
+	state.stream.consumed = end
 
 	record := objectRecord{
 		offset:       start,
@@ -186,7 +186,7 @@ func rewritePackHeaderAndTrailer(state *ingestState) error {
 	}
 	state.packHash = packHash
 	state.objectCountHeader = uint32(len(state.records))
-	state.stream.offset = uint64(endWithoutTrailer + int64(len(sum)))
+	state.stream.consumed = uint64(endWithoutTrailer + int64(len(sum)))
 
 	return nil
 }