֛h0.SrSSKJr SSKJrJr SSKJrJr SSK J r SSK J r J r SSKJr SSKJr SS KJr SS KJrJrJr SS KJrJr SS KJr SS KJr \"5r Sr!SSjr"\"\5"SS\RF55r$Sr%S/r&g)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)callWithLoggercUeN)es dC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/_threadedselect.pyraiseExceptionrDs GcFSn/n/nUR5nUR5n[Xx/U5n U upVn U"XVXU5 g![a SnM[aAn U RS[ :XaSn A gU RS[ :XaSnSn A M^eSn A ff=f)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) timeoutreadmapwritemap handleResultpreenrwreadints writeintsresultignoredses r_threadsafeSelectr-Hs& E A A <<>MMO  X"g>F.#MA' w%01 E  wwqzU" u$  s) A B  B B;BBB c^\rSrSrSrSSSjjrSrSrSSjrSSjr SSjr SSS jjr S S jr S!S jr S S jrS!S jrS"SjrS#SjrS$SjrSrSrSSjrSU4SjjrS%S&U4SjjjrS'SjrSU4SjjrSrU=r$)(ThreadedSelectReactor~zNA threaded select() based reactor - runs on all POSIX platforms and on Win32. c[5Ul[5Ul[RR U5 SUlXlSUlgr) setreadswritesr PosixReactorBase__init___selectorThread mainWaker_iterationQueue)selfwakers rr6ThreadedSelectReactor.__init__s?,/5 -0U ""++D148AErc8URR5 gr)r;wakeUpr:s rr>ThreadedSelectReactor.wakeUps rcn[RR"U/UQ70UD6nUR5 U$r)r r5 callLaterr>)r:r kwtples rrBThreadedSelectReactor.callLaters0))33DF4F2F  rc[RSUS9n[X5"5nSSS5 WR=nb URnW(aUR XUS:H5 gg!,(df  NG=f)Nzwhile handling selectable {sel})seldoRead)_logfailuresHandledgetattrfailurevalue_disconnectSelectable)r: selectablemethodopwhyfails r_doReadOrWrite$ThreadedSelectReactor._doReadOrWritesq  ! ! -:" *-/C JJ D +**C   & &z(8J K    s A'' A5c^^^^^^ ^ 0m 0m STRT 4STRT 44H!up4nUHnXeUR5'M M# TRmTcS5eSUUU4SjjmTRc[ S[ 55TlTRRUU UU 4Sj5 g)NTFz]neither .interleave() nor .mainLoop() / .run() called, but we are somehow running the reactorc 6>^^^^^TSUUUUUUU4Sjj5ng)Nc>T(a,[T RT RT R5 gT RnTH'nTUnUT R;dM[ X US5 M) T H'nT UnUT R;dM[ X@US5 M) T R 5 T R(a(T(a!T RT R5S5 gT R5 g)NrHdoWriteT) rr3r4rNrT_callWithLoggerrunUntilCurrent_started _selectOncer!_cleanUpThread) _drdwreadable rselectablewritable wselectable keepGoingr%r&r"r:r'r#s r onMainThreadSThreadedSelectReactor._selectOnce..callReadsAndWrites..onMainThreads% DKK1K1K++ !H")("3K"djj0' KR!" !"H"*8"4K"dkk1' KS!" $$&==Y$$T\\^T:'')rreturnNoner) r&r'r"r#r%rerdr8r:s ````` rcallReadsAndWrites=ThreadedSelectReactor._selectOnce..callReadsAndWritess * * *rc0[US9R5$)Ntarget)rstartrms r3ThreadedSelectReactor._selectOnce..svV4::[TTTT5$r)r-)rjr3r!r4srrprqs%guf>PQr) r& list[int]r'rsr"dict[int, IReadDescriptor]r#dict[int, IWriteDescriptor]r%boolrhri)r3r4filenor8r7r rdo) r:r!rdisReadfdmapdeachrjr8r3r4s ``` @@@@rr]!ThreadedSelectReactor._selectOnces "!# 4::u % DKK (! F1#'$++-  ! NN $  5 $  * * *0 *2  *   *   * *B    '#/*>' '  NN  !rcVXlURU5 URSS5 g)aD 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)r8 startRunningr])r:r;installSignalHandlerss r interleave ThreadedSelectReactor.interleaves($ /0 d#rcZURRU5 UR5 g)z@Add a FileDescriptor for notification of data available to read.N)r3addr>r:readers r addReaderThreadedSelectReactor.addReaders v rcZURRU5 UR5 g)zAAdd a FileDescriptor for notification of data available to write.N)r4rr>r:writers r addWriterThreadedSelectReactor.addWriters  rcZXR;aURRU5 gg)z?Remove a Selectable for notification of data available to read.N)r3removers r removeReader"ThreadedSelectReactor.removeReaders# ZZ  JJ  f % rcZXR;aURRU5 gg)z@Remove a Selectable for notification of data available to write.N)r4rrs r removeWriter"ThreadedSelectReactor.removeWriters# [[ KK  v & !rcNURURUR5$r) _removeAllr3r4r?s r removeAllThreadedSelectReactor.removeAll stzz4;;77rc,[UR5$r)listr3r?s r getReaders ThreadedSelectReactor.getReaderssDJJrc,[UR5$r)rr4r?s r getWriters ThreadedSelectReactor.getWriterssDKK  rcb[RRU5 UR5 g)z Extend the base stop implementation to also wake up the select thread so that C{runUntilCurrent} notices the reactor should stop. N)r r5stopr>r?s rrThreadedSelectReactor.stops! ""''- rcb[RRU5 UR5 gr)r r5crashr>r?s rrThreadedSelectReactor.crashs""((. rcX[5UlURRUlg)z 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)rr9putr8r?s r_testMainLoopSetup(ThreadedSelectReactor._testMainLoopSetup$s! %w--11rcB>[TU]5 UR5 g)z] Handle uninstallation to ensure that cleanup is properly performed by ReactorBuilder tests. N)super_uninstallHandlerr^r: __class__s rr'ThreadedSelectReactor._uninstallHandler.s !# rc>URcURcUR5 UR5 [TU]U5 gr)r9r8rr>riterate)r:r!rs rrThreadedSelectReactor.iterate6s9    'DNN,B  # # %   rcURceURUS5 URRUS9nU"5 g![a gf=f)NF)r!)r9r]getr)r:r!works r doIteration!ThreadedSelectReactor.doIteration<s]##/// %( ''++G+UR5 [TU] 5 g)z" This should not normally be run. N)rrmainLooprs rrThreadedSelectReactor.mainLoopEs ! r)r9r7r8r3r4r)r;z+Callable[[Callable[[], None]], None] | Nonerhri)rOobjectrPstrrhri)r! float | Nonerdrvrhrirg)T)r;z$Callable[[Callable[[], None]], None]rrvrhri)rrrhri)rrrhri)rhz(list[IReadDescriptor | IWriteDescriptor])rhzlist[IReadDescriptor])rhzlist[IWriteDescriptor])r)r!floatrhri)r!rrhri)__name__ __module__ __qualname____firstlineno____doc__r6r>rBrTr]r^rrrrrrrrrrrrrrr__static_attributes__ __classcell__)rs@rr/r/~s DHF@F F L7 r'+$3$ $$  $,  & ' 8 !2!! rr/c6[5nSSKJn U"U5 U$)zDConfigure the twisted mainloop to be run using the select() reactor.r)installReactor)r/twisted.internet.mainr)reactorrs rinstallrMs#%G47 NrrN) r!rr"rtr#rur$zeCallable[[list[int], list[int], dict[int, IReadDescriptor], dict[int, IWriteDescriptor], bool], None]rhri)'r __future__rerrnorrqueuerr threadingrtypingr r zope.interfacer twisted._threadsr twisted.internetr twisted.internet.interfacesrrrtwisted.internet.selectreactorrrtwisted.loggerrtwisted.python.logrrZrIrr-r5r/r__all__rrrrs +X# &)&XXE!@ x 31 31 '31*31  31 31l ]KI66KK\ +r