| 709 | } |
| 710 | |
| 711 | void TUdpHost::InjectTransfers(TSendOrder* order, ui8 prio) { |
| 712 | for (TSendOrder::iterator z = order->begin(); z != order->end();) { |
| 713 | const TTransfer& transfer = *z; |
| 714 | TConnection* connection = CheckedCast<TConnection*>(transfer.Connection.Get()); |
| 715 | TDeque<ui64>& transferIdQueue = connection->GetSendingTransfers(prio); |
| 716 | transferIdQueue.push_back(transfer.Id); |
| 717 | order->erase(z++); |
| 718 | Connections.InsertToSending(connection); |
| 719 | } |
| 720 | } |
| 721 | |
| 722 | TUdpHost::ESentPacketResult TUdpHost::SendTransferPacket(TConnection* connection, TUdpOutTransfer* xfer, ui64 transferId) { |
| 723 | NHPTimer::STime tCopy = CurrentT; |