From 8a3b667c382825d43f22151f4e22cf9e7f77e3f1 Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sat, 30 Apr 2016 10:57:10 +0700 Subject: [PATCH] better debug output for retransmissions --- frames/ack_frame.go | 2 +- session.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/frames/ack_frame.go b/frames/ack_frame.go index 517deb9ad..4eefa8735 100644 --- a/frames/ack_frame.go +++ b/frames/ack_frame.go @@ -13,8 +13,8 @@ var errInvalidNackRanges = errors.New("AckFrame: ACK frame contains invalid NACK // An AckFrame in QUIC type AckFrame struct { - Entropy byte LargestObserved protocol.PacketNumber + Entropy byte DelayTime time.Duration NackRanges []NackRange // has to be ordered. The NACK range with the highest FirstPacketNumber goes first, the NACK range with the lowest FirstPacketNumber goes last } diff --git a/session.go b/session.go index eb0049d77..1be61b04e 100644 --- a/session.go +++ b/session.go @@ -154,7 +154,7 @@ func (s *Session) handlePacket(remoteAddr interface{}, publicHeader *PublicHeade fmt.Printf("\tEstimated RTT: %dms\n", s.rttStats.SmoothedRTT()/time.Millisecond) // ToDo: send right error in ConnectionClose frame case *frames.ConnectionCloseFrame: - fmt.Printf("%#v\n", frame) + fmt.Printf("\t<- %#v\n", frame) s.Close(nil, false) case *frames.StopWaitingFrame: err = s.receivedPacketHandler.ReceivedStopWaiting(frame) @@ -277,6 +277,7 @@ func (s *Session) sendPacket() error { // TODO: handle multiple packets retransmissions retransmitPacket := s.sentPacketHandler.DequeuePacketForRetransmission() if retransmitPacket != nil { + fmt.Printf("\t-> Queueing retransmission for packet %d\n", retransmitPacket.PacketNumber) s.stopWaitingManager.RegisterPacketForRetransmission(retransmitPacket) // resend the frames that were in the packet controlFrames = append(controlFrames, retransmitPacket.GetControlFramesForRetransmission()...)