(ph SrSSKJr SSKrSSKrSSKJr SSKJr SSK J r J r SSK JrJrJr SS K Jr SSKr\R&"S 5rS S jrSS jrg)z8 Separate connection attempts from a connection string. ) annotationsN)shuffle)errors)ConnDict ConnMapping) get_param is_ip_address get_param_def)split_attemptspsycopgc# Sn/n[U5H&nUR[U5IShvN 5 M( U(d(U(de[R"[U55e[US5S:Xa [U5 U$NX![a3n[R SUR S5U5 UnSnAMSnAff=f7f)aSplit a set of connection params on the single attempts to perform. A connection param can perform more than one attempt more than one ``host`` is provided. Also perform async resolution of the hostname into hostaddr. Because a host can resolve to more than one address, this can lead to yield more attempts too. Raise `OperationalError` if no host could be resolved. Because the libpq async function doesn't honour the timeout, we need to reimplement the repeated attempts. Nzfailed to resolve host %r: %shostload_balance_hostsrandom) r extend_resolve_hostnamesOSErrorloggerdebuggeteOperationalErrorstrr r)paramslast_excattemptsattemptexs S/var/www/html/venv/lib/python3.13/site-packages/psycopg/_conninfo_attempts_async.pyconninfo_attempts_asyncr!sHH!&)  OO"4W"== >* x  X//-.(: O>  LL8'++f:Mr RH s>C B B B AC B  C(C<C CC c,# [US5nU(aURS5(d USSS:XaU/$[US5nU(aU/$[U5(a 0UESU0E/$[US5nU(d)[S5nU=(a UR=(d Sn[ R "5nURX[R[RS 9IS hvN nUVs/sHn0UESUS S 0EPM sn$N#s snf7f) a Perform async DNS lookup of the hosts and return a list of connection attempts. If a ``host`` param is present but not ``hostname``, resolve the host addresses asynchronously. :param params: The input parameters, for instance as returned by `~psycopg.conninfo.conninfo_to_dict()`. The function expects at most a single entry for host, hostaddr because it is designed to further process the input of split_attempts(). :return: A list of attempts to make (to include the case of a hostname resolving to more than one IP). r/r:hostaddrport5432)prototypeNr) r startswithr r compiledasyncioget_running_loop getaddrinfosocket IPPROTO_TCP SOCK_STREAM)rrr&r'port_defloopansitems r rr9s VV $D 4??3''4!9+;x,HxT,6,:t,-- VV $D  (-H--7 '')$$ f00v7I7I%  rCsI # &DD+   9 %B,@rB