Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/asynchronous/__pycache__/hub.cpython-39.pyc
Ðазад
a o�h�. � @ 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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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�errnoZENOMEM�logger�error� Exception�min) r6 Z min_delayZ 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> � ValueErrorrb r r' r( r2 �add)r6 ra �callback�flagsr r2 �destr r r rd � s zHub.addc C s t |�}| �|� d S r )r rb r` 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 ri � s z Hub.run_oncec G sJ t |t�st||�}| j� | j�|� W d � n1 s<0 Y |S r )� isinstancer r r/ r, rd )r6 re r r r r rC � s *z Hub.call_soonc G s | j �|||�S r )r& Z call_after�r6 rY re r r r r � call_later� s zHub.call_laterc G s | j �|||�S r )r& �call_at)r6 �whenre r r r r ro � s z Hub.call_atc G s | j �|||�S r )r& �call_repeatedlyrm r r r rq � s zHub.call_repeatedlyc G s | � ||ttB |�S r )rd r r �r6 �fdsre r r r r � add_reader� s zHub.add_readerc G s | � ||t|�S r )rd r rr 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( �getrb rd r )r6 ra �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' rv rb rd r r )r6 ra �readableZon_readrx 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 r` 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^ ��.0ra 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 re Ztodos�itemr r9 r r< s z Hub.closec C s4 t |�}| j�|d � | j�|d � | j�|� d S r )r r' �popr( r2 �discardr` r r r r_ s z Hub._discardc C s t jd||dd� d S )Nz Callback %r raised exception: %rr rJ )rT rU )r6 re 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)rX r r FTg�������?) r' r( r: r r] rh r& rL r2 r3 r4 r r r* rc rv �appendry r{ rT �info�W_UNKNOWN_EVENT� TypeErrorrl rR rS �EBADFrV ) r6 � generatorr rW rN r rk r} r r r r' r( r r] Z hub_removeZ scheduledr2 r3 rX �todor� Z poll_timeoutZ tick_callbackZto_consolidate�eventsra �eventZ general_errorrx 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] rb rd rh rj ri rC rn ro rq rt ru ry r{ r^ r r< r_ r� r� r rW rN r rk 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 rT r �__annotations__r� � BaseExceptionr r r" r r r r r r r �<module> s2
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка