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

Method ExecuteSend

library/cpp/neh/udp.cpp:547–564  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

545 }
546
547 inline void ExecuteSend() {
548 SetHighestThreadPriority();
549
550 while (true) {
551 TPacketRef p;
552
553 while (!ToSend_.Dequeue(&p)) {
554 ToSendEv_.Wait();
555 }
556
557 //shutdown
558 if (!p) {
559 return;
560 }
561
562 p->SendTo(S_);
563 }
564 }
565
566 inline void Schedule(TPacketRef p) {
567 ToSend_.Enqueue(p);

Callers

nothing calls this directly

Calls 4

SetHighestThreadPriorityFunction · 0.85
DequeueMethod · 0.45
WaitMethod · 0.45
SendToMethod · 0.45

Tested by

no test coverage detected