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/asynchronous/__pycache__/ |
a
��Sh�. � @ s& U d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlm Z ddl
m Z ddl m
Z dd lmZmZ dd
lmZ dd lmZ dd lmZmZmZmZ dd
lm Z ddl m Z dZ ee �Z!da"de#d< dZ$G dd� de%�Z&dd� Z'edd� �Z(dd�dd �Z)ddd �d d �Z*G d d!� d!�Z+dS )"zEvent loop implementation.� )� annotationsN)�contextmanager)�copy)�Empty)�sleep)�
GeneratorType)�Thenable�promise)�
get_logger)�fileno)�ERR�READ�WRITE�poll)�cached_property� )�Timer)�Hub�get_event_loop�set_event_loopz
Hub | None�
_current_loopz<Received unknown event %r for fd %r, please contact support!c @ s e Zd ZdZdS )�StopzStops the event loop.N)�__name__�
__module__� __qualname__�__doc__� r r �@/usr/local/lib/python3.9/site-packages/kombu/asynchronous/hub.pyr s r c C s
t � �d S �N)r r r r r �_raise_stop_error$ s r c o s
d V d S r r )�args�kwargsr r r �_dummy_context( s r" )�returnc C s t S )z Get current event loop object.�r r r r r r - s r )�loopr# c C s | a | S )z"Set the current event loop object.r$ )r% r r r r 2 s r c
@ sN e Zd ZdZeZeZeZdZdFdd�Ze dd� �Z
e
j dd� �Z
dd � Z d
d � Z
d d
� Zdd� Zdd� ZdGdd�Zdd� ZdHdd�Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Z d.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z!d8d9� Z"d:d;� Z#e$e%e&e'e(e)e*eeef
d<d=�Z+d>d?� Z,d@dA� Z-e.dBdC� �Z/e dDdE� �Z0dS )Ir z~Event loop object.
Arguments:
---------
timer (kombu.asynchronous.Timer): Specify custom timer instance.
Nc C sn |d ur |nt � | _i | _i | _t� | _t� | _t� | _t� � | _
d| _ d | _ t� | _
d | _d| _| �� d S )NFr )r �timer�readers�writers�set�on_tick�on_close�_ready� threading�Lock� _ready_lock�_running�_loop� consolidate�consolidate_callback�propagate_errors�_create_poller)�selfr& r r r �__init__N s
z Hub.__init__c C s | j s| �� | j S r )�_pollerr5 �r6 r r r �polleri s z
Hub.pollerc C s
|| _ d S r )r8 )r6 �valuer r r r: o s c C s | � � | �� d S r )�closer5 r9 r r r �resets s z Hub.resetc C s t � | _| jj| _| jj| _d S r )r r8 �register� _register_fd�
unregister�_unregister_fdr9 r r r r5 w s
zHub._create_pollerc C s* | j d ur&| j �� d | _ d | _d | _d S r )r8 r< r? rA r9 r r r �
_close_poller| s
zHub._close_pollerc C s | � t� d S r )� call_soonr r9 r r r �stop� s zHub.stopc C s d� t| �t| j�t| j��S )Nz<Hub@{:#x}: R:{} W:{}>)�format�id�lenr' r( r9 r r r �__repr__� s �z Hub.__repr__r �
r c
C s� | j }d }|r�|jr�t|�D ]�}t| j�\}}|d u r: q�z
|� W q |yX � Y q ttfyn � Y q ty� } z*| jtj kr�� t
j d| dd� W Y d } ~ q d } ~ 0 t y� } z t
j d| dd� W Y d } ~ q d } ~ 0 0 q t
|p�||�S )NzError in timer: %rr ��exc_info)r& �_queue�range�next� scheduler� MemoryError�AssertionError�OSError�errno�ENOMEM�logger�error� Exception�min)
r6 Z min_delay� max_delayZ
max_timers� propagater& �delay�i�entry�excr r r � fire_timers� s(
$(zHub.fire_timersc C s* z| � |� W | �|� n | �|� 0 d S r )� _unregister�_discard�r6 �fdr r r �_remove_from_loop� s zHub._remove_from_loopFc C sx t |�}z| j�||� W n ty8 | �|� � Y n<0 |t@ rH| jn| j}|rh| j� |� d ||< n ||f||< d S r )
r r: r> �
ValueErrorrd r
r' r( r2 �add)r6 rc �callback�flagsr r2 �destr r r rf � s
zHub.addc C s t |�}| �|� d S r )r rd rb r r r �remove� s z
Hub.removec C sD d| _ z0z | �� W q ty* Y q.Y q0 qW d| _ nd| _ 0 d S )NTF)r0 �run_oncer r9 r r r � run_forever� s zHub.run_foreverc C s, zt | j� W n ty& d | _Y n0 d S r )rN r% �
StopIterationr1 r9 r r r rk � s z Hub.run_oncec G sJ t |t�st||�}| j� | j�|� W d � n1 s<0 Y |S r )�
isinstancer r r/ r, rf )r6 rg r r r r rC � s
*z
Hub.call_soonc G s | j �|||�S r )r& Z
call_after�r6 r[ rg r r r r �
call_later� s zHub.call_laterc G s | j �|||�S r )r& �call_at)r6 �whenrg r r r r rq � s z Hub.call_atc G s | j �|||�S r )r& �call_repeatedlyro r r r rs � s zHub.call_repeatedlyc G s | � ||ttB |�S r )rf r
r �r6 �fdsrg r r r r �
add_reader� s zHub.add_readerc G s | � ||t|�S r )rf r rt r r r �
add_writer� s zHub.add_writerc C sd || j v }| j �|�}z*| �|� W |r`|\}}| �||t|� n |r^|\}}| �||t|� 0 d S r )r( �getrd rf r )r6 rc �writableZon_write�cbr r r r �
remove_reader� s
�zHub.remove_readerc C sl || j v }| j �|�}z.| �|� W |rh|\}}| �||ttB |� n"|rf|\}}| �||ttB |� 0 d S r )r' rx rd rf r
r )r6 rc �readableZon_readrz r r r r �
remove_writer� s
�zHub.remove_writerc
C s. z| j �|� W n tttfy( Y n0 d S r )r: r@ �AttributeError�KeyErrorrR rb r r r r` � s zHub._unregisterc C s< | j �" | j}t� | _|W d � S 1 s.0 Y d S r )r/ r, r) )r6 �readyr r r �
_pop_ready� s zHub._pop_readyc s~ � fdd�� j D � � j �� � fdd�� jD � � j�� � j�� � �� � jD ] }|� � qT� �� }|D ]
}|� qnd S )Nc s g | ]}� � |��qS r �r` ��.0rc r9 r r �
<listcomp> � z Hub.close.<locals>.<listcomp>c s g | ]}� � |��qS r r� r� r9 r r r� r� )r' �clearr( r2 rB r+ r� )r6 r rg Ztodos�itemr r9 r r< s
z Hub.closec C s4 t |�}| j�|d � | j�|d � | j�|� d S r )r r' �popr( r2 �discardrb r r r ra s z Hub._discardc C s t jd||dd� d S )Nz Callback %r raised exception: %rr rJ )rU rV )r6 rg r^ r r r �on_callback_error s �zHub.on_callback_errorc c s� | j | j } } | jj}
| j}| j}| jj}| j}| j }| j
}| � � }|D ]}|rH|� qH|rf||d�nd}t | j
�D ]
}|� qt| s�| �r�g }z |
|�}W n ty� Y d S 0 |p�dD �]�\}}d} ||v r�| �|�d u r�|�|� q�d } } ||@ �r0z| | \} } W n" |�y, | �|� Y q�Y n0 nb|| @ �rpz| | \} } W n" |�yl | �|� Y q�Y n0 n"||
@ �r�d} nt�t||� d} | �r�z | �|��p�| �|�\} } W n t�y� Y n0 | d u �r�| �|� q�t| |��rjz || � W nl t�y8 } z$| jtjk�r � ||� W Y d } ~ n8d } ~ 0 |�yJ Y n t�yf ||� � Y n0 q�z | | � W q� |�y� Y q�0 q�|�r�||� n|||d�� d V q<d S )N)rZ r r FTg�������?) r' r( r: r r_ rj r& rL r2 r3 r4 r� r r* re rx �appendr{ r} rU �info�W_UNKNOWN_EVENT� TypeErrorrn rR rS �EBADFrW ) r6 � generatorr rX rN r rm r r
r r r' r( r r_ Z
hub_removeZ scheduledr2 r3 rZ �todor� Z poll_timeoutZ
tick_callbackZto_consolidate�eventsrc �eventZ
general_errorrz Zcbargsr^ r r r � create_loop s�
�
�
zHub.create_loopc C s ddl m} || �S )Nr )� repr_active)�debugr� )r6 r� r r r r� s zHub.repr_activec C s ddl m} || |pg �S )Nr )� repr_events)r� r� )r6 r� r� r r r r� � s zHub.repr_eventsc C s
t | j�S r )�iterr& r9 r r r rO � s z
Hub.schedulerc C s | j d u r| �� | _ | j S r )r1 r� r9 r r r r% � s
zHub.loop)N)r rI rI r )r F)1r r r r r
r r r+ r7 �propertyr: �setterr= r5 rB rD rH r_ rd rf rj rl rk rC rp rq rs rv rw r{ r} r` r� r< ra r� r� r rX rN r rm r r� r� r� r rO r% r r r r r 9 s\
�
�
_
r ),r �
__future__r rS r- �
contextlibr r �queuer �timer �typesr r� Zviner r Z kombu.logr
Zkombu.utils.compatr Zkombu.utils.eventior r
r r Zkombu.utils.objectsr r& r �__all__r rU r �__annotations__r� �
BaseExceptionr r r" r r r r r r r �<module> s2