Yf0(dZddlmZddlmZmZddlmZmZddl m Z ddl m Z m Z ddlmZddlmZdd lmZdd lmZmZmZdd lmZmZdd lmZdd lmZeZ dZ!ddZ"eeGddej#Z$dZ%dgZ&dS) a Threaded select reactor The threadedselectreactor is a specialized reactor for integrating with arbitrary foreign event loop, such as those you find in GUI toolkits. There are three things you'll need to do to use this reactor. Install the reactor at the beginning of your program, before importing the rest of Twisted:: | from twisted.internet import _threadedselect | _threadedselect.install() Interleave this reactor with your foreign event loop, at some point after your event loop is initialized:: | from twisted.internet import reactor | reactor.interleave(foreignEventLoopWakerFunction) | self.addSystemEventTrigger('after', 'shutdown', foreignEventLoopStop) Instead of shutting down the foreign event loop directly, shut down the reactor:: | from twisted.internet import reactor | reactor.stop() In order for Twisted to do its work in the main thread (the thread that interleave is called from), a waker function is necessary. The waker function will be called from a "background" thread with one argument: func. The waker function's purpose is to call func() from the main thread. Many GUI toolkits ship with appropriate waker functions. One example of this is wxPython's wx.callAfter (may be wxCallAfter in older versions of wxPython). These would be used in place of "foreignEventLoopWakerFunction" in the above example. The other integration point at which the foreign event loop and this reactor must integrate is shutdown. In order to ensure clean shutdown of Twisted, you must allow for Twisted to come to a complete stop before quitting the application. Typically, you will do this by setting up an after shutdown trigger to stop your foreign event loop, and call reactor.stop() where you would normally have initiated the shutdown procedure for the foreign event loop. Shutdown functions that could be used in place of "foreignEventloopStop" would be the ExitMainLoop method of the wxApp instance with wxPython. ) annotations)EBADFEINTR)EmptyQueue)Thread)AnyCallable) implementer) ThreadWorker) posixbase) IReactorFDSetIReadDescriptorIWriteDescriptor)_preenDescriptors_select)Logger)callWithLoggerc|N)es R/var/www/html/env/lib/python3.11/site-packages/twisted/internet/_threadedselect.pyraiseExceptionrDs Gtimeout float | Nonereadmapdict[int, IReadDescriptor]writemapdict[int, IWriteDescriptor] handleResulteCallable[[list[int], list[int], dict[int, IReadDescriptor], dict[int, IWriteDescriptor], bool], None]returnNonechd}g}g} |}|} t||g|} | \}}} nY#t$rd}YnKt$r?} | jdt krYd} ~ dS| jdt krd}Yd} ~ n d} ~ wwxYw||||||dS)z Invoke C{select}. This will be called in a non-main thread, so it is very careful to work only on integers and avoid calling any application code. FTrN)keysr ValueErrorOSErrorargsrr) rrr r"preenrwreadints writeintsresultignoredses r_threadsafeSelectr4Hs& E A A<<>>MMOO  Xy"g>>F.#MAq' /   E E   wqzU"" u$$  &LAw%00000s)A B  B !B=BBB ceZdZdZ d0d1dZdZd Zd2dZd3dZd4dZ d5d6dZ d7dZ d8dZ d7dZ d8d Zd9d"Zd:d$Zd;d&Zd'Zd(Zd4d)Zd4fd* Zdd.Zd4fd/ ZxZS)?ThreadedSelectReactorzVA threaded select() based reactor - runs on all POSIX platforms and on Win32. Nwaker+Callable[[Callable[[], None]], None] | Noner$r%ct|_t|_tj|d|_||_d|_dSr) setreadswritesr PosixReactorBase__init___selectorThread mainWaker_iterationQueue)selfr7s rr>zThreadedSelectReactor.__init__sN,/55 -0UU "++D11148AErc8|jdSr)r7wakeUprBs rrDzThreadedSelectReactor.wakeUps rcbtjj|g|Ri|}||Sr)r r= callLaterrD)rBr+kwtples rrGzThreadedSelectReactor.callLaters7)3DF4FFF2FF  r selectableobjectmethodstrctd|5}t||}dddn #1swxYwY|jx}|j}|r||||dkdSdS)Nzwhile handling selectable {sel})seldoRead)_logfailuresHandledgetattrfailurevalue_disconnectSelectable)rBrJrLopwhyfails r_doReadOrWritez$ThreadedSelectReactor._doReadOrWrites  ! ! -:"   0 -'*f--//C 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0J D +*C  L  & &z3(8J K K K K K L LsAA Arr keepGoingboolcR i i dj fdj ffD]"\}}}|D]}|||<#j Jddfd j"t dt _j  fddS)NTFz]neither .interleave() nor .mainLoop() / .run() called, but we are somehow running the reactorr- list[int]r.rrr r!r,r\r$r%c :dfd }dS)Nr$r%cr"t j j jdS j}D]%}|}| jvrt |||d& D]%} |}| jvrt |||d&  jr,r*  ddS dS)NrPdoWriteT) rr;r<rVrZ_callWithLoggerrunUntilCurrent_started _selectOncer_cleanUpThread) _drdwreadable rselectablewritable wselectabler[r,r-rrBr.r s r onMainThreadzSThreadedSelectReactor._selectOnce..callReadsAndWrites..onMainThreads% DK1KF+ !SSH")("3K"dj00' UKRRR !TTH"*8"4K"dk11' UKSSS$$&&&=*Y*$$T\\^^T:::::'')))))rr$r%r) r-r.rr r,rlr[r@rBs ````` rcallReadsAndWritesz=ThreadedSelectReactor._selectOnce..callReadsAndWritessZ * * * * * * * * * * *Y * * *rcFt|S)Ntarget)rstartrps rz3ThreadedSelectReactor._selectOnce..svV444::<<rc(tSr)r4)rnr;rr<srrsz3ThreadedSelectReactor._selectOnce..s%guf>PQQr) r-r^r.r^rrr r!r,r\r$r%)r;r<filenor@r?r rdo) rBrr[isReadfdmapdeachrnr@r;r<s ``` @@@@rrez!ThreadedSelectReactor._selectOnces "!# 4:u % DK (!  ( ( FE1 ( (#'$++--   (N $$ 5%$$  * * * * * * * *B   '#/<' 4'  NN      ! rT$Callable[[Callable[[], None]], None]installSignalHandlerscj||_|||dddS)at interleave(waker) interleaves this reactor with the current application by moving the blocking parts of the reactor (select() in this case) to a separate thread. This is typically useful for integration with GUI applications which have their own event loop already running. See the module docstring for more information. TN)r@ startRunningre)rBr7rs r interleavez ThreadedSelectReactor.interleaves<$ /000 d#####rreaderrcb|j||dS)z@Add a FileDescriptor for notification of data available to read.N)r;addrDrBrs r addReaderzThreadedSelectReactor.addReaders' v rwriterrcb|j||dS)zAAdd a FileDescriptor for notification of data available to write.N)r<rrDrBrs r addWriterzThreadedSelectReactor.addWriters'  rcP||jvr|j|dSdS)z?Remove a Selectable for notification of data available to read.N)r;removers r removeReaderz"ThreadedSelectReactor.removeReaders3 TZ   J  f % % % % % rcP||jvr|j|dSdS)z@Remove a Selectable for notification of data available to write.N)r<rrs r removeWriterz"ThreadedSelectReactor.removeWriters3 T[ K  v & & & & & ! r(list[IReadDescriptor | IWriteDescriptor]cB||j|jSr) _removeAllr;r<rEs r removeAllzThreadedSelectReactor.removeAll stz4;777rlist[IReadDescriptor]c*t|jSr)listr;rEs r getReadersz ThreadedSelectReactor.getReaderssDJrlist[IWriteDescriptor]c*t|jSr)rr<rEs r getWritersz ThreadedSelectReactor.getWriterssDK   rcltj||dS)z Extend the base stop implementation to also wake up the select thread so that C{runUntilCurrent} notices the reactor should stop. N)r r=stoprDrEs rrzThreadedSelectReactor.stops, "''--- rcltj||dSr)r r=crashrDrEs rrzThreadedSelectReactor.crashs*"((... rcNt|_|jj|_dS)a Mostly for compliance with L{IReactorCore} and usability with the tests, set up a fake blocking main-loop; make the "foreign" main loop we are interfacing with be C{self.mainLoop()}, that is reading from a basic Queue. N)rrAputr@rEs r_testMainLoopSetupz(ThreadedSelectReactor._testMainLoopSetup$s! %ww-1rcpt|dS)zu Handle uninstallation to ensure that cleanup is properly performed by ReactorBuilder tests. N)super_uninstallHandlerrfrB __class__s rrz'ThreadedSelectReactor._uninstallHandler.s3 !!### rrfloatc|j|j||t |dSr)rAr@rrDriterate)rBrrs rrzThreadedSelectReactor.iterate6sN   'DN,B  # # % % %       rc|jJ||d |j|}n#t$rYdSwxYw|dS)NF)r)rAregetr)rBrworks r doIterationz!ThreadedSelectReactor.doIteration<sx#/// %((( '++G+<rDrGrZrerfrrrrrrrrrrrrrrr __classcell__)rs@rr6r6~s DHFFFFF LLLL7 7 7 7 r'+$$$$$,  &&&& '''' 8888    !!!!2222!!!!!!! rr6cDt}ddlm}|||S)zDConfigure the twisted mainloop to be run using the select() reactor.r)installReactor)r6twisted.internet.mainr)reactorrs rinstallrMs4#%%G444444N7 NrrN) rrrrr r!r"r#r$r%)'r __future__rerrnorrqueuerr threadingrtypingr r zope.interfacer twisted._threadsr twisted.internetr twisted.internet.interfacesrrrtwisted.internet.selectreactorrrtwisted.loggerrtwisted.python.logrrbrQrr4r=r6r__all__rrrrs ++X#""""" &&&&&&))))))&&&&&&XXXXXXXXXXEEEEEEEE!!!!!!@@@@@@ vxx   31313131l ]KKKKKI6KKK\ +r