,hw1%SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r J r J r J r SSKJ r SSKJr SSKJrJrJrJr SS KJr SS KJr SS KJr \R6r\R:r\R>r \RBr"\R6r#\R:r$\R>r%\RL"\'5r(SSS jjr)SSS jjr*SSSjjr+SSSjjr,SSSjjr-\."\S5(a\\R^\R`-\Rb-\\R^\Rd-\Rb-\ \R^\R`\Rd-\Rb--0r3O0r3SSSjjr4\."\S5(a4\\Rj\\Rl\ \Rj\Rl-0r7O0r7SSSjjr8S Sjr9\(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)Event TimeoutErrorget_event_loopwait_for)DefaultSelector)errors)RVPQGen PQGenConnWaitFunc)Ready)Wait)_psycopgc[U5n[5nURX5 URUS9=n(dUR [ 5 M.UR U5 USSnUR U5nURX5 Mj!,(df  g=f![anURnUsSnA$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 StopIterationvalue) genfilenointervalsselrlistreadyexrvs J/var/www/html/Ai_home/venv/lib/python3.13/site-packages/psycopg/waiting.py wait_selectorr(&s I  # LL #!$H!===HHZ(v&a HHUO V'   s5B%A=B B"B%"B%% C/ C<CCc[U5up#U(dSn[5nURX#5 URUS9=n(dUR [ 5 M.UR U5 USSnUR U5up#URX#5 Ml!,(df  g=f![anURnUsSnA$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 #!$H!===HHZ(v&a HHUO  V'   s5 B2A?B!! B/+B2/B22 C< C CCc^ ^ # [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[*anUR,n 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_asyncrLisz B  D ! IZFZFfoo(9!&=>> HHJE88 /'&rwwy(;;;'')OO&&v.&&v.A1<'$&&v.&&v. *  R))  sGBF5E 9D:D8D:E /E 0E 4AF8D:: EE EE 3E??F G F++ G8 G GG GGcb^ ^ # [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![$anUR&n 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_asyncrPs] B  D I ZFZFfoo(9!&=>> HHJE88 /&rwwy(;;;'')OO&&v.&&v.IF1<'$&&v.&&v.  sF/BF 7E?EEE!E5E6E:AF E E EEE3FF F, F'!F,"F/'F,,F/c[U5nSnU4n[R"U[-(aUOUU[-(aUOUUU5upgnSn U(a[n U(a U [ -n U (dUR [5 MzUR U 5nM![an U Rn 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!$  sBB C) B<6C<C EpollSelectorcL[U5nUbUS:aSn[R"5n[UnUR X5 UR U5=n(dUR [5 M0USSnSnU[R)-(a[nU[R)-(a U[-nUR U5n[UnURX5 M!,(df  g=f![an U Rn 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 *#(::h#777HHZ(QZ]((#E'W$EHHUO'* V,^"  s5+DCC00 C>:D>D D# DD#D# PollSelectorcF[U5nUbUS:aSnO[US-5n[R"5n[UnUR X5 URU5=n(dUR [5 M0USSnSnU[R)-(a[nU[R)-(a U[-nUR U5n[UnURX5 M![an U Rn 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_pollrjFs  I  x!|H8f,-H{{}q! f%#yy22G2$ABEV^^O#V]]N" A"1%F KK '  sC> D  DD D c[RRS5=n(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_patchedrtksi KKOOO ,,q, 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'rsD# AA%//"    '' ZZ '' '' 88   8 $BD:z7zD 9o&&##fnn4vF##foo5G$$ >>FOO +foo =?NN)X 9n%% /M M"J( __F"**$ JJ* +E   G $ $WY(> 9    9U D #,,')2D2F2F D')5Et"LL D Y'' D Dr5