Method AllocateMore

library/cpp/coroutine/engine/sockpool.cpp:30–58

}

TPooledSocket TSocketPool::AllocateMore(TConnectData* conn) {
    TCont* cont = conn->Cont;

    while (true) {
        TSocketHolder s(NCoro::Socket(Addr_->Addr()->sa_family, SOCK_STREAM, 0));

        if (s == INVALID_SOCKET) {
            ythrow TSystemError(errno) << TStringBuf("can not create socket");
        }

        SetCommonSockOpts(s, Addr_->Addr());
        SetZeroLinger(s);

        const int ret = NCoro::ConnectD(cont, s, Addr_->Addr(), Addr_->Len(), conn->DeadLine);

        if (ret == EINTR) {
            continue;
        } else if (ret) {
            ythrow TSystemError(ret) << TStringBuf("can not connect(") << cont->Name() << ')';
        }

        THolder<TPooledSocket::TImpl> res(new TPooledSocket::TImpl(s, this));
        s.Release();

        if (res->IsOpen()) {
            return res.Release();
        }
    }
}