From 2dfdc5f0951c42066708d5a10415017f898ff8c4 Mon Sep 17 00:00:00 2001 From: sneak Date: Fri, 7 Aug 2026 16:59:56 +0000 Subject: [PATCH] Fix noinlineerr findings: internal/blobgen (refs #61) --- internal/blobgen/compress.go | 12 ++++++++---- internal/blobgen/writer.go | 3 ++- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/internal/blobgen/compress.go b/internal/blobgen/compress.go index 20f8571..576b054 100644 --- a/internal/blobgen/compress.go +++ b/internal/blobgen/compress.go @@ -26,14 +26,16 @@ func CompressData(data []byte, compressionLevel int, recipients []string) (*Comp } // Write data - if _, err := w.Write(data); err != nil { + _, err = w.Write(data) + if err != nil { _ = w.Close() return nil, fmt.Errorf("writing data: %w", err) } // Close to flush - if err := w.Close(); err != nil { + err = w.Close() + if err != nil { return nil, fmt.Errorf("closing writer: %w", err) } @@ -61,12 +63,14 @@ func CompressStream(dst io.Writer, src io.Reader, compressionLevel int, recipien }() // Copy data - if _, err := io.Copy(w, src); err != nil { + _, err = io.Copy(w, src) + if err != nil { return 0, "", fmt.Errorf("copying data: %w", err) } // Close to flush - if err := w.Close(); err != nil { + err = w.Close() + if err != nil { return 0, "", fmt.Errorf("closing writer: %w", err) } diff --git a/internal/blobgen/writer.go b/internal/blobgen/writer.go index a14574c..08a13fb 100644 --- a/internal/blobgen/writer.go +++ b/internal/blobgen/writer.go @@ -27,7 +27,8 @@ type Writer struct { // The hash is computed on the uncompressed input for deterministic content-addressing. func NewWriter(w io.Writer, compressionLevel int, recipients []string) (*Writer, error) { // Validate compression level - if err := validateCompressionLevel(compressionLevel); err != nil { + err := validateCompressionLevel(compressionLevel) + if err != nil { return nil, err }