fix: close closed chan in pipe

nange · Aug 1, 2024 · 54abadd · 54abadd
1 parent 270b4eb
commit 54abadd
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/util/netpipe/pipe.go b/util/netpipe/pipe.go
@@ -96,14 +96,18 @@ func (p *pipe) Close() error {
 	p.cond.L.Lock()
 	defer p.cond.L.Unlock()
 
-	p.closed = true
+	if !p.closed {
+		p.closed = true
+		close(p.closing)
+	}
+
 	p.buf.CloseWithError(ErrPipeClosed)
 	p.cond.Broadcast()
 	if len(p.back) > 0 {
 		bytespool.MustPut(p.back)
 		p.back = nil
 	}
-	close(p.closing)
+
 	return nil
 }