3dddlZddlZddlmZddlmZmZddlmZm Z ddl m Z dZ GddZ d Zdd Zd Zd Zd ZdZdZdS)N)suppress)catch_warningsfilterwarnings)asyncioreactorerror) load_objectcddlm}t|dkrtd||s|d||St |ds||||St|dkr||d||St |d|ddzD]>} ||||cS#tj$r||dkrY;wxYwdS) z||_||_||_d|_dSN)_func_a_kw_call)selffuncakws r__init__zCallLaterOnce.__init__$s"  rcZddlm}|j||||_dSdSNrr )rr r$ callLater)r%delayr s rschedulezCallLaterOnce.schedule*sC,,,,,, : 8 **5$77DJJJ 8 8r*cJ|jr|jdSdSr )r$cancelr%s rr1zCallLaterOnce.cancel0s0 : J         r*c>d|_|j|ji|jSr )r$r!r"r#r2s r__call__zCallLaterOnce.__call__4s$ tz47/dh///r*N)r)__name__ __module__ __qualname____doc__r)r/r1r4r*rrrs_ 8888    00000r*rctj}tjdkrQtjdkrAt |tjs'tj}tj||S)N)win32)asyncioget_event_loop_policysys version_infoplatform isinstanceWindowsSelectorEventLoopPolicyset_event_loop_policy)policys rget_asyncio_event_loop_policyrG9sl  * , ,F F". LG #.67#IJJ. 799%f--- Mr*ct|}|tjurXttj5t |}tj|ddddS#1swxYwYdS|d^}}|dgz}td |}ttj5|ddddS#1swxYwYdS)zInstalls the :mod:`~twisted.internet.reactor` with the specified import path. Also installs the asyncio event loop with the specified import path if the asyncio reactor is enabled) eventloopN.install) rrAsyncioSelectorReactorrrReactorAlreadyInstalledErrorset_asyncio_event_looprKsplitjoin) reactor_pathevent_loop_path reactor_class event_loopmodule_installer_path installers rinstall_reactorrYFsu --M==  e8 9 9 9 9/@@J  "Z 8 8 8 8 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9"'',, 9+- 8 899 e8 9 9   IKKK                  s#%A))A-0A- C''C+.C+c tdSr )rNr9r*r_get_asyncio_event_loopr[Ws !$ ' ''r*ct}|.t|}|}tj|n t 5t ddt |}dddn #1swxYwYn8#t$r+| }tj|YnwxYw|S)z;Sets and returns the event loop with specified import path.NignorezThere is no current event loop)messagecategory) rGrr>set_event_looprrDeprecationWarningget_event_loop RuntimeErrornew_event_loop)rRrFevent_loop_classrTs rrNrN[s0 * , ,F/&77%%'' z**** /!! 5 5</ $2244  5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 / / / ..00J  ": . . . . . / s6B,B: BB  B B B2CCcddlm}t|}|j|ks*d|jd|jjd|d}t |dS)z{Raises :exc:`Exception` if the installed :mod:`~twisted.internet.reactor` does not match the specified import path.rr zThe installed reactor (rJz$) does not match the requested one ()N)rr r __class__r6r5 Exception)rQr rSmsgs rverify_installed_reactorrk}s)((((( --M   - 8" 8 8%,%6%? 8 8(4 8 8 8 nn r*cddlm}t|}t|j|rdS|jjjd|jjj}|jd|j}td|d|d)Nrr rJzUScrapy found an asyncio Twisted reactor already installed, and its event loop class (zF) does not match the one specified in the ASYNCIO_EVENT_LOOP setting (rg) rr rrC_asyncioEventlooprhr6r7ri) loop_pathr loop_class installed specifieds r#verify_installed_asyncio_event_looprrs((((((Y''J'+Z88  $ . 9 ? ?  % / < ? ?(DD:+BDDI  !09 ! ! ! ! !  r*cBddlm}t|tjSr,)rr rCrrLr s ris_asyncio_reactor_installedrts'(((((( g~D E EEr*r )r>r@ contextlibrwarningsrrrrrscrapy.utils.miscrrrrGrYr[rNrkrrrtr9r*rrxs  3333333322222222))))))(000000004   "(((D    &FFFFFr*