| 447 | } |
| 448 | |
| 449 | void TUdpSocket::ForgetHeadUdpPackets(const size_t numPackets) { |
| 450 | // necessary for TCircularPodBuffer::EraseBefore |
| 451 | if (numPackets == 0) { |
| 452 | return; |
| 453 | } |
| 454 | UdpPacketsAddresses.EraseHead(numPackets); |
| 455 | UdpPacketsAuxData.EraseHead(numPackets * CTRL_BUFFER_SIZE); |
| 456 | UdpPacketsHeadersBegin += size_t(numPackets); |
| 457 | |
| 458 | // necessary for TCircularPodBuffer::EraseBefore |
| 459 | if (UdpPacketsHeadersBegin == UdpPacketsHeaders.size()) { |
| 460 | PacketsDataBuffer.Clear(); |
| 461 | PacketsIoVecs.Clear(); |
| 462 | LastUdpPacketSize = 0; |
| 463 | } else { |
| 464 | Y_ASSERT(UdpPacketsHeaders[UdpPacketsHeadersBegin].msg_hdr.msg_iovlen); |
| 465 | const TIoVec* iov = UdpPacketsHeaders[UdpPacketsHeadersBegin].msg_hdr.msg_iov; |
| 466 | PacketsDataBuffer.EraseBefore((const char*)iov->iov_base); |
| 467 | PacketsIoVecs.CleanupBefore(iov); |
| 468 | } |
| 469 | } |
| 470 | |
| 471 | struct TPacketsCountAdder { |
| 472 | size_t operator()(const size_t base, const TMMsgHdr& next) const { |
nothing calls this directly
no test coverage detected