h"4SrSSKrSSKrSSKJr SSKJr SSKJr SSK J r \ "\S5r \ "\S5r \ "\S 5r\ "\S 5r\ "\S 5r\"\5"S S \R(\R*55rSrS S/rg!\a r\"\5eSrCff=f)z An epoll() based implementation of the twisted main loop. To install the event loop (and you should do this before any connections, listeners or connectors are added):: from twisted.internet import epollreactor epollreactor.install() N) implementer) posixbase) IReactorFDSet)logepollEPOLLHUPEPOLLERREPOLLINEPOLLOUTcp\rSrSrSr\\-r\r \ r Sr Sr SrSrSrSrS rS rS rS rS r\rSrg) EPollReactor%a7 A reactor that uses epoll(7). @ivar _poller: A C{epoll} which will be used to check for I/O readiness. @ivar _selectables: A dictionary mapping integer file descriptors to instances of C{FileDescriptor} which have been registered with the reactor. All C{FileDescriptors} which are currently receiving read or write readiness notifications will be present as values in this dictionary. @ivar _reads: A set containing integer file descriptors. Values in this set will be registered with C{_poller} for read readiness notifications which will be dispatched to the corresponding C{FileDescriptor} instances in C{_selectables}. @ivar _writes: A set containing integer file descriptors. Values in this set will be registered with C{_poller} for write readiness notifications which will be dispatched to the corresponding C{FileDescriptor} instances in C{_selectables}. @ivar _continuousPolling: A L{_ContinuousPolling} instance, used to handle file descriptors (e.g. filesystem files) that are not supported by C{epoll(7)}. c[S5Ul[5Ul[5Ul0Ul[ R"U5Ul[ RRU5 g)zU Initialize epoll object, file descriptor tracking dictionaries, and the base class. iN) r_pollerset_reads_writes _selectablesr_ContinuousPolling_continuousPollingPosixReactorBase__init__)selfs d/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/epollreactor.pyrEPollReactor.__init__GsPT{ e u "+">">t"D""++D1cUR5nXr;aXUnXs;a X-nURRXx5 OURRXx5 UR U5 XU'gg)z Private method for adding a descriptor from the event loop. It takes care of adding it if new or modifying it if already added for another state (read -> read/write for example). N)filenormodifyregisteradd) rxerprimaryother selectablesevent antieventfdflagss r_addEPollReactor._addVsfZZ\ E {" ##B. %%b0 KKO!O! rcURXRURUR[[ 5 g![ aDnUR[R:Xa URRU5 SnAgeSnAff=f)zB Add a FileDescriptor for notification of data available to read. N) r*rrrr r OSErrorerrnoEPERMr addReader)rreaderes rr0EPollReactor.addReaderpsj  II T\\43D3Dgx  ww%++%''11&99 ;> B 9BBB cURXRURUR[[ 5 g![ aDnUR[R:Xa URRU5 SnAgeSnAff=f)zC Add a FileDescriptor for notification of data available to write. N) r*rrrr r r-r.r/r addWriter)rwriterr2s rr6EPollReactor.addWritersk  II dkk43D3DhPW  ww%++%''11&99 r4cUR5nUS:Xa UR5H upxXLdM O gXr;aRXs;aUn URRXy5 OXG URR U5 UR U5 gg)z Private method for removing a descriptor from the event loop. It does the inverse job of _add, and also add a check in case of the fd has gone away. N)ritemsrr unregisterremove) rr"r#r$r%r&r'r(fdesr)s r_removeEPollReactor._removesZZ\ 8'--/;0 ={! ##B.O ''+ NN2  rcURRU5(aURRU5 gURXRUR UR [[5 g)zA Remove a Selectable for notification of data available to read. N) r isReading removeReaderr?rrrr r )rr1s rrCEPollReactor.removeReadersW  " " , ,V 4 4  # # 0 0 8  KKt/@/@'8 rcURRU5(aURRU5 gURXRUR UR [[5 g)zB Remove a Selectable for notification of data available to write. N) r isWriting removeWriterr?rrrr r )rr7s rrGEPollReactor.removeWritersW  " " , ,V 4 4  # # 0 0 8  LL$++t/@/@(G rc URURVs/sHoRUPM snURVs/sHoRUPM sn5URR 5-$s snfs snf)z4 Remove all selectables, and return a list of them. ) _removeAllrrrr removeAllrr(s rrKEPollReactor.removeAllsr OO15=2""2&=15>2""2&> %%//1  2 =>s A<B cURVs/sHoRUPM snURR5-$s snfN)rrr getReadersrLs rrPEPollReactor.getReaderssG,0KK ,7b  b !K  # # . . 01 1 AcURVs/sHoRUPM snURR5-$s snfrO)rrr getWritersrLs rrTEPollReactor.getWriterssG,0LL ,8b  b !L  # # . . 01 1 rRczUcSnURRU[UR55nURnUH-upVURUn[R"XtXuU5 M/ g![a)nUR [ R :XaSnAgeSnAff=f![a Muf=f)z! Poll the poller for new events. Nr:) rpolllenrr-r.EINTR_doReadOrWritercallWithLoggerKeyError)rtimeoutlerr_drdwr(r& selectables rdoPollEPollReactor.doPolls ?G   !!'3t/@/@+ABA##IB M!..r2 "":jeL  yyEKK'    s//A6 B,6 B)B$#B$$B), B:9B:)rrrrrN)__name__ __module__ __qualname____firstlineno____doc__rr _POLL_DISCONNECTEDr _POLL_INr _POLL_OUTrr*r0r6r?rCrGrKrPrTrb doIteration__static_attributes__rrr r %s]8"H,HI 2"4""2      1 1 M>Krr c4[5nSSKJn U"U5 g)z Install the epoll() reactor. r)installReactorN)r twisted.internet.mainrp)prps rinstallrss A41rrs)rhr.selectzope.interfacertwisted.internetrtwisted.internet.interfacesrtwisted.pythonrgetattrrrr r r AttributeErrorr2 ImportErrorr_PollLikeMixinr rs__all__rnrrr~s &&5  FG $Evz*Hvz*Hfi(Gvz*H  ]P9--y/G/GPPf 9 %E a.s-BB BB