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()...)