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/celery/worker/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/celery/worker/__pycache__/loops.cpython-39.pyc
a

��Sh��@s|dZddlZddlZddlmZddlmZddlmZddl	m
Z
dZee�Z
dd
d�Zdd
d�Zddd�Zddd�ZdS)z*The consumers highly-optimized inner loop.�N)�	bootsteps)�WorkerLostError)�
get_logger�)�state)�asynloop�synloop皙�����?c
CsZz|j|d�WnDtyT}z,t|dd�}|dur@|tjkr@�WYd}~n
d}~00dS)N��timeout�errno)�drain_events�	Exception�getattrr�EAGAIN)�
connectionr�exc�	exc_errno�r�=/usr/local/lib/python3.9/site-packages/celery/worker/loops.py�_quick_drainsr�@csJdg��s�S���}|r �js$�S��fdd�}|�||||f��S)Nc
s@z��|�Wn,ty:}z|�d<WYd}~n
d}~00dS)Nr)Zheartbeat_checkr)�rate�e�r�heartbeat_errorrr�tick&sz#_enable_amqheartbeats.<locals>.tick)Zget_heartbeat_intervalZsupports_heartbeatsZcall_repeatedly)�timerrr�	heartbeatrrrr�_enable_amqheartbeatss
rc	Cs�tj}	|j}
|j}|��}t|j||d�}
||_|j�	|�|�	|�|�
�|��|jsn|j
��sntd��|jjdkr�|�t|�||_|��}z�|j|	kr�|jr�t��|
ddur�|
d�|j|jkr�|
�zt|�Wq�ty�|��}Yq�0q�Wz|��Wn2t�y>}zt� d|�WYd}~n
d}~00nBz|��Wn2t�y�}zt� d|�WYd}~n
d}~000dS)zNon-blocking event loop.�rz Could not start worker processesZamqprNz&Error cleaning up after event loop: %r)!r�RUN�updateZconnection_errors�create_task_handlerrr�
on_message�
controllerZregister_with_event_loop�consume�on_readyZ
restart_count�poolZdid_start_okr�	transportZdriver_type�	call_soonrZpropagate_errorsZcreate_looprr�maybe_shutdown�prev�value�next�
StopIteration�resetr�logger�	exception)�objr�consumer�	blueprint�hub�qosr�clock�hbrater!Z
update_qos�errors�on_task_receivedr�looprrrrr2sN
���rc	s�tj�|��}
|j�dg�t|jdd�r8t|j�|d��|
|_|�	�|�
�������fdd�}�j�kr�|jr�zt�
�W|�qd|�0qddS)zEFallback blocking event loop for transports that doesn't support AIO.NZis_greenFr cst�ddur�d��j�jkr(���z���jdd�Wn0tjyRYntyn�j�krj�Yn0dS)zC
        Perform one iteration of the blocking event loop.
        rNrr
)r,r-r"r
�socketr�OSErrorrr�r!r5rr�perform_pending_operationsr7rr�_loop_cyclezs
zsynloop.<locals>._loop_cycle)rr!r#r@rr(rrr$r&r'rrr+)r3rr4r5r6r7rr8r9�kwargsr;rArr?rrls
r)r	)r)r)r)�__doc__rr=ZceleryrZcelery.exceptionsrZcelery.utils.logr�r�__all__�__name__r1rrrrrrrr�<module>s
	
�
;�

Yohohohohohooho | Sanrei Aya