nonoo/kappanhang
1
0
Fork 0
mirror of https://github.com/nonoo/kappanhang.git synced 2026-01-20 07:40:14 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Prevent RX seqbuf congestions caused by late entries

Browse source
This commit is contained in:
Nonoo 2020-10-26 17:56:00 +01:00
parent c0afc17190
commit 179fb6facf
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
seqbuf.go
View file

@ -66,6 +66,7 @@ func (s *seqBuf) addToFront(seq seqNum, data []byte) {
func (s *seqBuf) addToBack(seq seqNum, data []byte) {
e := s.createEntry(seq, data)
e.addedAt = time.Time{} // Release the packet from the seqbuf as soon as possible, as it is a late entry.
s.entries = append(s.entries, e)
s.notifyWatcher()
@ -83,6 +84,7 @@ func (s *seqBuf) insert(seq seqNum, data []byte, toPos int) (addedToFront bool)
sliceBefore := s.entries[:toPos]
sliceAfter := s.entries[toPos:]
e := s.createEntry(seq, data)
e.addedAt = time.Time{} // Release the packet from the seqbuf as soon as possible, as it is a late entry.
s.entries = append(sliceBefore, append([]seqBufEntry{e}, sliceAfter...)...)
s.notifyWatcher()