]j6.%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(\RRS :waSS jr*OSSjr*S S!Sjjr+S S"Sjjr,S S!Sjjr-S S"Sjjr.S S!Sjjr/\0"\S5(a[\\Rb\Rd-\\Rb\Rf-\ \Rb\Rd-\Rf-0r4O0r4S S!Sjjr5\0"\S5(aN\\Rl\\Rn\ \Rl\Rn-0r8\Rl\Rn-)r9O0r8S S!Sjjr:S#Sjr;\(a \RxrTU-mTR5 grsetstateevr3s rwakeupwait_async..wakeups  r!bad poll status: rrr>rreturnNone)r&rrr'WAIT_RWAIT_Wr InternalErrorclear add_readerREADY_R add_writerREADY_Wrwaitr remove_reader remove_writerr*OSErrorrr,r-) r.rr/loopr@r0readerwriterrr4r?r3s @@r wait_asyncrU~sw@AA B  D  IZFZFfoo(9!&=>> HHJE88 /"2779h777&&v.&&v.A+8#&&v.&&v. E  !;<"D  s~,F:BE1D+!D)"D+&AE1)D++ D85D;7D88D;;3E..E11 F7;F F7 F2,F7-F:2F77F:c~^ ^ # Uc [S5e[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(aUR!U5 U(aUR#U5 UR%T 5upEGMNc![a NTf=fN\!U(aUR!U5 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. :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. Nr#c*>UmTR5 grr;r=s rr@wait_conn_async..wakeups r!rBrrC)r&rrr'rFrGrrHrIrJrKrLrMrrNrrOrPr*r,r-) r.r/rRr@rr0rSrTrr4r?r3s @@rwait_conn_asyncrYsq@AA B  D I ZFZFfoo(9!&=>> HHJE88 /&rwwy(;;;'')OO&&v.&&v.IF1<'$&&v.&&v.  s,F=BFE" E*E+E/E"E E"AFE EE"EE""3FF F:" F5/F:0F=5F::F=cUc [S5e[U5nSnU4n[R"U[-(aUOUU[-(aUOUUU5upgnU(a![ U5 [ R"S5eSn U(a[n U(a U [-n URU 5nM![an [ R"S5U eSn A f[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. Nr#r rr)r&r'r)rFrGrrrrKrMr*rQr,r-) r.rr/r0emptyfnlistrlwlxlr3rr4s r wait_selectr`s @AA If*%f*% JBB  ((()CDDE A#& E  !;<"D  s*B'B77 C=C C=% C82C=8C= EpollSelectorctUc [S5e[U5nUS:aSn[R"5n[UnUR X5 UR U5=n(d"[U5 UR[5 M;USSnSnU[R-(a[nU[R-(a U[-nURU5n[UnURX5 M!,(df  g=f![an U R n 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 Nr#rr )r&r'r)epoll_epoll_evmasksr(pollrr*r+EPOLLINrKEPOLLOUTrMmodifyr,r-) r.rr/r0rdevmaskfileevsr?r3rr4s r wait_epollrl-s @AA I a<H \\^u#A&F NN6 *#(::h#777$V,HHZ(QZ]&#E'W$EHHUO'* V,^$  s5(DC D DDD D7 D2,D72D7 PollSelectorcUc [S5e[U5nUS:aSnO[US-5n[R"5n[ UnUR X5 UR U5=n(dUR[5 M0USSnSnU[R-(a[nU[R-(a U[-nU(d/U[-(a![U5 [R "S5eURU5n[ UnUR#X5 M![$an U R&n U sSn A $Sn A ff=f)zU Wait for a generator using poll where supported. Parameters are like for `wait()`. Nr#rg@@r r)r&r'intr)rf _poll_evmasksr(r*r+POLLINrKPOLLOUTrMPOLL_BADrrrrir,r-) r.rr/r0rfrjrkr?r3rr4s r wait_pollrtgs* @AA# I a<H8f,-H{{}q! f%#yy22G2$ABEFMM!FNN" R(] ((()CDDA"1%F KK '),  sD-D== E EEEc[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.monkeyr)Tz+failed to detect gevent monkey-patching: %sNF)sysmodulesgetis_module_patchedrloggerwarning)mrs r_is_select_patchedr}si KKOOO ,,q, N""8,,-  N NNH" M M  NsA A, A''A,rrNPSYCOPG_WAIT_FUNCwait_zHPSYCOPG_WAIT_FUNC should be the name of an available wait function; got SelectSelector)rrorDrE)rc)r.z PQGen[RV]rror/floatrDr )r.z PQGenConn[RV]r/rrDr )rDbool)E__doc__ __future__rrrvr)logging selectorsasynciorrrrrr rabcr r r r_enumsrr_cmodulerRrFWrGRWWAIT_RWNONEr+rKrMREADY_RW getLogger__name__rzplatformrr5r8rUrYr`hasattr EPOLLONESHOTrgrhrerlrqrrrprsrtr}wait_c__annotations__environfname startswithglobals ImportErrorrNgetattrr r!rrsT# AA%//"    '' ZZ '' '' 88   8 $<<7I!HD:z:@%P 9o&&##fnn4##foo5$$v~~5GN N,^ 9n%% /M /0HM+\( __F"**$ JJ* +E   G $ $WY(> 9    9U D #,,')2D2F2F D')5Et"LL D Y'' D Dr!