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

Method Send

library/cpp/netliba/v12/udp_host.cpp:594–603  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

592 }
593
594 TTransfer TUdpHost::Send(const TIntrusivePtr<IConnection>& connectionPtr, TAutoPtr<TRopeDataPacket> data, EPacketPriority pp, const TTos& tos, ui8 netlibaColor) {
595 TConnection* connection = CheckedCast<TConnection*>(connectionPtr.Get());
596 Y_ASSERT(connection);
597
598 TTransfer transfer(connection, connection->GetNextTransferId());
599 Y_ABORT_UNLESS(transfer.Id > 0, "transferId overflowed, wow you have counted to almost infinity!");
600 TXUserQueue.EnqueueSend(transfer, data, pp, tos, netlibaColor);
601 CancelWaitLow();
602 return transfer;
603 }
604 void TUdpHost::SendLow(const TTransfer& transfer, TAutoPtr<TRopeDataPacket> data, EPacketPriority pp, const TTos& tos, ui8 netlibaColor) {
605 TConnection* connection = CheckedCast<TConnection*>(transfer.Connection.Get());
606 std::pair<TUdpOutTransfer*, bool> p = connection->InsertSendTransfer(transfer.Id); // FailedSend needs created transfer

Callers 4

SendLowMethod · 0.45
DoSendsMethod · 0.45
GetDebugInfoFunction · 0.45

Calls 3

GetNextTransferIdMethod · 0.80
EnqueueSendMethod · 0.80
GetMethod · 0.45

Tested by

no test coverage detected