Yohohohohohooho | Sanrei Aya
Sanrei Aya


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__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/kombu/asynchronous/__pycache__/hub.cpython-39.pyc
a

��Sh�.�@s&UdZddlmZddlZddlZddlmZddlmZddlm	Z	ddl
mZddlm
Zdd	lmZmZdd
lmZddlmZddlmZmZmZmZdd
lmZddlmZdZee �Z!da"de#d<dZ$Gdd�de%�Z&dd�Z'edd��Z(dd�dd�Z)ddd�dd�Z*Gd 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@seZdZdZdS)�StopzStops the event loop.N)�__name__�
__module__�__qualname__�__doc__�rr�@/usr/local/lib/python3.9/site-packages/kombu/asynchronous/hub.pyr srcCs
t��dS�N)rrrrr�_raise_stop_error$srcos
dVdSrr)�args�kwargsrrr�_dummy_context(sr")�returncCstS)zGet current event loop object.�rrrrrr-sr)�loopr#cCs|a|S)z"Set the current event loop object.r$)r%rrrr2src
@sNeZdZdZeZeZeZdZdFdd�Ze	dd��Z
e
jdd��Z
dd	�Zd
d�Z
dd
�Zdd�Zdd�ZdGdd�Zdd�ZdHdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�Zd&d'�Zd(d)�Zd*d+�Zd,d-�Zd.d/�Zd0d1�Zd2d3�Zd4d5�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)Irz~Event loop object.

    Arguments:
    ---------
        timer (kombu.asynchronous.Timer): Specify custom timer instance.
    NcCsn|dur|nt�|_i|_i|_t�|_t�|_t�|_t�	�|_
d|_d|_t�|_
d|_d|_|��dS)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&rrr�__init__Ns
	zHub.__init__cCs|js|��|jSr)�_pollerr5�r6rrr�pollerisz
Hub.pollercCs
||_dSr)r8)r6�valuerrrr:oscCs|��|��dSr)�closer5r9rrr�resetssz	Hub.resetcCs t�|_|jj|_|jj|_dSr)rr8�register�_register_fd�
unregister�_unregister_fdr9rrrr5ws
zHub._create_pollercCs*|jdur&|j��d|_d|_d|_dSr)r8r<r?rAr9rrr�
_close_poller|s


zHub._close_pollercCs|�t�dSr)�	call_soonrr9rrr�stop�szHub.stopcCsd�t|�t|j�t|j��S)Nz<Hub@{:#x}: R:{} W:{}>)�format�id�lenr'r(r9rrr�__repr__�s�zHub.__repr__r�
rc
Cs�|j}d}|r�|jr�t|�D]�}t|j�\}}|dur:q�z
|�Wq|yX�Yqttfyn�Yqty�}	z*|	jtj	kr��t
jd|	dd�WYd}	~	qd}	~	0ty�}	zt
jd|	dd�WYd}	~	qd}	~	00qt
|p�||�S)NzError in timer: %rr��exc_info)r&�_queue�range�next�	scheduler�MemoryError�AssertionError�OSError�errno�ENOMEM�logger�error�	Exception�min)
r6Z	min_delay�	max_delayZ
max_timers�	propagater&�delay�i�entry�excrrr�fire_timers�s(

$(zHub.fire_timersc	Cs*z|�|�W|�|�n|�|�0dSr)�_unregister�_discard�r6�fdrrr�_remove_from_loop�szHub._remove_from_loopFcCsxt|�}z|j�||�Wnty8|�|��Yn<0|t@rH|jn|j}|rh|j�	|�d||<n||f||<dSr)
rr:r>�
ValueErrorrdr
r'r(r2�add)r6rc�callback�flagsr r2�destrrrrf�s

zHub.addcCst|�}|�|�dSr)rrdrbrrr�remove�sz
Hub.removecCsDd|_z0z|��Wqty*Yq.Yq0qWd|_nd|_0dS)NTF)r0�run_oncerr9rrr�run_forever�szHub.run_forevercCs,zt|j�Wnty&d|_Yn0dSr)rNr%�
StopIterationr1r9rrrrk�szHub.run_oncecGsJt|t�st||�}|j�|j�|�Wd�n1s<0Y|Sr)�
isinstancerr	r/r,rf)r6rgr rrrrC�s


*z
Hub.call_sooncGs|j�|||�Sr)r&Z
call_after�r6r[rgr rrr�
call_later�szHub.call_latercGs|j�|||�Sr)r&�call_at)r6�whenrgr rrrrq�szHub.call_atcGs|j�|||�Sr)r&�call_repeatedlyrorrrrs�szHub.call_repeatedlycGs|�||ttB|�Sr)rfr
r�r6�fdsrgr rrr�
add_reader�szHub.add_readercGs|�||t|�Sr)rfrrtrrr�
add_writer�szHub.add_writercCsd||jv}|j�|�}z*|�|�W|r`|\}}|�||t|�n|r^|\}}|�||t|�0dSr)r(�getrdrfr)r6rc�writableZon_write�cbr rrr�
remove_reader�s
�zHub.remove_readercCsl||jv}|j�|�}z.|�|�W|rh|\}}|�||ttB|�n"|rf|\}}|�||ttB|�0dSr)r'rxrdrfr
r)r6rc�readableZon_readrzr rrr�
remove_writer�s
�zHub.remove_writerc
Cs.z|j�|�Wntttfy(Yn0dSr)r:r@�AttributeError�KeyErrorrRrbrrrr`�szHub._unregistercCs<|j�"|j}t�|_|Wd�S1s.0YdSr)r/r,r))r6�readyrrr�
_pop_ready�szHub._pop_readycs~�fdd��jD��j���fdd��jD��j���j������jD]}|��qT���}|D]
}|�qndS)Ncsg|]}��|��qSr�r`��.0rcr9rr�
<listcomp>�zHub.close.<locals>.<listcomp>csg|]}��|��qSrr�r�r9rrr�r�)r'�clearr(r2rBr+r�)r6r rgZtodos�itemrr9rr<s




z	Hub.closecCs4t|�}|j�|d�|j�|d�|j�|�dSr)rr'�popr(r2�discardrbrrrraszHub._discardcCstjd||dd�dS)Nz Callback %r raised exception: %rrrJ)rUrV)r6rgr^rrr�on_callback_errors�zHub.on_callback_errorc cs�|j|j}}|jj}
|j}|j}|jj}|j}|j	}|j
}|��}|D]}|rH|�qH|rf||d�nd}t|j
�D]
}|�qt|s�|�r�g}z|
|�}Wnty�YdS0|p�dD�]�\}}d}||vr�|�|�dur�|�|�q�d}}||@�r0z||\}}Wn"|�y,|�|�Yq�Yn0nb||	@�rpz||\}}Wn"|�yl|�|�Yq�Yn0n"||
@�r�d}nt�t||�d}|�r�z|�|��p�|�|�\}}Wnt�y�Yn0|du�r�|�|�q�t||��rjz||�Wnlt�y8}z$|jtjk�r�||�WYd}~n8d}~0|�yJYnt�yf||��Yn0q�z||�Wq�|�y�Yq�0q�|�r�||�n|||d��dVq<dS)N)rZrrFTg�������?)r'r(r:rr_rjr&rLr2r3r4r�rr*rerx�appendr{r}rU�info�W_UNKNOWN_EVENT�	TypeErrorrnrRrS�EBADFrW) r6�	generatorrrXrNrrmrr
rrr'r(rr_Z
hub_removeZ	scheduledr2r3rZ�todor�Zpoll_timeoutZ
tick_callbackZto_consolidate�eventsrc�eventZ
general_errorrzZcbargsr^rrr�create_loop s�
�





�




zHub.create_loopcCsddlm}||�S)Nr)�repr_active)�debugr�)r6r�rrrr�szHub.repr_activecCsddlm}|||pg�S)Nr)�repr_events)r�r�)r6r�r�rrrr��szHub.repr_eventscCs
t|j�Sr)�iterr&r9rrrrO�sz
Hub.schedulercCs|jdur|��|_|jSr)r1r�r9rrrr%�s

zHub.loop)N)rrIrIr)rF)1rrrrr
rrr+r7�propertyr:�setterr=r5rBrDrHr_rdrfrjrlrkrCrprqrsrvrwr{r}r`r�r<rar�r�rrXrNrrmrr�r�r�rrOr%rrrrr9s\


�



�
_
r),r�
__future__rrSr-�
contextlibrr�queuer�timer�typesrr�Zvinerr	Z	kombu.logr
Zkombu.utils.compatrZkombu.utils.eventiorr
rrZkombu.utils.objectsrr&r�__all__rrUr�__annotations__r��
BaseExceptionrrr"rrrrrrr�<module>s2


Yohohohohohooho | Sanrei Aya