fix: Use locks for closeing error channels

Author: pojntfx

pkg/chunks/puller.go

@@ -25,6 +25,8 @@ type Puller struct {
 	chunkIndexesLock          sync.Mutex
 	nextChunk                 int64
 	nextChunkAndFinalizedLock sync.Mutex
+
+	closeLock sync.Mutex
 }
 
 func NewPuller(
@@ -165,6 +167,9 @@ func (p *Puller) Wait() error {
 	go func() {
 		p.workersWg.Wait()
 
+		p.closeLock.Lock()
+		defer p.closeLock.Unlock()
+
 		if p.errs != nil {
 			close(p.errs)
 

pkg/migration/file_migrator.go

@@ -111,6 +111,9 @@ func (s *FileMigrator) Seed() (
 			return
 		}
 
+		s.closeLock.Lock()
+		defer s.closeLock.Unlock()
+
 		if s.errs != nil {
 			close(s.errs)
 
@@ -173,6 +176,9 @@ func (s *FileMigrator) Leech(
 			return
 		}
 
+		s.closeLock.Lock()
+		defer s.closeLock.Unlock()
+
 		if !s.released && s.errs != nil {
 			close(s.errs)
 
@@ -238,6 +244,9 @@ func (s *FileMigrator) Leech(
 					return
 				}
 
+				s.closeLock.Lock()
+				defer s.closeLock.Unlock()
+
 				if s.errs != nil {
 					close(s.errs)
 

pkg/migration/path_migrator.go

@@ -135,6 +135,9 @@ func (s *PathMigrator) Seed() (
 			return
 		}
 
+		s.closeLock.Lock()
+		defer s.closeLock.Unlock()
+
 		if s.errs != nil {
 			close(s.errs)
 
@@ -198,6 +201,9 @@ func (s *PathMigrator) Leech(
 			return
 		}
 
+		s.closeLock.Lock()
+		defer s.closeLock.Unlock()
+
 		if !s.released && s.errs != nil {
 			close(s.errs)
 
@@ -262,6 +268,9 @@ func (s *PathMigrator) Leech(
 					return
 				}
 
+				s.closeLock.Lock()
+				defer s.closeLock.Unlock()
+
 				if s.errs != nil {
 					close(s.errs)
 

pkg/migration/slice_migrator.go

@@ -110,6 +110,9 @@ func (s *SliceMigrator) Seed() (
 			return
 		}
 
+		s.closeLock.Lock()
+		defer s.closeLock.Unlock()
+
 		if s.errs != nil {
 			close(s.errs)
 
@@ -172,6 +175,9 @@ func (s *SliceMigrator) Leech(
 			return
 		}
 
+		s.closeLock.Lock()
+		defer s.closeLock.Unlock()
+
 		if !s.released && s.errs != nil {
 			close(s.errs)
 
@@ -237,6 +243,9 @@ func (s *SliceMigrator) Leech(
 					return
 				}
 
+				s.closeLock.Lock()
+				defer s.closeLock.Unlock()
+
 				if s.errs != nil {
 					close(s.errs)