Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/kombu/utils/__pycache__/ |
a
��Sh�' � @ s^ d Z ddlmZ ddlZddlZddlZddlZddlm Z ddl
m Z ddl m
Z
dZejZejZeed d�Zeed
d�Zeed d�Zeed d�Zeed
d�Zeedd�Zeedd�Zeedd�Zeedd�Zeedd�Z eedd�Z eedd�Z eed d �Z eed d �Z eed d!�Z!eed"d#�Z"eed$d%�Z#eed&d�Z$eed'd�Z%eed(d�Z&eed)d�Z'eed*d+�Z(eed,d-�Z)eed.d�Z*eed/d0�Z+eed1d�Z,eed2d�Z-eed3d+�Z.eed4d-�Z/eed5d�Z0d Z1Z2d Z3Z4d6 Z5Z6zej7ej8hZ9W n e:�y ej7hZ9Y n0 G d7d8� d8�Z;G d9d:� d:�Z<G d;d<� d<�Z=G d=d>� d>�Z>d?d@� Z?dAd � Z@dS )BzSelector Utilities.� )� annotationsN)�Integral� )�fileno)�detect_environment)�pollr �epoll�kqueue�kevent� KQ_EV_ADD� KQ_EV_DELETE� � KQ_EV_ENABLE� � KQ_EV_CLEAR� � KQ_EV_ERRORi @ � KQ_EV_EOFi � �KQ_FILTER_READ����KQ_FILTER_WRITE����
KQ_FILTER_AIO����KQ_FILTER_VNODE����KQ_FILTER_PROC����KQ_FILTER_SIGNALi�����KQ_FILTER_TIMERi�����
KQ_NOTE_LOWAT�KQ_NOTE_DELETE�
KQ_NOTE_WRITE�KQ_NOTE_EXTEND�KQ_NOTE_ATTRIB� � KQ_NOTE_LINK� �KQ_NOTE_RENAME�KQ_NOTE_REVOKE�@ �POLLIN�POLLOUT�POLLERR�POLLHUP�POLLNVAL� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �_epollc C s t � | _d S �N)r r1 ��self� r5 �=/usr/local/lib/python3.9/site-packages/kombu/utils/eventio.py�__init__= s z_epoll.__init__c
C sP z| j �||� W n8 tyJ } z t|dd �tjkr6� W Y d }~n
d }~0 0 |S �N�errno)r1 �register� Exception�getattrr9 �EEXIST)r4 �fd�events�excr5 r5 r6 r: @ s z_epoll.registerc C sl z| j �|� W nV ttttfy* Y n> tyf } z&t|dd �tjtj fvrR� W Y d }~n
d }~0 0 d S r8 )
r1 �
unregister�OSError�
ValueError�KeyError� TypeErrorr< r9 �ENOENT�EPERM�r4 r> r@ r5 r5 r6 rA H s z_epoll.unregisterc
C sX z| j �|d ur|nd�W S tyR } z t|dd �tjkr>� W Y d }~n
d }~0 0 d S )Nr r9 )r1 r r; r< r9 �EINTR)r4 �timeoutr@ r5 r5 r6 r Q s
z _epoll.pollc C s | j �� d S r2 )r1 �closer3 r5 r5 r6 rK X s z _epoll.closeN)�__name__�
__module__� __qualname__r7 r: rA r rK r5 r5 r5 r6 r1 ; s
r1 c @ s\ e Zd ZeeB eB eB Zdd� Zdd� Z dd� Z
dd� Z d d
� Z d d � Z
d
d� Zdd� ZdS )�_kqueuec C s" t � | _i | _d | _| jj| _d S r2 )r rO �_active�on_file_change�control� _kcontrolr3 r5 r5 r6 r7 ` s z_kqueue.__init__c C s | � ||t� || j|< |S r2 )�_controlr rP �r4 r> r? r5 r5 r6 r: f s
z_kqueue.registerc C s< | j �|d �}|r8z| �||t� W n ty6 Y n0 d S r2 )rP �poprT r rB rU r5 r5 r6 rA k s z_kqueue.unregisterc C s, t |tttB tB | jd�}| �|gd� d S �N)�filter�flags�fflagsr )r
r r r r �w_fflagsrS �r4 r> Zevr5 r5 r6 �
watch_files s
�z_kqueue.watch_filec C s$ t |tt| jd�}| �|gd� d S rW )r
r r r[ rS r\ r5 r5 r6 � unwatch_filez s �z_kqueue.unwatch_filec C s� |sd S g }|t @ r(|�t|t|d�� |r4|t@ rH|�t|t|d�� | j}|D ](}z||gd� W qR tyx Y qR0 qRd S )N)rX rY r )�WRITE�appendr
r �READr rS rC )r4 r> r? rY �keventsrR �er5 r5 r6 rT � s$ � � z_kqueue._controlc
C s. z| � d d|�}W nF tyX } z.t|dd �tjkrBW Y d }~d S � W Y d }~n
d }~0 0 i g }}|D ]�}|j}|jtkr�|�|d�t B ||< qh|jt
kr�|j t @ r�t
||< n|�|d�tB ||< qh|jtkr�|�|d�t
B ||< qh|jtkrh|jt@ �r| �|� |�|� qh|�r"| �|� t|�� �S )Ni� r9 r )rS r; r< r9 rI �identrX r �getra r rY r �ERRr_ r r rZ r! rA r` rQ �list�items)r4 rJ rb r@ r? Z file_changes�kr> r5 r5 r6 r � s0
z _kqueue.pollc C s | j �� d S r2 )rO rK r3 r5 r5 r6 rK � s z
_kqueue.closeN)rL rM rN r" r# r$ r! r[ r7 r: rA r] r^ rT r rK r5 r5 r5 r6 rO \ s ��rO c @ sH e Zd Zdd� Zdd� Zdd� Zejee e
e e e
efdd�Zd d
� Zd S ) �_pollc C s* t � | _| jj| _| jj| _| jj| _d S r2 )�xpoll�_pollerr � _quick_pollr: �_quick_registerrA �_quick_unregisterr3 r5 r5 r6 r7 � s
z_poll.__init__c C sL t |�}d}|t@ r |tO }|t@ r,|tO }|t@ r<|tO }| �||� |S )Nr )r rf r- r_ r, ra r+ rn )r4 r> r? Z
poll_flagsr5 r5 r6 r: � s z_poll.registerc
C sb z t |�}W nF tyR } z.t|dd �tv r<|W Y d }~S � W Y d }~n
d }~0 0 | �|� |S r8 )r rB r< �
SELECT_BAD_FDro rH r5 r5 r6 rA � s
z_poll.unregisterc
C s� |r|dk rdn||pdd �}z| � |�}
W nJ ttfyx } z.t| dd �tjkrbW Y d } ~ d S � W Y d } ~ n
d } ~ 0 0 g } |
D ]t\}
}d}||@ r�||O }||@ r�||O }||@ s�|t@ s�|t@ r�||O }|s�J �t|
| �s�|
� � }
| �
|
|f� q�| S )Nr g @�@r9 ) rm �
_selecterrrB r< r9 rI r/ r. �
isinstancer r` )r4 rJ �roundr+ r, r- ra r_ rf r �
event_listr@ �readyr> �eventr? r5 r5 r6 r � s*
z
_poll.pollc C s
d | _ d S r2 )rl r3 r5 r5 r6 rK � s z _poll.closeN)rL rM rN r7 r: rA �math�ceilr+ r, r- ra r_ rf r r rK r5 r5 r5 r6 rj � s �
rj c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�_selectc C s& t � t � t � f | _\| _| _| _d S r2 )�setZ_all�_rfd�_wfd�_efdr3 r5 r5 r6 r7 � s
� �z_select.__init__c C sH t |�}|t@ r | j�|� |t@ r0| j�|� |t@ rD| j�|� |S r2 )r rf r} �addr_ r| ra r{ rU r5 r5 r6 r: � s z_select.registerc C st | j | jB | jB D ]\}zt|gg g d� W q ttfyl } z&t|dd �tv rX| �|� W Y d }~qd }~0 0 qd S )Nr r9 ) r{ r| r} �_selectfrq rB r< rp rA rH r5 r5 r6 � _remove_bad s z_select._remove_badc
C sz z t |�}W nD tyP } z,t|dd �tv r:W Y d }~d S � W Y d }~n
d }~0 0 | j�|� | j�|� | j�|� d S r8 )r rB r< rp r{ �discardr| r} rH r5 r5 r6 rA
s z_select.unregisterc
C s0 z t | j| j| j|�\}}}W nn ttfy� } zRt|dd �tjkrRW Y d }~d S t|dd �t v rv| �
� W Y d }~S � W Y d }~n
d }~0 0 i }|D ]*}t |t �s�|�
� }|�|d�tB ||< q�|D ]*}t |t �s�|�
� }|�|d�tB ||< q�|D ],}t |t ��s|�
� }|�|d�tB ||< q�t|�� �S )Nr9 r )r r{ r| r} rq rB r< r9 rI rp r� rr r r re ra r_ rf rg rh )r4 rJ �read�write�errorr@ r? r> r5 r5 r6 r s0 �
z _select.pollc C s" | j �� | j�� | j�� d S r2 )r{ �clearr| r} r3 r5 r5 r6 rK 2 s
z
_select.closeN) rL rM rN r7 r: r� rA r rK r5 r5 r5 r6 ry � s
ry c C s8 t � dkrtS trtS tr(dtjv r(tS tr0t S tS d S )N�defaultZnetbsd)
r ry r r1 r �sys�platformrO rk rj r5 r5 r5 r6 � _get_poller8 s
r� c O s t � | i |��S )zCreate new poller instance.)r� )�args�kwargsr5 r5 r6 r G s )A�__doc__�
__future__r r9 rw �selectZ
__select__r� Znumbersr � r �compatr �__all__r r� rq r< rk r r r
r r r r r r r r r r r r r r r! r" r# r$ r& r( r) r+ r, r- r. r/ ra Z POLL_READr_ Z
POLL_WRITErf ZPOLL_ERR�EBADFZ WSAENOTSOCKrp �AttributeErrorr1 rO rj ry r� r r5 r5 r5 r6 �<module> sl !W>G