(elems *QueueOutboundElementsContainer)
| 280 | } |
| 281 | |
| 282 | func (peer *Peer) StagePackets(elems *QueueOutboundElementsContainer) { |
| 283 | for { |
| 284 | select { |
| 285 | case peer.queue.staged <- elems: |
| 286 | return |
| 287 | default: |
| 288 | } |
| 289 | select { |
| 290 | case tooOld := <-peer.queue.staged: |
| 291 | for _, elem := range tooOld.elems { |
| 292 | peer.device.PutMessageBuffer(elem.buffer) |
| 293 | peer.device.PutOutboundElement(elem) |
| 294 | } |
| 295 | peer.device.PutOutboundElementsContainer(tooOld) |
| 296 | default: |
| 297 | } |
| 298 | } |
| 299 | } |
| 300 | |
| 301 | func (peer *Peer) SendStagedPackets() { |
| 302 | top: |
no test coverage detected