gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

better debug output for retransmissions

Browse Source
This commit is contained in:
Marten Seemann
2016-04-30 10:57:10 +07:00
parent 06b51871b1
commit 8a3b667c38
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
frames/ack_frame.go
View File

@@ -13,8 +13,8 @@ var errInvalidNackRanges = errors.New("AckFrame: ACK frame contains invalid NACK
// An AckFrame in QUIC // An AckFrame in QUIC
type AckFrame struct { type AckFrame struct {
Entropy byte
LargestObserved protocol.PacketNumber LargestObserved protocol.PacketNumber
Entropy byte
DelayTime time.Duration 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 NackRanges []NackRange // has to be ordered. The NACK range with the highest FirstPacketNumber goes first, the NACK range with the lowest FirstPacketNumber goes last
} }

3
session.go
View File

@@ -154,7 +154,7 @@ func (s *Session) handlePacket(remoteAddr interface{}, publicHeader *PublicHeade
fmt.Printf("\tEstimated RTT: %dms\n", s.rttStats.SmoothedRTT()/time.Millisecond) fmt.Printf("\tEstimated RTT: %dms\n", s.rttStats.SmoothedRTT()/time.Millisecond)
// ToDo: send right error in ConnectionClose frame // ToDo: send right error in ConnectionClose frame
case *frames.ConnectionCloseFrame: case *frames.ConnectionCloseFrame:
fmt.Printf("%#v\n", frame) fmt.Printf("\t<- %#v\n", frame)
s.Close(nil, false) s.Close(nil, false)
case *frames.StopWaitingFrame: case *frames.StopWaitingFrame:
err = s.receivedPacketHandler.ReceivedStopWaiting(frame) err = s.receivedPacketHandler.ReceivedStopWaiting(frame)
@@ -277,6 +277,7 @@ func (s *Session) sendPacket() error {
// TODO: handle multiple packets retransmissions // TODO: handle multiple packets retransmissions
retransmitPacket := s.sentPacketHandler.DequeuePacketForRetransmission() retransmitPacket := s.sentPacketHandler.DequeuePacketForRetransmission()
if retransmitPacket != nil { if retransmitPacket != nil {
fmt.Printf("\t-> Queueing retransmission for packet %d\n", retransmitPacket.PacketNumber)
s.stopWaitingManager.RegisterPacketForRetransmission(retransmitPacket) s.stopWaitingManager.RegisterPacketForRetransmission(retransmitPacket)
// resend the frames that were in the packet // resend the frames that were in the packet
controlFrames = append(controlFrames, retransmitPacket.GetControlFramesForRetransmission()...) controlFrames = append(controlFrames, retransmitPacket.GetControlFramesForRetransmission()...)