From 450d96ec9f9f21565966d667e76d4f5efaae6128 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Sat, 24 May 2025 02:42:20 -0300 Subject: [PATCH] mdbx: try lz4 --- node/store/mdbx.go | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) diff --git a/node/store/mdbx.go b/node/store/mdbx.go index 31045a6..672adf2 100644 --- a/node/store/mdbx.go +++ b/node/store/mdbx.go @@ -2,7 +2,6 @@ package store import ( "bytes" - "compress/gzip" "io" "os" "runtime" @@ -11,6 +10,7 @@ import ( "github.com/cockroachdb/pebble" "github.com/erigontech/mdbx-go/mdbx" + lz4 "github.com/pierrec/lz4/v4" "source.quilibrium.com/quilibrium/monorepo/node/config" ) @@ -21,11 +21,7 @@ func compressValue(value []byte) ([]byte, error) { return value, nil } var b bytes.Buffer - w, err := gzip.NewWriterLevel(&b, gzip.BestSpeed) - - if err != nil { - return nil, err - } + w := lz4.NewWriter(&b) if _, err := w.Write(value); err != nil { return nil, err @@ -46,11 +42,7 @@ func decompressValue(value []byte) ([]byte, error) { } // Create a zlib reader - r, err := gzip.NewReader(bytes.NewReader(value)) - if err != nil { - return nil, err - } - defer r.Close() + r := lz4.NewReader(bytes.NewReader(value)) // Read the decompressed data var b bytes.Buffer