fix(snapshot): drop inflate buffer slack from retained payloads

A grown buffer could keep up to twice the payload size for every restored history chunk.

commit: ab3fd846f61cdd8dbea677b1b3f87b18ba831d68
author: brice · 14d ago · 2026-10-08 06:22 UTC
committer: brice · 14d ago · 2026-10-08 06:24 UTC
parent: fab9d89
signature: GPG VerifiedCD88F9E564E0102646FB6077A1A07C7C7C3E349D · arch-gpg Verified for the committer email

1 file · +4 -0

M internal/snapshotcodec/object_compress.go +4 -0


@@ -66,6 +66,10 @@ func inflateObjectPayload(compressed []byte, size uint32) ([]byte, error) {
66	66		return nil, invalid(io.ErrUnexpectedEOF)
67	67		}
68	68		payload := out.Bytes()
	69	+	if cap(payload) > len(payload)+len(payload)/4 {
	70	+	// Restored payloads are retained; drop the growth slack.
	71	+	payload = bytes.Clone(payload)
	72	+	}
69	73		var extra [1]byte
70	74		if n, err := r.Read(extra[:]); n != 0 \|\| err != io.EOF {
71	75		if err == nil \|\| err == io.EOF {


@@ -66,6 +66,10 @@ func inflateObjectPayload(compressed []byte, size uint32) ([]byte, error) {
66	return nil, invalid(io.ErrUnexpectedEOF)	66		return nil, invalid(io.ErrUnexpectedEOF)
67	}	67		}
68	payload := out.Bytes()	68		payload := out.Bytes()
		69	+	if cap(payload) > len(payload)+len(payload)/4 {
		70	+	// Restored payloads are retained; drop the growth slack.
		71	+	payload = bytes.Clone(payload)
		72	+	}
69	var extra [1]byte	73		var extra [1]byte
70	if n, err := r.Read(extra[:]); n != 0 \|\| err != io.EOF {	74		if n, err := r.Read(extra[:]); n != 0 \|\| err != io.EOF {
71	if err == nil \|\| err == io.EOF {	75		if err == nil \|\| err == io.EOF {