()
| 1217 | } |
| 1218 | |
| 1219 | func (b *BufferBase) flushExtPacketsLocked() { |
| 1220 | for b.extPackets.Len() > 0 { |
| 1221 | ep := b.extPackets.PopFront() |
| 1222 | ReleaseExtPacket(ep) |
| 1223 | } |
| 1224 | b.extPackets.Clear() |
| 1225 | } |
| 1226 | |
| 1227 | func (b *BufferBase) maybeGrowBucket(now int64) { |
| 1228 | if now-b.lastBucketCapCheckAt < bucketCapCheckInterval { |
no test coverage detected