,h SrSSKJr SSKrSSKrSSKJr SSKJr SSK J r J r SSK JrJrJrJr \R$"S 5rS S jrS S jrg)z8 Separate connection attempts from a connection string. ) annotationsN)shuffle)errors)ConnDict ConnMapping) get_param get_param_def is_ip_addresssplit_attemptspsycopgcXSn/n[US5S:H=n(a+UR5VVs0sHupEUS:wdM XE_M nnn[U5HnUR[ U55 M U(d(U(de[R"[U55e[US5S:Xa [U5 U(aUVs/sH n0UESS0EPM snU-nU$s snnf![ a3n[ RSURS5U5 UnSnAMSnAff=fs snf) 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. Ntarget_session_attrszprefer-standbyzfailed to resolve host %r: %shostload_balance_hostsrandomstandby) r itemsr extend_resolve_hostnamesOSErrorloggerdebuggeteOperationalErrorstrr) paramslast_excattemptsprefer_standbykvattemptexas U/var/www/html/Ai_home/venv/lib/python3.13/site-packages/psycopg/_conninfo_attempts.pyconninfo_attemptsr(s*HH&015EE~$*<<>Q>41Q:P5P$!$>Q!&)  OO.w7 8* x  X//-.(:>F >F 4q 4() 4h  O1R   LL8'++f:Mr RH  s( C!C!C'D'' D$1(DD$c[US5nU(aURS5(d USSS:XaU/$[US5(aU/$[U5(a 0UESU0E/$[US5=n(d)[S5nU=(a UR=(d Sn[ R "X[ R[ RS 9nUVs/sHn0UESUS S 0EPM sn$s snf) 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)prototyper) r startswithr r compiledsocket getaddrinfo IPPROTO_TCP SOCK_STREAM)rrr.port_defansitems r'rrDs VV $D 4??3''4!9+;x$$xT,6,:t,--ff- -D - (-H--7    &,,63E3E CrGs@ # &TT   9 %*Z$@rF