| 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 { |