diff options
author | anon5 <anon5clam@protonmail.com> | 2021-02-20 16:31:06 +0000 |
---|---|---|
committer | anon5 <anon5clam@protonmail.com> | 2021-02-20 16:31:06 +0000 |
commit | 8b61ee961a9191fd2731a48d46f33b561a316032 (patch) | |
tree | 5d9423e8e0dafbc2fb2b4cf91266ec4bdd19b305 /rudp/send.go | |
parent | 14c04859a14edfe326d9664107707c0c1ae90dea (diff) | |
download | mt-8b61ee961a9191fd2731a48d46f33b561a316032.tar.xz |
rudp: deprecate ErrClosed and replace with net.ErrClosed
Diffstat (limited to 'rudp/send.go')
-rw-r--r-- | rudp/send.go | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/rudp/send.go b/rudp/send.go index 3cfcda4..2615c59 100644 --- a/rudp/send.go +++ b/rudp/send.go @@ -126,7 +126,7 @@ func (p *Peer) sendRaw(pkt rawPkt) (ack <-chan struct{}, err error) { select { case <-p.Disco(): - return nil, ErrClosed + return nil, net.ErrClosed default: } @@ -201,12 +201,9 @@ func (p *Peer) sendRel(pkt rawPkt) (ack <-chan struct{}, err error) { } go func() { - resend := time.NewTicker(500 * time.Millisecond) - defer resend.Stop() - for { select { - case <-resend.C: + case <-time.After(500 * time.Millisecond): if _, err := p.sendRaw(relpkt); err != nil { p.errs <- fmt.Errorf("failed to re-send timed out reliable seqnum: %d: %w", sn, err) } |