From 08c3fc6ca9f1f1a73aa551d46c31e945d27d136f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Nicol=C3=A1s=20Pazos?= Date: Wed, 1 Nov 2023 20:12:52 -0300 Subject: [PATCH] fix: zstd to correctly reset buffer --- storage/remote/compression.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/storage/remote/compression.go b/storage/remote/compression.go index 4895208e20..a7d5dbe045 100644 --- a/storage/remote/compression.go +++ b/storage/remote/compression.go @@ -123,7 +123,7 @@ type snappyAltCompression struct { } func (s *snappyAltCompression) Compress(data []byte) ([]byte, error) { - s.buf = s.buf[0:cap(s.buf)] + s.buf = s.buf[:0] res := reSnappy.Encode(s.buf, data) if n := reSnappy.MaxEncodedLen(len(data)); n > len(s.buf) { s.buf = make([]byte, n) @@ -131,7 +131,7 @@ func (s *snappyAltCompression) Compress(data []byte) ([]byte, error) { return res, nil } func (s *snappyAltCompression) Decompress(data []byte) ([]byte, error) { - s.buf = s.buf[0:cap(s.buf)] + s.buf = s.buf[:0] uncompressed, err := reSnappy.Decode(s.buf, data) if len(uncompressed) > cap(s.buf) { s.buf = uncompressed @@ -152,7 +152,7 @@ func (s *s2Compression) Compress(data []byte) ([]byte, error) { } func (s *s2Compression) Decompress(data []byte) ([]byte, error) { - s.buf = s.buf[0:cap(s.buf)] + s.buf = s.buf[:0] uncompressed, err := reS2.Decode(s.buf, data) if len(uncompressed) > cap(s.buf) { s.buf = uncompressed @@ -170,7 +170,7 @@ func (z *zstdCompression) Compress(data []byte) ([]byte, error) { if err != nil { return nil, err } - z.buf = z.buf[0:cap(z.buf)] + z.buf = z.buf[:0] res := w.EncodeAll(data, z.buf) if len(res) > cap(z.buf) { z.buf = res