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 54c8395 commit e09187eCopy full SHA for e09187e
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 {
@@ -577,8 +579,6 @@ func (g *GoBackNConn) receivePacketsForever() error { // nolint:gocyclo
577
579
case *PacketACK:
578
580
gotValidACK := g.sendQueue.processACK(m.Seq)
581
if gotValidACK {
- g.resendTicker.Reset(g.cfg.resendTimeout)
-
582
// Send a signal to indicate that new
583
// ACKs have been received.
584
select {
0 commit comments