Method Run

library/cpp/neh/tcp2.cpp:640–679

called from client thread

                //called from client thread
                bool Run(TRequestRef& req) {
                    if (Y_UNLIKELY(AtomicGet(State_) == Closed)) {
                        return false;
                    }

                    req->Ref();
                    try {
                        Reqs_.Enqueue(req.Get());
                    } catch (...) {
                        req->UnRef();
                        throw;
                    }

                    NeedCheckReqsQueue_.store(true);
                    req->SetConnection(this);
                    TAtomicBase state = AtomicGet(State_);
                    if (Y_LIKELY(state == Connected)) {
                        ProcessOutputReqsQueue();
                        return true;
                    }

                    if (state == Init) {
                        if (AtomicCas(&State_, Connecting, Init)) {
                            try {
                                TEndpoint addr(new NAddr::TAddrInfo(&*req->Addr()->Addr.Begin()));
                                AS_.AsyncConnect(addr, std::bind(&TConnection::OnConnect, TConnectionRef(this), _1, _2), TTcp2Options::ConnectTimeout);
                            } catch (...) {
                                AS_.GetIOService().Post(std::bind(&TConnection::OnErrorCallback, TConnectionRef(this), CurrentExceptionMessage()));
                            }
                            return true;
                        }
                    }
                    state = AtomicGet(State_);
                    if (state == Connected) {
                        ProcessOutputReqsQueue();
                    } else if (state == Closed) {
                        SafeOnError();
                    }
                    return true;
                }

                //called from client thread
                void Cancel(TRequestId id) {