gRPC migration update
Change-Id: Icdd1a824948fa994cd36bd121c962f5ecf74e3cf
diff --git a/vendor/github.com/Shopify/sarama/zstd.go b/vendor/github.com/Shopify/sarama/zstd.go
index 58880e2..e23bfc4 100644
--- a/vendor/github.com/Shopify/sarama/zstd.go
+++ b/vendor/github.com/Shopify/sarama/zstd.go
@@ -2,26 +2,17 @@
import (
"github.com/klauspost/compress/zstd"
- "sync"
)
var (
- zstdDec *zstd.Decoder
- zstdEnc *zstd.Encoder
-
- zstdEncOnce, zstdDecOnce sync.Once
+ zstdDec, _ = zstd.NewReader(nil)
+ zstdEnc, _ = zstd.NewWriter(nil, zstd.WithZeroFrames(true))
)
func zstdDecompress(dst, src []byte) ([]byte, error) {
- zstdDecOnce.Do(func() {
- zstdDec, _ = zstd.NewReader(nil)
- })
return zstdDec.DecodeAll(src, dst)
}
func zstdCompress(dst, src []byte) ([]byte, error) {
- zstdEncOnce.Do(func() {
- zstdEnc, _ = zstd.NewWriter(nil, zstd.WithZeroFrames(true))
- })
return zstdEnc.EncodeAll(src, dst), nil
}