o
0g, @ 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__)names_to_ignoredunder_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__ Z/var/www/html/backend_erp/backend_erp_env/lib/python3.10/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 eventsfdcur_event_for_fdr" r" r#
__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/ r0 r1 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 r3 r5 r7 r" r" r# r8 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) pass_events)r r start_GeventSelector__callbackr updateclearr is_setr waitr _key_from_fdr9 r: appendr' r; )r timeoutr( r7 resulteventr5 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
r: r; r r r )r dr7 r" r" r# r; s
zGeventSelector.closer )
__name__
__module__ __qualname____doc__r r> r r r, r8 rH r;
__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 selectorsrH _selectrH c s |i |S r r" )r argskwargsrR r" r# rQ s z(_gevent_do_monkey_patch.._selectT
EpollSelectorKqueueSelectorDevpollSelector PollSelector
_selector_cls)poll) patch_kwargs
target_moduledefault_patch_itemssysmodulesrJ get_originalrH
__selectors__SelectSelectorhasattrrQ
gevent.select_gevent_monkey remove_itemr rX rZ rY )
patch_requestrO
target_modr^ orig_select_selectrP rb rQ rZ r" rR r# _gevent_do_monkey_patch s:
rj ),rM
__future__r r r collectionsr rP ra ImportErrorr
__target__
gevent.hubr r+ geventr gevent._compatr r
gevent._utilr r gevent.eventr
rd r r __implements__ __extra__r globals __imports__r. r$ r% r- SelectorKeygetattr BaseSelectorr r r rj r" r" r" r# sX 2