Return ErrClosedPipe for writeTo.

pion · Dec 8, 2022 · 8b6af54 · 8b6af54
1 parent ea00dc7
commit 8b6af54
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/candidate_base.go b/candidate_base.go
@@ -308,6 +308,10 @@ func (c *candidateBase) close() error {
 func (c *candidateBase) writeTo(raw []byte, dst Candidate) (int, error) {
  n, err := c.conn.WriteTo(raw, dst.addr())
  if err != nil {
+ // If the connection is closed, we should return the error
+ if errors.Is(err, io.ErrClosedPipe) {
+ return n, err
+ }
  c.agent().log.Infof("%s: %v", errSendPacket, err)
  return n, nil
  }