Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ackhandler

package

Go to main page

Versions in this module

v0

v0.6.0

Dec 12, 2017

Changes in this version

+ func HasRetransmittableFrames(fs []wire.Frame) bool

+ func IsFrameRetransmittable(f wire.Frame) bool

type ReceivedPacketHandler

+ GetAlarmTimeout func() time.Time

+ IgnoreBelow func(protocol.PacketNumber)

type SentPacketHandler

+ SetHandshakeComplete func()

+ ShouldSendRetransmittablePacket func() bool

v0.5.0

Apr 11, 2017

Changes in this version

+ var ErrAckForSkippedPacket = qerr.Error(qerr.InvalidAckData, "Received an ACK for a skipped packet number")

+ var ErrDuplicateOrOutOfOrderAck = errors.New("SentPacketHandler: Duplicate or out-of-order ACK")

+ var ErrDuplicatePacket = errors.New("ReceivedPacketHandler: Duplicate Packet")

+ var ErrPacketSmallerThanLastStopWaiting = errors.New("ReceivedPacketHandler: Packet number smaller than highest StopWaiting")

+ var ErrTooManyTrackedSentPackets = errors.New("Too many outstanding non-acked and non-retransmitted packets")

+ type Packet struct

+ EncryptionLevel protocol.EncryptionLevel

+ Frames []frames.Frame

+ Length protocol.ByteCount

+ PacketNumber protocol.PacketNumber

+ SendTime time.Time

+ func (p *Packet) GetFramesForRetransmission() []frames.Frame

+ type PacketElement struct

+ Value Packet

+ func (e *PacketElement) Next() *PacketElement

+ func (e *PacketElement) Prev() *PacketElement

+ type PacketList struct

+ func NewPacketList() *PacketList

+ func (l *PacketList) Back() *PacketElement

+ func (l *PacketList) Front() *PacketElement

+ func (l *PacketList) Init() *PacketList

+ func (l *PacketList) InsertAfter(v Packet, mark *PacketElement) *PacketElement

+ func (l *PacketList) InsertBefore(v Packet, mark *PacketElement) *PacketElement

+ func (l *PacketList) Len() int

+ func (l *PacketList) MoveAfter(e, mark *PacketElement)

+ func (l *PacketList) MoveBefore(e, mark *PacketElement)

+ func (l *PacketList) MoveToBack(e *PacketElement)

+ func (l *PacketList) MoveToFront(e *PacketElement)

+ func (l *PacketList) PushBack(v Packet) *PacketElement

+ func (l *PacketList) PushBackList(other *PacketList)

+ func (l *PacketList) PushFront(v Packet) *PacketElement

+ func (l *PacketList) PushFrontList(other *PacketList)

+ func (l *PacketList) Remove(e *PacketElement) Packet

+ type ReceivedPacketHandler interface

+ GetAckFrame func() *frames.AckFrame

+ ReceivedPacket func(packetNumber protocol.PacketNumber, shouldInstigateAck bool) error

+ ReceivedStopWaiting func(*frames.StopWaitingFrame) error

+ func NewReceivedPacketHandler(ackAlarmResetCallback func(time.Time)) ReceivedPacketHandler

+ type SentPacketHandler interface

+ DequeuePacketForRetransmission func() (packet *Packet)

+ GetAlarmTimeout func() time.Time

+ GetLeastUnacked func() protocol.PacketNumber

+ GetStopWaitingFrame func(force bool) *frames.StopWaitingFrame

+ OnAlarm func()

+ ReceivedAck func(ackFrame *frames.AckFrame, withPacketNumber protocol.PacketNumber, ...) error

+ SendingAllowed func() bool

+ SentPacket func(packet *Packet) error

+ func NewSentPacketHandler(rttStats *congestion.RTTStats) SentPacketHandler