summaryrefslogtreecommitdiff
path: root/rudp/send.go
diff options
context:
space:
mode:
authoranon5 <anon5clam@protonmail.com>2021-02-20 16:31:06 +0000
committeranon5 <anon5clam@protonmail.com>2021-02-20 16:31:06 +0000
commit8b61ee961a9191fd2731a48d46f33b561a316032 (patch)
tree5d9423e8e0dafbc2fb2b4cf91266ec4bdd19b305 /rudp/send.go
parent14c04859a14edfe326d9664107707c0c1ae90dea (diff)
downloadmt-8b61ee961a9191fd2731a48d46f33b561a316032.tar.xz
rudp: deprecate ErrClosed and replace with net.ErrClosed
Diffstat (limited to 'rudp/send.go')
-rw-r--r--rudp/send.go7
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)
}