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

Method RunDispatcher

library/cpp/neh/https.cpp:1714–1731  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1712 }
1713
1714 void RunDispatcher(TCont* c) {
1715 for (;;) {
1716 TAutoPtr<IJob> job(JQ_->Dequeue(c));
1717
1718 if (!job) {
1719 break;
1720 }
1721
1722 try {
1723 c->Executor()->Create(*job, "https-job");
1724 Y_UNUSED(job.Release());
1725 } catch (...) {
1726 }
1727 }
1728
1729 JQ_->Enqueue(nullptr);
1730 c->Executor()->Abort();
1731 }
1732
1733 void OnAcceptFull(const TAcceptFull& a) override {
1734 try {

Callers

nothing calls this directly

Calls 7

Y_UNUSEDFunction · 0.85
DequeueMethod · 0.45
CreateMethod · 0.45
ExecutorMethod · 0.45
ReleaseMethod · 0.45
EnqueueMethod · 0.45
AbortMethod · 0.45

Tested by

no test coverage detected