Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/worker/__pycache__/pidbox.cpython-39.pyc
Ðазад
a t�h. � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z dd l mZ d Ze e�Zejejej ZZZG d d � d �ZG d d� de�ZdS )z Worker Pidbox (remote control).� N)� ignore_errors)�safe_str)� AttributeDict)�pass1)� get_logger� )�control)�Pidbox�gPidboxc @ sT e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dS )r zWorker mailbox.Nc C s^ || _ |j| _|jjjjt|j�tjjt |j|j||j j r>t nt d�d�| _| j jjj| _d S )N)�app�hostname�consumerZtset)�handlers�state)�cr r r �mailbox�Noder �Panel�datar � controllerZ use_eventloopr �set�node�clock�forward�_forward_clock��selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/worker/pidbox.py�__init__ s �� zPidbox.__init__c C s� | � � z| j�||� W nf tyH } ztd|� W Y d }~nBd }~0 ty� } z"td|dd� | �� W Y d }~n d }~0 0 d S )NzNo such control command: %szControl command error: %rT)�exc_info)r r Zhandle_message�KeyError�error� Exception�reset)r �body�message�excr r r � on_message' s zPidbox.on_messagec C s. |j �� | j_| jj| jd�| _|j| j_d S �N)�callback)� connection�channelr �listenr( r Zon_decode_errorr r r r �start3 s z Pidbox.startc C s d S �Nr �r r r r �on_stop8 s zPidbox.on_stopc C s | � � | �|�| _d S r/ )r1 �_close_channelr r r r r �stop; s z Pidbox.stopc C s | � | j� | �| j� d S r/ )r3 r r. r0 r r r r$ ? s z Pidbox.resetc C s" | j r | j jr t|| j jj� d S r/ )r r, r �closer r r r r2 C s zPidbox._close_channelc C s4 | � � | jr$td� t|| jj� | �| j� d S )Nz Canceling broadcast consumer...)r1 r �debugr �cancelr3 r r r r r �shutdownG s zPidbox.shutdown) �__name__� __module__� __qualname__�__doc__r r r( r. r1 r3 r$ r2 r7 r r r r r s r c @ sD e Zd ZdZdZdZdZdd� Zdd� Zdd � Z d d � Z d d � Z dS )r zWorker pidbox (greenlet).Nr c C s |j �| j|� d S r/ )�poolZspawn_n�loopr r r r r. V s z gPidbox.startc C s2 | j r.| j�� td� | j �� d | _ | _d S )Nz+Waiting for broadcast thread to shutdown...)� _node_stopped�_node_shutdownr r5 �waitr0 r r r r1 Y s zgPidbox.on_stopc C s | j d7 _ d S )Nr )�_resetsr0 r r r r$ ` s z gPidbox.resetc C s6 | � |� |�� | j_| jj| jd�| _| j�� d S r) )r2 r, r r- r( r �consume)r r r+ r r r � _do_resetc s zgPidbox._do_resetc C s� | j g}t�� }| _t�� }| _z�|�� ��}td|�� � | �||� |� � s�|j r�|d | j k r�|d d7 < | �||� z|j dd� W qJ t j y� Y qJ0 qJW d � n1 s�0 Y W |�� n |�� 0 d S )Nzpidbox: Connected to %s.r r g �?)�timeout)rA � threading�Eventr? r> Zconnection_for_read�info�as_urirC �is_setr+ Z drain_events�socketrD r )r r Zresetsr7 �stoppedr+ r r r r= i s (z gPidbox.loop) r8 r9 r: r; r? r> rA r. r1 r$ rC r= r r r r r O s r )r; rJ rE Z kombu.commonr Zkombu.utils.encodingr Zcelery.utils.collectionsr Zcelery.utils.functionalr Zcelery.utils.logr � r �__all__r8 �loggerr5 r" rG r r r r r r �<module> s ;
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка