ho2FSrSSKrSSKJrJrJrJr SSKJr SSK J r SSK J r SSK JrJrJr SSKJr SS KJr S S KJrJr /4S jr"S S\5rSrS\\/S4/S4S\/S4S\/S44Sjr\"\5"SS\ R8\ R:55rg)aC This module provides base support for Twisted to interact with the glib/gtk mainloops. The classes in this module should not be used directly, but rather you should import gireactor or gtk3reactor for GObject Introspection based applications, or glib2reactor or gtk2reactor for applications using legacy static bindings. N)AnyCallableDictSet) implementer) posixbase)FileDescriptor) IReactorFDSetIReadDescriptorIWriteDescriptor)log) MonkeyPatcher)_IWaker _UnixWakercUH.n[RRU5cM%[U5e UHnS[RU'M g)a+ Check whether the given modules were imported, and if requested, ensure they will not be importable in the future. @param moduleNames: A list of module names we make sure aren't imported. @type moduleNames: C{list} of C{str} @param preventImports: A list of module name whose future imports should be prevented. @type preventImports: C{list} of C{str} @param errorMessage: Message to use when raising an C{ImportError}. @type errorMessage: C{str} @raise ImportError: with given error message if a given module name has already been imported. N)sysmodulesget ImportError) moduleNames errorMessagepreventImportsnames a/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/_glibbase.pyensureNotImportedrsF$ ;;??4 ,l+ +   Dc<^\rSrSrSrU4SjrSU4SjjrSrU=r$) GlibWaker7z' Run scheduled events after waking up. c.>[TU]5 XlgN)super__init__reactor)selfr% __class__s rr$GlibWaker.__init__<s  rcV>[TU]5 URR5 gr")r#doReadr% _simulate)r&r's rr*GlibWaker.doRead@s   r)r%)returnN) __name__ __module__ __qualname____firstlineno____doc__r$r*__static_attributes__ __classcell__r's@rrr7s!!rrcLSSKJn [5nURUSS5 U$)a: Integrate glib's wakeup file descriptor usage and our own. Python supports only one wakeup file descriptor at a time and both Twisted and glib want to use it. This is a context manager that can be wrapped around the whole glib reactor main loop which makes our signal handling work with glib's signal handling. r) _ossighelper_wakeup_fd_is_activeT)gir7raddPatch) signalGluepatchers r _signalGluer=Es&.oG Z!7> NridleAddloopQuitr-c^^UU4Sj$)zu Combine the C{glib.idle_add} and C{glib.MainLoop.quit} functions into a function suitable for crashing the reactor. c>T"T5$r"r>r?sr_loopQuitter..^s 78$rrBrCs``r _loopQuitterrFWs  %$rc ^\rSrSrSrS\4SjrSS\S\S\SS4U4S jjjr U4S jr S r S r S r SrSrSrSrSrSrSrSrSSjrSrSrS SjrSrSrSrSrU=r$)!GlibReactorBaseaa Base class for GObject event loop reactors. Notification for I/O events (reads and writes on file descriptors) is done by the gobject-based event loop. File descriptors are registered with gobject with the appropriate flags for read/write/disconnect notification. Time-based events, the results of C{callLater} and C{callFromThread}, are handled differently. Rather than registering each event with gobject, a single gobject timeout is registered for the earliest scheduled event, the output of C{reactor.timeout()}. For example, if there are timeouts in 1, 2 and 3.4 seconds, a single timeout is registered for 1 second in the future. When this timeout is hit, C{_simulate} is called, which calls the appropriate Twisted-level handlers, and a new timeout is added to gobject by the C{_reschedule} method. To handle C{callFromThread} events, we use a custom waker that calls C{_simulate} whenever it wakes up. @ivar _sources: A dictionary mapping L{FileDescriptor} instances to GSource handles. @ivar _reads: A set of L{FileDescriptor} instances currently monitored for reading. @ivar _writes: A set of L{FileDescriptor} instances currently monitored for writing. @ivar _simtag: A GSource handle for the next L{simulate} call. r-c[U5$r")rr&s r _wakerFactoryGlibReactorBase._wakerFactorys r glib_module gtk_moduleuseGtkNc>SUl[5Ul[5Ul0UlXlUR RUR R-UR R-Ul UR RUl UR RUlURUR-UlURUR-Ul["TU]I5 UR R&UlUR R*UlUR R/5UlUR0R2UlUR0R6UlUR R;5Ul[?UR R@UR<RB5Ul"UR<RFUl$gr")%_simtagset_reads_writes_sources_glib IOConditionHUPERRNVAL_POLL_DISCONNECTEDIN_POLL_INOUT _POLL_OUTINFLAGSOUTFLAGSr#r$ source_remove_source_remove timeout_add _timeout_addmain_context_defaultcontextpending_pending iteration _iterationMainLooplooprFidle_addquit_crashrun_run)r&rNrOrPr's rr$GlibReactorBase.__init__sg ,/E .1e 35    # # ' '%%)) *%%** +  $//22 $0044 }}t'>'>> )@)@@  "jj66 JJ22zz668  ,, ,,00JJ'') "4::#6#6 G IIMM rcT>^[TT]5 U4SjnTRSU5 g)zY Make sure the reactor's signal handlers are installed despite any outside interference. cn>TRR5 TRR5 gr")_signals uninstallinstallrKsr reinitSignals:GlibReactorBase._reallyStartRunning..reinitSignalss# MM # # % MM ! ! #rrN)r#_reallyStartRunning callLater)r&rzr's` rr|#GlibReactorBase._reallyStartRunnings% #% $ q-(rc^^[TS5(aUU4SjnTR5nOTnTnURRUURRUU5$)Nfilenoc>T"TU5$r"rB)ignored conditioncallbacksources rwrapper*GlibReactorBase.input_add..wrappers 22r)hasattrrrW io_add_watchPRIORITY_DEFAULT_IDLE)r&rrrrrs ` ` r input_addGlibReactorBase.input_addsY 68 $ $ 3]]_FFGzz&&  JJ , ,     rcH[R"XRXU5 g)z0 Called by event loop when an I/O event occurs. T)r callWithLogger_doReadOrWrite)r&rrs r_ioEventCallback GlibReactorBase._ioEventCallbacks 6#6#6 RrcX;agUnX;a"URURU5 Xe-nURXUR5URU'UR U5 g)z Add the given L{FileDescriptor} for monitoring either for reading or writing. If the file is already monitored for the other operation, we delete the previous registration and re-register it for both reading and writing. N)rdrVrradd)r&rprimaryother primaryFlag otherFlagflagss r_addGlibReactorBase._addsa    ?    f 5 6  E $vd>S>S T f Frc|URXRURURUR5 g)zC Add a L{FileDescriptor} for monitoring of data available to read. N)rrTrUrarbr&readers r addReaderGlibReactorBase.addReaders& &++t||T\\4==Qrc|URXRURURUR5 g)z? Add a L{FileDescriptor} for monitoring ability to write data. N)rrUrTrbrar&writers r addWriterGlibReactorBase.addWriters& &,, T]]DLLQrc,[UR5$)zG Retrieve the list of current L{FileDescriptor} monitored for reading. )listrTrKs r getReadersGlibReactorBase.getReaderssDKK  rc,[UR5$)zG Retrieve the list of current L{FileDescriptor} monitored for writing. )rrUrKs r getWritersGlibReactorBase.getWriterssDLL!!rcNURURUR5$)z: Remove monitoring for all registered L{FileDescriptor}s. ) _removeAllrTrUrKs r removeAllGlibReactorBase.removeAll st{{DLL99rcX;agURURU5 URU5 X;a*URXUR5URU'gURR U5 g)z Remove monitoring the given L{FileDescriptor} for either reading or writing. If it's still monitored for the other operation, we re-register the L{FileDescriptor} for only that operation. N)rdrVremoverrpop)r&rrrrs r_removeGlibReactorBase._removesf   DMM&12v ?$(NN6$BWBW$XDMM& ! MM  f %rcfURXRURUR5 g)z: Stop monitoring the given L{FileDescriptor} for reading. N)rrTrUrbrs r removeReaderGlibReactorBase.removeReaders  V[[$,, FrcfURXRURUR5 g)z: Stop monitoring the given L{FileDescriptor} for writing. N)rrUrTrars r removeWriterGlibReactorBase.removeWriter$s  V\\4;; ErcUR5 UR5(a)URS5 UR5(aM(gg)z^ One iteration of the event loop, for trial's use. This is not used for actual reactor runs. rN)runUntilCurrentrjrl)r&delays riterateGlibReactorBase.iterate*s4 mmoo OOA mmoorcb[RRU5 UR5 g)z Crash the reactor. N)rPosixReactorBasecrashrqrKs rrGlibReactorBase.crash4s! ""((. rcb[RRU5 UR5 g)z Stop the reactor. N)rrstopwakeUprKs rrGlibReactorBase.stop;s# ""''- rc[5 URUR5 URUS9 UR(aUR 5 SSS5 g!,(df  g=f)z Run the reactor. )installSignalHandlersN)r=callWhenRunning _reschedule startRunning_startedrs)r&rs rrrGlibReactorBase.runIsI]  !1!1 2   4I  J}} ]]s A A  A.cn[RR"U/UQ70UD6nUR5 U$)z Schedule a C{DelayedCall}. )rrr}r)r&argskwargsresults rr}GlibReactorBase.callLaterSs7++55dLTLVL  rc URb"URUR5 SUlUR5nUbAUR[ US-5UR UR RS9Ulgg)z+ Schedule a glib timeout for C{_simulate}. Ni)priority)rRrdtimeoutrfintr+rWr)r&rs rrGlibReactorBase._reschedule]st << #    -DL,,.  ,,GdN#99-DL rcDUR5 UR5 g)zH Run timers, and then reschedule glib timeout for next scheduled event. N)rrrKs rr+GlibReactorBase._simulatels  r)rarbr\r^r`rqrWrlrjrTrsrRrdrVrfrUrhrn)F)r)T)r.r/r0r1r2rrLrboolr$r|rrrrrrrrrrrrrrrrr}rr+r3r4r5s@rrHrHasBw"C"S"$"SW""B)B " R R ! " : &G F   rrH)r2rtypingrrrrzope.interfacertwisted.internetrtwisted.internet.abstractr twisted.internet.interfacesr r r twisted.pythonr twisted.python.monkeyrrwrrrrr=rFr_PollLikeMixinrHrBrrrs  ++&&4XX/)AC!6 ! !$% xD)*D0 1%=Eb$h=O% b$h% ]Oi00)2J2JOOr