o
e, @ sB d Z ddlmZ ddlmZ ddlmZ ddlmZ zddlZW n e y/ ddl
ZdZ Y nw ddl m
Z dd lmZ dd
lmZ dd lmZ dd lmZ dd
lmZ ddlmZ ddlmZ ddlmZ dgZ dgZ e e Z eee e ddZ eeB Z!ej"Z"ej#Z#e"e#B Z$ej%Z%e&edej'Z(G dd de(Z)e)Z*dd Z+dS )an
This module provides :class:`GeventSelector`, a high-level IO
multiplexing mechanism. This is aliased to :class:`DefaultSelector`.
This module provides the same API as the selectors defined in :mod:`selectors`.
On Python 2, this module is only available if the `selectors2
`_ backport is installed.
.. versionadded:: 20.6.0
)absolute_import)division)print_function) defaultdictN
selectors2)_get_hub_noargs)sleep) iteritems)
itervalues) copy_globals)Lazy)Event)_EV_READ) _EV_WRITEDefaultSelectorGeventSelector)__all__)Znames_to_ignoreZdunder_names_to_keep_BaseSelectorImplc sZ e Zd ZdZd fdd Zdd Zedd Zdd d
Zd d Z dd
dZ
dd Z Z S )r a
A selector implementation using gevent primitives.
This is a type of :class:`selectors.BaseSelector`, so the documentation
for that class applies here.
.. caution::
As the base class indicates, it is critically important to
unregister file objects before closing them. (Or close the selector
they are registered with before closing them.) Failure to do so
may crash the process or have other unintended results.
Nc s> |d ur|| _ i | _i | _tt| _t | _tt |
d S N) hub_active_watchers_inactive_watchersr int_accumulated_eventsr
_readysuperr __init__)selfr __class__ @D:\Projects\ConvertPro\env\Lib\site-packages\gevent/selectors.pyr n s
zGeventSelector.__init__c C sJ |dkr | j | }|t@ r|tO }|t@ r|tO }|| j |< | j d S )Nr )r r
EVENT_READr EVENT_WRITEr set)r eventsfdZcur_event_for_fdr r r! Z
__callbacky s
zGeventSelector.__callbackc C s t S r )get_hub)r r r r! r s zGeventSelector.hubc
C sf t | |||}|tkrt}n |tkrt}nt}| jj}|j }|j
}||j | | j |j < } || _
|S r )r register _ALL_EVENTS _POLL_ALLr" r r r loopioMAXPRIr& r priority)
r fileobjr% datakeyflagsr+ r, r- watcherr r r! r( s zGeventSelector.registerc C sZ t | |}|j| jv r| j|j}n| j|j}| | | j|jd |S r ) r
unregisterr& r popr stopcloser )r r/ r1 r3 r r r! r4 s zGeventSelector.unregisterc C s |dur
|dk r
d}t | jD ]
\}}|j| j|dd q| j| j | j | j r1t | j
| | j g }t | j D ])\}}| |}| j
|}| |rh||||j@ f || j|< qC| qC| j |S )z
Poll for I/O.
Note that, like the built-in selectors, this will block
indefinitely if no timeout is given and no files have been
registered.
Nr T)Z pass_events)r r start_GeventSelector__callbackr updateclearr is_setr waitr _key_from_fdr5 r6 appendr% r7 )r timeoutr& r3 resulteventr1 r r r! select s*
zGeventSelector.selectc C s` | j | jfD ]}|d u r
qt|D ]
}| | qqd | _ | _d | _d | _t| d S r )r r r
r6 r7 r r r )r dr3 r r r! r7 s
zGeventSelector.closer )
__name__
__module__ __qualname____doc__r r9 r r r( r4 rC r7
__classcell__r r r r! r E s (
>c s | j d }| j}| dd l}d|jvr |jt |jd< | dd}|j|us*J t}|j }t
|drO|j |j|fv rOddl m fdd}||j _ d |_
|r\| |d
d d t|_t
|d
rst
|jdruddl m} ||j_d S d S d S )N
aggressiver selectorsrC _selectrC c s |i |S r r )r argskwargsrM r r! rL s z(_gevent_do_monkey_patch.._selectTZ
EpollSelectorZKqueueSelectorZDevpollSelector PollSelector
_selector_cls)poll)Z patch_kwargsZ
target_moduleZdefault_patch_itemssysmodulesrE Z get_originalrC
__selectors__SelectSelectorhasattrrL
gevent.selectZ_gevent_monkeyZ remove_itemr rP rR rQ ) Z
patch_requestrJ Z
target_modrS Zorig_select_selectrK rV rL rR r rM r! _gevent_do_monkey_patch s:
rY ),rH
__future__r r r collectionsr rK rU ImportErrorr Z
__target__Z
gevent.hubr r' Zgeventr Zgevent._compatr r
Z gevent._utilr r Z gevent.eventr
rX r r Z__implements__Z __extra__r globalsZ __imports__r* r" r# r) SelectorKeygetattr BaseSelectorr r r rY r r r r! sX 2