+ j"8Rt^RIt^RIt^RIHt^RIHt^RIHt^RI H t ] !]R4t ] !]R4t ] !]R4t] !]R 4t] !]R 4t]!]4!R R ]P(]P*44tR tR R.tR# ]dt]!]4hRtAii;i)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)logepollEPOLLHUPEPOLLERREPOLLINEPOLLOUTca]tRt^%toRt]],t]t ] t Rt Rt RtRtRtRtRtR tR tR tR t]tR tVtR#) EPollReactora7 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 \R4Vn\4Vn\4Vn/Vn\ P!V4Vn\ PPV4R#)zU Initialize epoll object, file descriptor tracking dictionaries, and the base class. iN) r_pollerset_reads_writes _selectablesr_ContinuousPolling_continuousPollingPosixReactorBase__init__)selfs&?/usr/lib/python3/dist-packages/twisted/internet/epollreactor.pyrEPollReactor.__init__GsPT{ e u "+">">t"D""++D1c VP4pWr9d_TpWs9d%W,pVPPWx4MVPPWx4VP V4WV&R#R#)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! rc &VPWPVPVP\\ 4R# \ dGpTP\P8Xd"TPPT4Rp?R#hRp?ii;i)zB Add a FileDescriptor for notification of data available to read. N) r(rrrr r OSErrorerrnoEPERMr addReader)rreaderes&& rr.EPollReactor.addReaderpsj  II T\\43D3Dgx  ww%++%''11&99 ;? B :B  B  Bc &VPWPVPVP\\ 4R# \ dGpTP\P8Xd"TPPT4Rp?R#hRp?ii;i)zC Add a FileDescriptor for notification of data available to write. N) r(rrrr r r+r,r-r addWriter)rwriterr0s&& rr4EPollReactor.addWritersk  II dkk43D3DhPW  ww%++%''11&99 r2c ,VP4pVR8Xd#VP4F wrxWJgK M R#Wr9dUWs9dTp VPPWy4MWGVPP V4VP V4R#R#)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  rc VPPV4'dVPPV4R#VPWPVP VP \\4R#)zA Remove a Selectable for notification of data available to read. N) r isReading removeReaderr=rrrr r )rr/s&&rrAEPollReactor.removeReadersW  " " , ,V 4 4  # # 0 0 8  KKt/@/@'8 rc VPPV4'dVPPV4R#VPWPVP VP \\4R#)zB Remove a Selectable for notification of data available to write. N) r isWriting removeWriterr=rrrr r )rr5s&&rrEEPollReactor.removeWritersW  " " , ,V 4 4  # # 0 0 8  LL$++t/@/@(G rc TPVPUu.uFqPV,NK upVPUu.uFqPV,NK up4VPP 4,#uupiuupi)z4 Remove all selectables, and return a list of them. ) _removeAllrrrr removeAllrr&s& rrIEPollReactor.removeAllsx OO15=2""2&&=15>2""2&&> %%//1  2 =>s BB cVPUu.uFqPV,NK upVPP4,#uupiN)rrr getReadersrJs& rrNEPollReactor.getReaderssJ,0KK ,7b  b ! !K  # # . . 01 1 A cVPUu.uFqPV,NK upVPP4,#uupirM)rrr getWritersrJs& rrREPollReactor.getWriterssJ,0LL ,8b  b ! !L  # # . . 01 1 rPc VfRpVPPV\VP44pTPpTF1wrVTPT,p\P!YtYuT4K3 R# \d,pTP \ P 8XdRp?R#hRp?ii;i \dK~i;i)z! Poll the poller for new events. Nr8) rpolllenrr+r,EINTR_doReadOrWritercallWithLoggerKeyError)rtimeoutlerr_drdwr&r$ selectables&& rdoPollEPollReactor.doPolls ?G   !!'3t/@/@+ABA##IB M!..r2 "":jeL  yyEKK'    s//A< B5< B2B-,B--B25 CC)rrrrrN)__name__ __module__ __qualname____firstlineno____doc__rr_POLL_DISCONNECTEDr _POLL_INr _POLL_OUTrr(r.r4r=rArErIrNrRr` doIteration__static_attributes____classdictcell__) __classdict__s@rr r %s`8"H,HI 2"4""2      1 1 M>Krr c6\4p^RIHpV!V4R#)z Install the epoll() reactor. )installReactorN)r twisted.internet.mainro)pros rinstallrrs A41rrr)rfr,selectzope.interfacertwisted.internetrtwisted.internet.interfacesrtwisted.pythonrgetattrrrrr r AttributeErrorr0 ImportErrorr_PollLikeMixinr rr__all__rrr~s &&5  FG $Evz*Hvz*Hfi(Gvz*H  ]P9--y/G/GPPf 9 %E a.s-BB BB