fix: don't set Deadline if pipe is closed

nange · Aug 2, 2024 · d23ae01 · d23ae01
1 parent 54abadd
commit d23ae01
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/util/netpipe/pipe.go b/util/netpipe/pipe.go
@@ -153,6 +153,10 @@ func (p *pipe) SetWriteDeadline(t time.Time) error {
 	p.cond.L.Lock()
 	defer p.cond.L.Unlock()
 
+	if p.closed {
+		return ErrPipeClosed
+	}
+
 	uid, err := uuid.NewV7()
 	if err != nil {
 		return err
@@ -201,6 +205,10 @@ func (p *pipe) SetReadDeadline(t time.Time) error {
 	p.cond.L.Lock()
 	defer p.cond.L.Unlock()
 
+	if p.closed {
+		return ErrPipeClosed
+	}
+
 	uid, err := uuid.NewV7()
 	if err != nil {
 		return err