We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 768ef7a commit 4a43139Copy full SHA for 4a43139
gbn/gbn_conn.go
@@ -514,6 +514,8 @@ func (g *GoBackNConn) receivePacketsForever() error { // nolint:gocyclo
514
g.pongTicker.Pause()
515
}
516
517
+ g.resendTicker.Reset(g.cfg.resendTimeout)
518
+
519
switch m := msg.(type) {
520
case *PacketData:
521
switch m.Seq == g.recvSeq {
@@ -588,8 +590,6 @@ func (g *GoBackNConn) receivePacketsForever() error { // nolint:gocyclo
588
590
case *PacketACK:
589
591
gotValidACK := g.sendQueue.processACK(m.Seq)
592
if gotValidACK {
- g.resendTicker.Reset(g.cfg.resendTimeout)
-
593
// Send a signal to indicate that new
594
// ACKs have been received.
595
select {
0 commit comments