ZdUdZddlZddlZddlZddlZddlmZmZddlmZddl Z ddl m Z eZ ee d<GddeZd ejfd Zd ejfd Zejd kreZneZGd dZGddee jZGddee jZee_Gdde jeZGddeZdZdZde_dZ gdZ!dS)z8AsyncIO support for zmq Requires asyncio and Python 3. N)FutureSelectorEventLoop)WeakKeyDictionary)_future _selectorsceZdZdZdS)ProactorSelectorThreadWarningzWarning class for notifying about the extra thread spawned by tornado We automatically support proactor via tornado's AddThreadSelectorEventLoopN)__name__ __module__ __qualname____doc__+lib/python3.11/site-packages/zmq/asyncio.pyr r s"RRRRrr returncptvr tSttdrttjrm ddlm}n#t$rtdwxYwtj dtd|xt<j fd}|_ SS) zGet selector-compatible loop Returns an object with ``add_reader`` family of methods, either the loop itself or a SelectorThread instance. Workaround Windows proactor removal of *reader methods, which we need for zmq sockets. ProactorEventLoopr)AddThreadSelectorEventLoopaProactor event loop does not implement add_reader family of methods required for zmq. zmq will work with proactor if tornado >= 6.1 can be found. Use `asyncio.set_event_loop_policy(WindowsSelectorEventLoopPolicy())` or install 'tornado>=6.1' to avoid this error.aProactor event loop does not implement add_reader family of methods required for zmq. Registering an additional selector thread for add_reader support via tornado. Use `asyncio.set_event_loop_policy(WindowsSelectorEventLoopPolicy())` to avoid this warning. stacklevelct_tddSN)closerpop) asyncio_loop loop_close selector_loopsr_close_selector_and_loopz7_get_selector_windows.._close_selector_and_loopIs9",L  NN< . . .    ! ! ! ! !r) rhasattrasyncio isinstancertornado.platform.asyncior ImportError RuntimeErrorwarningswarnRuntimeWarningr)rrrrrs` @@r_get_selector_windowsr)s z!!,''w+,,&g/22&  K K K K K K K   B     &     4N3Ml3[3[[ <0"'  " " " " " " "6 s AA+c|S)zno-op on non-Windowsr)loops r_get_selector_noopr,Vs Krwin32c4eZdZeZejZejZ dZ dS)_AsyncIOctjdkr@ tjS#t$rt jdtdYnwxYwtjS)N)uONo running event loop. zmq.asyncio should be used from within an asyncio loop.r) sys version_infor!get_running_loopr%r&r'r(get_event_loopselfs r _default_loopz_AsyncIO._default_loopfs|  v % % /111    e"  %'''s%&A AN) r r r r_Future selectors EVENT_WRITE_WRITE EVENT_READ_READr:rrrr/r/as8G  "F  E ( ( ( ( (rr/ceZdZdZdZdZdS)Pollerz1Poller returning asyncio.Future for poll results.ct|}||jzr||fd||jzr||fddSdS)z"Schedule callback for a raw socketcSrrargsfs rz*Poller._watch_raw_socket..{ aaccrcSrrrEs rrHz*Poller._watch_raw_socket..}rIrN) _get_selectorr@ add_readerr> add_writer)r9r+socketevtrGselectors ` r_watch_raw_socketzPoller._watch_raw_socketws~ &&   ;   (9(9(9(9 : : :   ;   (9(9(9(9 : : : : : ; ;rct|}|D],}||||-dS)z$Unschedule callback for a raw socketN)rK remove_reader remove_writer)r9r+socketsrPrNs r_unwatch_raw_socketszPoller._unwatch_raw_socketssS && + +F  " "6 * * *  " "6 * * * * + +rN)r r r r rQrVrrrrBrBts8;;;;;+++++rrBc,eZdZdZeZddZddZdZdS)Socketz.sd11!Q77rN)rKrL_fdr[s` r_init_io_statezSocket._init_io_statesD 7##.. H7777     rc|j}|rN|s<|jdkr3|||jdSdSdSdS)zEclear any ioloop event handler called once at close N) _current_loop is_closedr`rKrS)r9r+s r_clear_io_statezSocket._clear_io_statesq !  =(( =TX^^   t $ $ 2 248 < < < < < = = = =^^rr) r r r r rB _poller_classrKrarfrrrrXrXsVFFM&&&&     =====rrXceZdZdZeZdZdS)Contextz/Context for creating asyncio-compatible SocketsN)r r r r rX _socket_class _instancerrrriris 99MIIIrric$eZdZdZdfd ZxZS) ZMQEventLoopz}DEPRECATED: AsyncIO eventloop using zmq_poll. pyzmq sockets should work with any asyncio event loop as of pyzmq 17. Ncbtt|Sr) _deprecatedsuper__init__)r9rP __class__s rrqzZMQEventLoop.__init__s$ ww)))rr)r r r r rq __classcell__)rrs@rrmrmsG **********rrmcrtjrdSdt_tjdtddS)NTzsZMQEventLoop and zmq.asyncio.install are deprecated in pyzmq 17. Special eventloop integration is no longer needed.r1r)rocalledr&r'DeprecationWarningrrrrorosFK M}rFc"tdS)z(DEPRECATED: No longer needed in pyzmq 17N)rorrrinstallrxsMMMMMr)rirXrBrmrx)"r r!r<r4r&rrweakrefrzmq_zmqrr__annotations__r(r AbstractEventLoopr)r,platformrKr/ _AsyncPollerrB _AsyncSocketrXrjrirm_looprorurx__all__rrrrs\ --------%%%%%%!2 1 3 3 333RRRRRNRRR 6 6666r 9 <7)MM&M((((((((&+++++Xw++++&=====Xw+===4dl6"*****$***         r