use join errors

rusq · Mar 30, 2024 · 0e88fa0 · 0e88fa0
1 parent 1eb2a19
commit 0e88fa0
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/internal/chunk/dirproc/base.go b/internal/chunk/dirproc/base.go
@@ -1,6 +1,7 @@
 package dirproc
 
 import (
+	"errors"
 	"io"
 	"sync/atomic"
 
@@ -35,13 +36,13 @@ func (p *baseproc) Close() error {
 	if p.closed.Load() {
 		return nil
 	}
+	var errs error
 	if err := p.Recorder.Close(); err != nil {
-		p.wc.Close()
-		return err
+		errors.Join(errs, err)
 	}
 	p.closed.Store(true)
 	if err := p.wc.Close(); err != nil {
-		return err
+		errors.Join(errs, err)
 	}
-	return nil
+	return errs
 }