Method Start

library/cpp/http/server/http.cpp:207–255

    }

    bool Start() {
        Poller.Reset(new TSocketPoller());
        Connections.Reset(new TConnections(Poller.Get(), Options_));

        // throws on error
        TPipeHandle::Pipe(ListenWakeupReadFd, ListenWakeupWriteFd);

        SetNonBlock(ListenWakeupWriteFd, true);
        SetNonBlock(ListenWakeupReadFd, true);

        Poller->WaitRead(ListenWakeupReadFd, &WakeupPollAble);

        ErrorCode = 0;

        std::function<void(TSocket)> callback = [&](TSocket socket) {
            THolder<TListenSocket> ls(new TListenSocket(socket, this));
            if (Options_.OneShotPoll) {
                Poller->WaitReadOneShot(socket, static_cast<IPollAble*>(ls.Get()));
            } else {
                Poller->WaitRead(socket, static_cast<IPollAble*>(ls.Get()));
            }
            Reqs.PushBack(ls.Release());
        };

        bool addressesBound = TryToBindAddresses(Options_, &callback);
        if (!addressesBound) {
            SaveErrorCode();
            return false;
        }

        Requests->Start(Options_.nThreads, Options_.MaxQueueSize);
        FailRequests->Start(Options_.nFThreads, Options_.MaxFQueueSize);
        Cb_->OnListenStart();

        try {
            RunningListeners_.store(Options_.nListenerThreads);
            for (size_t i = 0; i < Options_.nListenerThreads; ++i) {
                ListenThreads.push_back(MakeHolder<TThread>([this, threadNum = i]() {
                    ListenSocket(threadNum);
                }));
                ListenThreads.back()->Start();
            }
        } catch (const yexception&) {
            SaveErrorCode();
            return false;
        }

        return true;
    }

    void JoinListenerThreads() {
        while (!ListenThreads.empty()) {