o Q_Z@sdZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddlmZmZddl mZmZmZmZmZmZmZmZmZe jrkddl mZddlmZGdd d eZeeefZ ed Z!e"Z#d d d Z$e%e$GdddeZ&Gddde&Z'Gddde&Z(dej)d ej)fddZ*dej)d ej)fddZ+e j,dkre-edrej.Z/nej0Z/Gddde/Z1Gdddej2Z3dS)!akBridges between the `asyncio` module and Tornado IOLoop. .. versionadded:: 3.2 This module integrates Tornado with the ``asyncio`` module introduced in Python 3.4. This makes it possible to combine the two libraries on the same event loop. .. deprecated:: 5.0 While the code in this module is still used, it is now enabled automatically when `asyncio` is available, so applications should no longer need to refer to this module directly. .. note:: Tornado is designed to use a selector-based event loop. On Windows, where a proactor-based event loop has been the default since Python 3.8, a selector event loop is emulated by running ``select`` on a separate thread. Configuring ``asyncio`` to use a selector event loop may improve performance of Tornado (but may reduce performance of other ``asyncio``-based libraries in the same process). Nconvert_yielded)IOLoop _Selectable) AnyTypeVar AwaitableCallableUnionOptionalListTupleDict)Set)Protocolc@seZdZdefddZdS) _HasFilenoreturncCdSNselfrr:/usr/lib/python3/dist-packages/tornado/platform/asyncio.pyfileno-sz_HasFileno.filenoN)__name__ __module__ __qualname__intrrrrrr,sr_Trc CsztD]4}|jd|_|jWdn1swYz|jdWn ty0Ynw|jqt dS)NTa) _selector_loops _select_cond_closing_selectornotify_waker_wsendBlockingIOError_threadjoinclear)looprrr_atexit_callback9s    r+c steZdZdejdeddffdd Zd.deddfd d Zd e e e fd e d de ddfddZ d e e e fde ddfddZd e e e fddfddZd e de ddfddZd/ddZd/ddZdede d dededef ddZd eddfd!d"Zde dededdfd#d$Zde dededdfd%d&Zd'eejjd(e d)efdedeefd*d+Zd'ejjddfd,d-Z Z!S)0BaseAsyncIOLoop asyncio_loopkwargsrNc s|_|_ttdrt|tjrt|_i_t_ t_ d_ t t jD] }|r3t j|=q)t j|<d_tjdi|dfdd }|dS) NProactorEventLoopFrrcst_dSr) threading get_ident_thread_identityrrrrassign_thread_identityxz:BaseAsyncIOLoop.initialize..assign_thread_identityrrN)r- selector_loophasattrasyncio isinstancer/AddThreadSelectorEventLoophandlerssetreaderswritersclosinglistr_ioloop_for_asyncio is_closedr2super initialize add_callback)rr-r.r*r3 __class__rrrDNs&    zBaseAsyncIOLoop.initializeFall_fdscCsjd|_t|jD]}|j|\}}|||r||qtj|j=|j|jur.|j |j dSNT) r?r@r;remove_handlerclose_fdrrAr-r6close)rrHfdfileobj handler_funcrrrrL}s     zBaseAsyncIOLoop.closerMhandler.NeventscCs||\}}||jvrtd|||f|j|<|tj@r/|j||j|tj|j ||tj @rG|j ||j|tj |j |dSdS)Nzfd %s added twice) split_fdr; ValueErrorrREADr6 add_reader_handle_eventsr=addWRITE add_writerr>)rrMrPrRrNrrr add_handlers     zBaseAsyncIOLoop.add_handlercCs||\}}|tj@r#||jvr"|j||j|tj|j|n||jvr4|j||j ||tj @rS||j vrQ|j ||j|tj |j |dSdS||j vrf|j ||j |dSdSr)rSrrUr=r6rVrWrX remove_readerremoverYr>rZ remove_writer)rrMrRrNrrrupdate_handlers$          zBaseAsyncIOLoop.update_handlercCsl||\}}||jvrdS||jvr|j||j|||jvr0|j||j||j|=dSr)rSr;r=r6r\r]r>r^)rrMrNrrrrJs        zBaseAsyncIOLoop.remove_handlercCs|j|\}}|||dSr)r;)rrMrRrNrOrrrrWszBaseAsyncIOLoop._handle_eventsc Csdzt}Wn ttfyd}Ynwz|t|j|jWt|dSt|wr)r8get_event_loop RuntimeErrorAssertionError_setup_loggingset_event_loopr- run_forever)rold_looprrrstarts   zBaseAsyncIOLoop.startcCs|jdSr)r-stoprrrrrhr4zBaseAsyncIOLoop.stopwhencallbackargscOs4|jtd|||jtj|g|Ri|S)Nr)r- call_latermaxtime _run_callback functoolspartial)rrirjrkr.rrrcall_ats zBaseAsyncIOLoop.call_attimeoutcCs |dSr)cancel)rrsrrrremove_timeout zBaseAsyncIOLoop.remove_timeoutcOsnt|jkr |jj}n|jj}z||jtj|g|Ri|WdSt y-YdSt y6YdSwr) r0r1r2r- call_sooncall_soon_threadsaferorprqraAttributeError)rrjrkr.rwrrrrEs &  zBaseAsyncIOLoop.add_callbackcOs@z|j|jtj|g|Ri|WdStyYdSwr)r-rxrorprqra)rrjrkr.rrradd_callback_from_signals z(BaseAsyncIOLoop.add_callback_from_signalexecutorfunc.cGs|jj||g|RSr)r-run_in_executor)rr{r|rkrrrr}szBaseAsyncIOLoop.run_in_executorcCs |j|Sr)r-set_default_executor)rr{rrrr~rvz$BaseAsyncIOLoop.set_default_executorFr5)"rrrr8AbstractEventLooprrDboolrLr rrr r[r_rJrWrgrhfloatobjectrrrurErzr concurrentfuturesExecutorrrr}r~ __classcell__rrrFrr,Msn/          r,cs4eZdZdZdeddffdd Zd ddZZS) AsyncIOMainLoopa``AsyncIOMainLoop`` creates an `.IOLoop` that corresponds to the current ``asyncio`` event loop (i.e. the one returned by ``asyncio.get_event_loop()``). .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. .. versionchanged:: 5.0 Closing an `AsyncIOMainLoop` now closes the underlying asyncio loop. r.rNc stjtfi|dSr)rCrDr8r`)rr.rFrrrDszAsyncIOMainLoop.initializecCrrrrrrr make_currentszAsyncIOMainLoop.make_currentr5)rrr__doc__rrDrrrrrFrrsrcsVeZdZdZdeddffdd Zddeddffd d Zdd d Zdd dZ Z S) AsyncIOLoopa``AsyncIOLoop`` is an `.IOLoop` that runs on an ``asyncio`` event loop. This class follows the usual Tornado semantics for creating new ``IOLoops``; these loops are not necessarily related to the ``asyncio`` default event loop. Each ``AsyncIOLoop`` creates a new ``asyncio.EventLoop``; this object can be accessed with the ``asyncio_loop`` attribute. .. versionchanged:: 5.0 When an ``AsyncIOLoop`` becomes the current `.IOLoop`, it also sets the current `asyncio` event loop. .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. r.rNc sBd|_t}z tj|fi|WdSty |wNF) is_currentr8new_event_looprCrD ExceptionrL)rr.r*rFrrrD3s zAsyncIOLoop.initializeFrHcs |jr|tj|ddS)N)rH)r clear_currentrCrL)rrHrFrrrL>szAsyncIOLoop.closec CsH|jszt|_Wnttfyd|_Ynwd|_t|jdSrI)rr8r` old_asynciorarbrdr-rrrrrCs zAsyncIOLoop.make_currentcCs |jrt|jd|_dSdSr)rr8rdrrrrr_clear_current_hookLs  zAsyncIOLoop._clear_current_hookrr5) rrrrrrDrrLrrrrrrFrrs   rasyncio_futurecCs|S)zConvert an `asyncio.Future` to a `tornado.concurrent.Future`. .. versionadded:: 4.1 .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now a no-op. r)rrrrto_tornado_futureRs rtornado_futurecCst|S)asConvert a Tornado yieldable object to an `asyncio.Future`. .. versionadded:: 4.1 .. versionchanged:: 4.3 Now accepts any yieldable object, not just `tornado.concurrent.Future`. .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now equivalent to `tornado.gen.convert_yielded`. r)rrrrto_asyncio_future^s rwin32WindowsSelectorEventLoopPolicycs(eZdZdZdejffdd ZZS)AnyThreadEventLoopPolicyaDEvent loop policy that allows loop creation on any thread. The default `asyncio` event loop policy only automatically creates event loops in the main threads. Other threads must create event loops explicitly or `asyncio.get_event_loop` (and therefore `.IOLoop.current`) will fail. Installing this policy allows event loops to be created automatically on any thread, matching the behavior of Tornado versions prior to 5.0 (or 5.0 on Python 2). Usage:: asyncio.set_event_loop_policy(AnyThreadEventLoopPolicy()) .. versionadded:: 5.0 rc s:ztWSttfy|}|||YSwr)rCr`rarbrrd)rr*rFrrr`s  z'AnyThreadEventLoopPolicy.get_event_loop)rrrrr8rr`rrrrFrrvsrcseZdZdZhdZdedeffdd Zdej ddfd d Z d+d d Z d+d dZ d+ddZ d+ddZd+ddZd+ddZdeddedddfddZdddedefddfddZddd ed!d"eddfd#d$Zddd ed!d"eddfd%d&Zd,d'd(Zd,d)d*ZZS)-r:aWrap an event loop to add implementations of the ``add_reader`` method family. Instances of this class start a second thread to run a selector. This thread is completely hidden from the user; all callbacks are run on the wrapped event loop's thread. This class is used automatically by Tornado; applications should not need to refer to it directly. It is safe to wrap any event loop with this class, although it only makes sense for event loops that do not implement the ``add_reader`` family of methods themselves (i.e. ``WindowsProactorEventLoop``) Closing the ``AddThreadSelectorEventLoop`` also closes the wrapped event loop. >rLr'_readers_waker_rr$_writers _real_looprVrZ _run_select _select_argsr! _handle_event _start_selectr\r^_consume_waker_handle_select_wake_selectorr"namercs"|tjvr t|St|j|Sr)r: MY_ATTRIBUTESrC__getattribute__getattrr)rrrFrrrs   z+AddThreadSelectorEventLoop.__getattribute__ real_loopNcCs||_t|_d|_d|_tjdd|jd|_|j |j |j i|_ i|_ t\|_|_|jd|jdt|||j|jdS)NFzTornado selectorT)rdaemontarget)rr0 Conditionr!rr"Threadrr'rgrwrrrsocket socketpairrr$ setblockingr rXrVr)rrrrr__init__s"     z#AddThreadSelectorEventLoop.__init__cCs"t||j|jdSr)r discardrrLr$rrrr__del__s  z"AddThreadSelectorEventLoop.__del__cCst|jd|_|jWdn1swY||jt||j |j |j dSrI) r!r"r#rr'r(r rrrLr$rrrrrrLs     z AddThreadSelectorEventLoop.closecC(z |jdWdStyYdSw)Nr)r$r%r&rrrrr  z)AddThreadSelectorEventLoop._wake_selectorcCr)Ni)rrecvr&rrrrrrz)AddThreadSelectorEventLoop._consume_wakercCsb|j$|jdus Jt|jt|jf|_|jWddS1s*wYdSr)r!rr@rkeysrr#rrrrrs  "z(AddThreadSelectorEventLoop._start_selectc Cs" |j8|jdur|js|j|jdur|jr |jr& WddS|jdus-J|j\}}d|_Wdn1s?wYzt|||\}}}||}Wn2ty}z&|jttdtjkr{t|j gggd\}}}|rzg}nWYd}~nd}~ww|j |j ||q)NT WSAENOTSOCKr)r!rr"waitselectOSErrorerrnorEBADFrrrrxr)rto_readto_writerswsxse_rrrr s6     z&AddThreadSelectorEventLoop._run_selectr_FileDescriptorLikercCs<|D] }|||jq|D] }|||jq|dSr)rrrr)rrrrwrrrr?s  z)AddThreadSelectorEventLoop._handle_selectrMcb_mapcCs,z||}Wn tyYdSw|dSr)KeyError)rrMrrjrrrrHs    z(AddThreadSelectorEventLoop._handle_eventrjrQrkcG$tj|g|R|j|<|dSr)rprqrrrrMrjrkrrrrVQ z%AddThreadSelectorEventLoop.add_readercGrr)rprqrrrrrrrZWrz%AddThreadSelectorEventLoop.add_writercC|j|=|dSr)rrrrMrrrr\] z(AddThreadSelectorEventLoop.remove_readercCrr)rrrrrrr^arz(AddThreadSelectorEventLoop.remove_writerr5)rMrrN)rrrrrstrrrr8rrrrLrrrrr rrr rrVrZr\r^rrrrFrr:sZ    2       r:r5)4rr8atexitconcurrent.futuresrrrprrsysr0typing tornado.genrtornado.iolooprrrrrr r r r r r TYPE_CHECKINGrtyping_extensionsrrrrrr<r r+registerr,rrFuturerrplatformr7r _BasePolicyDefaultEventLoopPolicyrrr:rrrrsD ,     ;3