| 1674 | |
| 1675 | public: |
| 1676 | inline TServer(IOnRequest* cb, const TParsedLocation& loc) |
| 1677 | : CB_(cb) |
| 1678 | , E_(RealStackSize(16000)) |
| 1679 | , L_(new TContListener(this, &E_, TContListener::TOptions().SetDeferAccept(true))) |
| 1680 | , JQ_(new TJobsQueue()) |
| 1681 | , SslCtx_(loc) |
| 1682 | { |
| 1683 | L_->Bind(TNetworkAddress(loc.GetPort())); |
| 1684 | E_.Create<TServer, &TServer::RunDispatcher>(this, "dispatcher"); |
| 1685 | Thrs_.push_back(Spawn<TServer, &TServer::Run>(this)); |
| 1686 | } |
| 1687 | |
| 1688 | ~TServer() override { |
| 1689 | JQ_->Enqueue(nullptr); |
nothing calls this directly
no test coverage detected