diff options
| -rw-r--r-- | rudp/conn.go | 1 | ||||
| -rw-r--r-- | rudp/recv.go | 2 |
2 files changed, 2 insertions, 1 deletions
diff --git a/rudp/conn.go b/rudp/conn.go index 7e241a8..11ffe0d 100644 --- a/rudp/conn.go +++ b/rudp/conn.go @@ -149,7 +149,6 @@ func newConn(uc udpConn, id, remoteID PeerID) *Conn { c.newAckBuf() - go c.sendPings(c.ping.C) go c.recvUDPPkts() return c diff --git a/rudp/recv.go b/rudp/recv.go index d8cd7e1..0a9933b 100644 --- a/rudp/recv.go +++ b/rudp/recv.go @@ -136,6 +136,8 @@ func (c *Conn) processRawPkt(data []byte, pi PktInfo) (err error) { c.mu.Unlock() c.newAckBuf() + + go c.sendPings(c.ping.C) case ctlPing: defer errWrap("ping") case ctlDisco: |