| 429 | } |
| 430 | |
| 431 | TImpl(THttpServer* parent, ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options_) |
| 432 | : Requests(mainWorkers) |
| 433 | , FailRequests(failWorkers) |
| 434 | , Options_(options_) |
| 435 | , Cb_(cb) |
| 436 | , Parent_(parent) |
| 437 | { |
| 438 | if (Options_.nListenerThreads > 1) { |
| 439 | Options_.OneShotPoll = true; |
| 440 | |
| 441 | const auto minPollTimeout = TDuration::MilliSeconds(100); |
| 442 | if (!Options_.PollTimeout || Options_.PollTimeout > minPollTimeout) { |
| 443 | Options_.PollTimeout = minPollTimeout; |
| 444 | } |
| 445 | |
| 446 | Y_ENSURE(Options_.nListenerThreads < 64); |
| 447 | } |
| 448 | } |
| 449 | |
| 450 | TImpl(THttpServer* parent, ICallBack* cb, const TOptions& options, IThreadFactory* factory) |
| 451 | : TImpl( |
nothing calls this directly
no test coverage detected