Method Add

library/cpp/http/server/http.cpp:88–97

        }

        inline void Add(TClientConnection* c) noexcept {
            TGuard<TMutex> g(Mutex_);

            Conns_.PushBack(c);
            if (Options.OneShotPoll) {
                Poller_->WaitReadOneShot(c->Socket_, (void*)static_cast<const IPollAble*>(c));
            } else {
                Poller_->WaitRead(c->Socket_, (void*)static_cast<const IPollAble*>(c));
            }
        }

        void Cleanup(size_t threadNum) {
            if (Options.nListenerThreads < 2) {