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 6b38b9e commit 893b879Copy full SHA for 893b879
gbn/gbn_conn.go
@@ -602,6 +602,8 @@ func (g *GoBackNConn) receivePacketsForever() error { // nolint:gocyclo
602
g.pongTicker.Pause()
603
}
604
605
+ g.resendTicker.Reset(g.resendTimeout)
606
+
607
switch m := msg.(type) {
608
case *PacketData:
609
switch m.Seq == g.recvSeq {
@@ -675,8 +677,6 @@ func (g *GoBackNConn) receivePacketsForever() error { // nolint:gocyclo
675
677
case *PacketACK:
676
678
gotValidACK := g.sendQueue.processACK(m.Seq)
679
if gotValidACK {
- g.resendTicker.Reset(g.resendTimeout)
-
680
g.awaitingCatchUpMu.RLock()
681
if m.Seq == g.awaitedACK && g.awaitingCatchUp {
682
log.Tracef("Got awaited ACK")
0 commit comments