diff options
| author | anon5 <anon5clam@protonmail.com> | 2021-02-28 18:54:41 +0000 |
|---|---|---|
| committer | anon5 <anon5clam@protonmail.com> | 2021-02-28 18:54:41 +0000 |
| commit | 7d69943c17614bcf6733ff0b3206374d272e274b (patch) | |
| tree | 29301ea544edf7b37442f79e0a6085a28d0cf7e3 /rudp/send.go | |
| parent | 27c0776cb2f1084356df5c9f6080fecf20f8fddf (diff) | |
| download | mt-7d69943c17614bcf6733ff0b3206374d272e274b.tar.xz | |
rudp: fix errors returned by Peer.Recv other than net.ErrClosed when the Peer is closed
Diffstat (limited to 'rudp/send.go')
| -rw-r--r-- | rudp/send.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/rudp/send.go b/rudp/send.go index 2615c59..ce3f013 100644 --- a/rudp/send.go +++ b/rudp/send.go @@ -205,6 +205,9 @@ func (p *Peer) sendRel(pkt rawPkt) (ack <-chan struct{}, err error) { select { case <-time.After(500 * time.Millisecond): if _, err := p.sendRaw(relpkt); err != nil { + if errors.Is(err, net.ErrClosed) { + return + } p.errs <- fmt.Errorf("failed to re-send timed out reliable seqnum: %d: %w", sn, err) } case <-ack: |