Fix noinlineerr findings: internal/blobgen (refs #61)
This commit is contained in:
@@ -26,14 +26,16 @@ func CompressData(data []byte, compressionLevel int, recipients []string) (*Comp
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Write data
|
// Write data
|
||||||
if _, err := w.Write(data); err != nil {
|
_, err = w.Write(data)
|
||||||
|
if err != nil {
|
||||||
_ = w.Close()
|
_ = w.Close()
|
||||||
|
|
||||||
return nil, fmt.Errorf("writing data: %w", err)
|
return nil, fmt.Errorf("writing data: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Close to flush
|
// Close to flush
|
||||||
if err := w.Close(); err != nil {
|
err = w.Close()
|
||||||
|
if err != nil {
|
||||||
return nil, fmt.Errorf("closing writer: %w", err)
|
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
|
// 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)
|
return 0, "", fmt.Errorf("copying data: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Close to flush
|
// Close to flush
|
||||||
if err := w.Close(); err != nil {
|
err = w.Close()
|
||||||
|
if err != nil {
|
||||||
return 0, "", fmt.Errorf("closing writer: %w", err)
|
return 0, "", fmt.Errorf("closing writer: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -27,7 +27,8 @@ type Writer struct {
|
|||||||
// The hash is computed on the uncompressed input for deterministic content-addressing.
|
// The hash is computed on the uncompressed input for deterministic content-addressing.
|
||||||
func NewWriter(w io.Writer, compressionLevel int, recipients []string) (*Writer, error) {
|
func NewWriter(w io.Writer, compressionLevel int, recipients []string) (*Writer, error) {
|
||||||
// Validate compression level
|
// Validate compression level
|
||||||
if err := validateCompressionLevel(compressionLevel); err != nil {
|
err := validateCompressionLevel(compressionLevel)
|
||||||
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user