tf"XdZddlZddlZddlmZddlmZddlmZddl m Z  e edZ e edZ e ed Ze ed Ze ed Zn#e$rZeedZ[wwxYweeGd d ejejZdZd dgZdS)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)logepollEPOLLHUPEPOLLERREPOLLINEPOLLOUTcjeZdZdZeezZeZe Z dZ dZ dZ dZdZdZdZd Zd Zd Zd ZeZd S) EPollReactora 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)}. ctd|_t|_t|_i|_t j||_t j |dS)zm Initialize epoll object, file descriptor tracking dictionaries, and the base class. iN) r_pollerset_reads_writes _selectablesr_ContinuousPolling_continuousPollingPosixReactorBase__init__selfs \/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/internet/epollreactor.pyrzEPollReactor.__init__Gs_T{{ ee uu "+">t"D"D"++D11111c|}||vr^|}||vr!||z}|j||n|j|||||||<dSdS)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_addzEPollReactor._addVsZZ\\ W  E U{{" ##B.... %%b%000 KKOOO!KOOO!  rc |||j|j|jtt dS#t $r<}|jtjkr|j |nYd}~dSd}~wwxYw)zR Add a FileDescriptor for notification of data available to read. N) r)rrrr r OSErrorerrnoEPERMr addReader)rreaderes rr.zEPollReactor.addReaderps  II T\43Dgx        w%+%%'11&9999:99999  37 A=1A88A=c |||j|j|jtt dS#t $r<}|jtjkr|j |nYd}~dSd}~wwxYw)zS Add a FileDescriptor for notification of data available to write. N) r)rrrr r r+r,r-r addWriter)rwriterr0s rr3zEPollReactor.addWriters  II dk43DhPW        w%+%%'11&9999:99999  r1c2|}|dkr"|D] \}}||urn dS||vrV||vr|} |j|| n||=|j|||dSdS)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_removezEPollReactor._removesZZ\\ 88'--//  D$;;E ==U{{! ##B....O ''+++ NN2      =rc|j|r|j|dS|||j|j|jttdS)zQ Remove a Selectable for notification of data available to read. N) r isReading removeReaderr;rrrr r )rr/s rr>zEPollReactor.removeReadersm  " , ,V 4 4   # 0 0 8 8 8 F DKt/@'8     rc|j|r|j|dS|||j|j|jttdS)zR Remove a Selectable for notification of data available to write. N) r isWriting removeWriterr;rrrr r )rr4s rrAzEPollReactor.removeWritersm  " , ,V 4 4   # 0 0 8 8 8 F DL$+t/@(G     rcfdjDfdjDjzS)zD Remove all selectables, and return a list of them. c*g|]}j|Sr.0r'rs r z*EPollReactor.removeAll..s!===2"2&===rc*g|]}j|SrDrErFs rrHz*EPollReactor.removeAll..s!>>>2"2&>>>r) _removeAllrrr removeAllrs`rrKzEPollReactor.removeAllsf OO=======>>>>>>>  %//11  2 rc^fdjDjzS)Nc*g|]}j|SrDrErFs rrHz+EPollReactor.getReaders...   &(D b !   r)rr getReadersrs`rrOzEPollReactor.getReaderssG    ,0K    # . . 0 01 1rc^fdjDjzS)Nc*g|]}j|SrDrErFs rrHz+EPollReactor.getWriters..rNr)rr getWritersrs`rrRzEPollReactor.getWriterssG    ,0L    # . . 0 01 1rcR|d} |j|t|j}n.#t$r!}|jt jkrYd}~dSd}~wwxYw|j}|D];\}} |j|}tj |||||,#t$rY8wxYwdS)z1 Poll the poller for new events. Nr6) rpolllenrr+r,EINTR_doReadOrWritercallWithLoggerKeyError)rtimeoutlerr_drdwr'r% selectables rdoPollzEPollReactor.doPolls ?G   !!'3t/@+A+ABBAA   yEK''  # M MIB M!.r2 ":uj"eLLLL     M Ms,-4 AAAA1 B B$#B$N)__name__ __module__ __qualname____doc__rr _POLL_DISCONNECTEDr _POLL_INr _POLL_OUTrr)r.r3r;r>rArKrOrRr_ doIterationrDrrr r %s8"H,HI 2 2 2"""4""2            111 111 MMM>KKKrr cDt}ddlm}||dS)z& Install the epoll() reactor. r)installReactorN)r twisted.internet.mainri)pris rinstallrls5 A444444N1rrl)rcr,selectzope.interfacertwisted.internetrtwisted.internet.interfacesrtwisted.pythonrgetattrrrr r r AttributeErrorr0 ImportErrorr_PollLikeMixinr rl__all__rDrrrwsg &&&&&&&&&&&&555555  GFG $ $Ewvz**Hwvz**Hgfi((Gwvz**HH +a.. ]PPPPP9-y/GPPPf 9 %s