(ph\2 %SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r J r J r J r SSKJ r SSKJr SSKJrJrJrJr SS KJrJr SS KJr \R6r\R:r\R>r \RBr"\R6r#\R:r$\R>r%\RL"\'5r(SSS jjr)SSS jjr*SSS jjr+SSSjjr,SSSjjr-\."\S5(a\\R^\R`-\Rb-\\R^\Rd-\Rb-\ \R^\R`\Rd-\Rb--0r3O0r3SSSjjr4\."\S5(a4\\Rj\\Rl\ \Rj\Rl-0r7O0r7SSSjjr8SSjr9\(a \Rtr:S\;S'S\Rx;aG\RxSr=\=R}S5(a \=\?"5;a \@"S\=<35e\?"5\=rAg\(a\RS:wa\9"5(d\:rAg\R\C"\SS5La\-rAg\."\S5(a\8rAg\)rAg) z Code concerned with waiting in different contexts (blocking, async, etc). These functions are designed to consume the generators returned by the `generators` module function and to return their final value. ) annotationsN)get_event_loopwait_forEvent TimeoutError)DefaultSelector)errors)RVPQGen PQGenConnWaitFunc)WaitReady)_psycopgc[U5n[5nURX5 URUS9nU(dUR [ 5 M.UR U5 USSnUR U5nURX5 Mj!,(df  g=f![a.nUR(aURSOSnUsSnA$SnAff=f)a Wait for a generator using the best strategy available. :param gen: a generator performing database operations and yielding `Ready` values when it would block. :param fileno: the file descriptor to wait on. :param interval: interval (in seconds) to check for other interrupt, e.g. to allow Ctrl-C. If zero or None, wait indefinitely. :return: whatever `!gen` returns on completion. Consume `!gen`, scheduling `fileno` for completion when it is reported to block. Once ready again send the ready state back to `!gen`. timeoutrr N nextrregisterselectsend READY_NONE unregister StopIterationargs) genfilenointervalsselrlistreadyexrvs B/var/www/html/venv/lib/python3.13/site-packages/psycopg/waiting.py wait_selectorr(%s I  # LL # 8 4HHZ(v&a HHUO V'  !wwD s5B%A=B B"B%"B%% C/#CCCc[U5up#U(dSn[5nURX#5 URUS9nU(dUR [ 5 M.UR U5 USSnUR U5up#URX#5 Ml!,(df  g=f![a.nUR(aURSOSnUsSnA$SnAff=f)a Wait for a connection generator using the best strategy available. :param gen: a generator performing database operations and yielding (fd, `Ready`) pairs when it would block. :param interval: interval (in seconds) to check for other interrupt, e.g. to allow Ctrl-C. If zero or None, wait indefinitely. :return: whatever `!gen` returns on completion. Behave like in `wait()`, but take the fileno to wait from the generator itself, which might change during processing. Nrrr r) rr rr!r"r#r$r%r&s r' wait_connr*GsI H  # LL # 8 4HHZ(v&a HHUO  V'  !wwD s5 B2A?B!! B/+B2/B22 C*<#C%C*%C*c^ ^ # [5m [5nSU U 4Sjjn[U5nU[-nU[-nU(d U(d[ R "SU35eT R5 Sm U(aURX[5 U(aURX[5 Ub$[T R5U5IShvN OT R5IShvN U(aURU5 U(aUR!U5 UR#T 5nGM Na![a NRf=fNZ!U(aURU5 U(aUR!U5 ff=f![$a$n[ R&"[)U55eSnAf[*a.nUR,(aUR,SOSn U sSnA$SnAff=f7f)a Coroutine waiting for a generator to complete. :param gen: a generator performing database operations and yielding `Ready` values when it would block. :param fileno: the file descriptor to wait on. :param interval: interval (in seconds) to check for other interrupt, e.g. to allow Ctrl-C. If None, wait indefinitely. :return: whatever `!gen` returns on completion. Behave like in `wait()`, but exposing an `asyncio` interface. c0>TU-mTR5 gNsetstateevr$s r'wakeupwait_async..wakeup~s  bad poll status: rNr1rreturnNone)rrrWAIT_RWAIT_We InternalErrorclear add_readerREADY_R add_writerREADY_Wrwaitr remove_reader remove_writerrOSErrorOperationalErrorstrrr) rrr loopr3r!readerwriterr%r&r2r$s @@r' wait_asyncrLjs B  D ! IZFZF&oo(9!&=>> HHJE88 /'&rwwy(;;;'')OO&&v.&&v.A1<'$&&v.&&v. *  R)) !wwD sG)BF5E 9D:D8D:E /E 0E 4AF8D:: EE EE 3E??F G& F++ G&8#G!G&G)!G&&G)c^ ^ # [5m [5nSU U 4Sjjn[U5upEU[-nU[-nU(d U(d[ R "SU35eT R5 Sm U(aURXC[5 U(aURXC[5 U(a$[T R5U5IShvN OT R5IShvN U(aURU5 U(aUR!U5 UR#T 5upEGMNc![a NTf=fN\!U(aURU5 U(aUR!U5 ff=f![$a.nUR&(aUR&SOSn U sSnA$SnAff=f7f)a Coroutine waiting for a connection generator to complete. :param gen: a generator performing database operations and yielding (fd, `Ready`) pairs when it would block. :param interval: interval (in seconds) to check for other interrupt, e.g. to allow Ctrl-C. If zero or None, wait indefinitely. :return: whatever `!gen` returns on completion. Behave like in `wait()`, but take the fileno to wait from the generator itself, which might change during processing. c*>UmTR5 gr-r.r0s r'r3wait_conn_async..wakeups r5r6rNr7)rrrr:r;r<r=r>r?r@rArBrrCrrDrErrr) rr rIr3rr!rJrKr%r&r2r$s @@r'wait_conn_asyncrPsi B  D I ZFZF&oo(9!&=>> HHJE88 /&rwwy(;;;'')OO&&v.&&v.IF1<'$&&v.&&v. !wwD sGBF 7E?EEE!E5E6E:AF E E EEE3FF G#F=7G8G=GGc[U5nSnU4n[R"U[-(aUOUU[-(aUOUUU5upgnSn U(a[n U(a U [ -n U (dUR [5 MzUR U 5nM![a.n U R(aU RSOSn U sSn A $Sn A ff=f)zv Wait for a generator using select where supported. BUG: on Linux, can't select on FD >= 1024. On Windows it's fine. rN) rrr:r;r@rBrrrr) rrr r!emptyfnlistrlwlxlr$r%r&s r' wait_selectrXs  If*%f*% JBB E $A!$ !wwD sBB C)#C CC EpollSelectorcx[U5nUbUS:aSn[R"5n[UnUR X5 UR U5nU(dUR [5 M0USSnSnU[R)-(a[nU[R)-(a U[-nUR U5n[UnURX5 M!,(df  g=f![a.n U R(aU RSOSn U sSn A $Sn A ff=f)a Wait for a generator using epoll where supported. Parameters are like for `wait()`. If it is detected that the best selector strategy is `epoll` then this function will be used instead of `wait`. See also: https://linux.die.net/man/2/epoll_ctl BUG: if the connection FD is closed, `epoll.poll()` hangs. Same for EpollSelector. For this reason, wait_poll() is currently preferable. To reproduce the bug: export PSYCOPG_WAIT_FUNC=wait_epoll pytest tests/test_concurrency.py::test_concurrent_close Nrgr )rrepoll_epoll_evmasksrpollrrEPOLLOUTr@EPOLLINrBmodifyrr) rrr r!r[evmaskfileevsr2r$r%r&s r' wait_epollrcs  I  x!|H \\^u#A&F NN6 ***X.HHZ(QZ]((#E'W$EHHUO'* V,^$ !wwD s5+DCC00 C>:D>D D9 #D4.D94D9 PollSelectorcr[U5nUbUS:aSnO[US-5n[R"5n[UnUR X5 URU5nU(dUR [5 M0USSnSnU[R)-(a[nU[R)-(a U[-nUR U5n[UnURX5 M![a.n U R(aU RSOSn U sSn A $Sn A ff=f)zU Wait for a generator using poll where supported. Parameters are like for `wait()`. Nrg@@r )rintrr] _poll_evmasksrrrPOLLOUTr@POLLINrBr`rr) rrr r!r]rarbr2r$r%r&s r' wait_pollrjHs  I  x!|H8f,-H{{}q! f%ii)G$ABEV^^O#V]]N" A"1%F KK ' !wwD sC> D6#D1+D61D6c[RRS5nU(aURS5(aggg![a n[ R SU5 SnAgSnAff=f)z Detect if some greenlet library has patched the select library. If this is the case, avoid to use the wait_c function as it doesn't behave in a collaborative way. Currently supported: gevent. z gevent.monkeyrTz+failed to detect gevent monkey-patching: %sNF)sysmodulesgetis_module_patched Exceptionloggerwarning)mr%s r'_is_select_patchedrtnsf (A N""8,,-  N NNH" M M  NsA A, A''A,rrCPSYCOPG_WAIT_FUNCwait_zHPSYCOPG_WAIT_FUNC should be the name of an available wait function; got win32SelectSelectorr-)rz PQGen[RV]rrfr float | Noner8r )rz PQGenConn[RV]r ryr8r )r8bool)D__doc__ __future__rosrlrlogging selectorsasynciorrrrrr r<abcr r r r_enumsrr_cmodulerRr:Wr;RWWAIT_RWNONErr@rBREADY_RW getLogger__name__rqr(r*rLrPrXhasattr EPOLLONESHOTr_EPOLLERRr^r\rcrirhrgrjrtwait_c__annotations__environfname startswithglobals ImportErrorrCplatformgetattrrRr5r'rsA# AA%//0   '' ZZ '' '' 88   8 $D F:z7zD 9o&&##fnn4vF##foo5G$$ >>FOO +foo =?NN*Z 9n%% /M M#L* __F"**$ JJ* +E   G $ $WY(> 9    9U D #,,')2D2F2F D')5Et"LL D Y'' D Dr5