MCPcopy Create free account
hub / github.com/catboost/catboost / InjectTransfers

Method InjectTransfers

library/cpp/netliba/v12/udp_host.cpp:711–720  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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;

Callers

nothing calls this directly

Calls 6

InsertToSendingMethod · 0.80
beginMethod · 0.45
endMethod · 0.45
GetMethod · 0.45
push_backMethod · 0.45
eraseMethod · 0.45

Tested by

no test coverage detected