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 f16ac9e commit a75915fCopy full SHA for a75915f
gbn/gbn_conn.go
@@ -503,6 +503,8 @@ func (g *GoBackNConn) receivePacketsForever() error { // nolint:gocyclo
503
g.pongTicker.Pause()
504
}
505
506
+ g.resendTicker.Reset(g.cfg.resendTimeout)
507
+
508
switch m := msg.(type) {
509
case *PacketData:
510
switch m.Seq == g.recvSeq {
@@ -578,8 +580,6 @@ func (g *GoBackNConn) receivePacketsForever() error { // nolint:gocyclo
578
580
gotValidACK := g.sendQueue.processACK(m.Seq)
579
581
582
if gotValidACK {
- g.resendTicker.Reset(g.cfg.resendTimeout)
-
583
// Send a signal to indicate that new
584
// ACKs have been received.
585
select {
0 commit comments