Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/__pycache__/task_manager.cpython-39.pyc
Ðазад
a ]�hP& � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z ddl m Z ddl m Z mZmZmZ ddlmZmZmZmZ e�e�Zdd � ZG d d � d e�ZG d d � d �Z dS )� N)�partial)�config� )�schema)�DBMExitException�InvalidateHandlerException�RescheduleException�ShutdownException)�cmsg� cmsg_event� cmsg_failed� cmsg_sstartc g s& | D ] }|d ur|D ] }|V qqd S �N� )�argv�sequence�itemr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/task_manager.py�Events s r c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )� NDBConfigc C s || _ d S r )� task_manager)�selfr r r r �__init__ s zNDBConfig.__init__c C s | j �|�S r )r Z config_get�r �keyr r r � __getitem__" s zNDBConfig.__getitem__c C s | j �||�S r )r Z config_set)r r �valuer r r � __setitem__% s zNDBConfig.__setitem__c C s | j �|�S r )r Z config_delr r r r � __delitem__( s zNDBConfig.__delitem__c C s | j �� S r )r Z config_keys�r r r r �keys+ s zNDBConfig.keysc C s | j �� S r )r Z config_itemsr r r r �items. s zNDBConfig.itemsc C s | j �� S r )r Z config_valuesr r r r �values1 s zNDBConfig.valuesN) �__name__� __module__� __qualname__r r r r r r! r" r r r r r s r c @ sN e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zddd�Z dd� Z dS )� TaskManagerc C s6 || _ |j| _i | _|j| _d | _t�� | _| _d S r ) �ndb�log� event_mapZ _event_queue� event_queue�thread�time�ctime�gctime)r r' r r r r 6 s zTaskManager.__init__c C s( || j vrg | j |< | j | �|� d S r )r) �append�r �event�handlerr r r �register_handler> s z TaskManager.register_handlerc C s | j | �|� d S r )r) �remover0 r r r �unregister_handlerC s z TaskManager.unregister_handlerc C s. t t|dd �t�r|j�t�dt|� � d S )N�payloadz unsupported event ignored: %s)� isinstance�getattr� Exceptionr6 r( �debug�type)r �targetr1 r r r �default_handlerF s zTaskManager.default_handlerc C s, |d d8 < |d dkr(| j j�� d S )N� countdownr r )r' � _dbm_ready�set)r �_localsr< r1 r r r �check_sources_startedK s z!TaskManager.check_sources_startedc sh �fdd�}�fdd�}G dd� dt �� � �fdd�}� �fd d �}|}|}t���r^|}|}� ||fS ) Nc sl z6� |j i |j��D ]}|j�|� q|j�t� � W n0 tyf } z|j�|� W Y d }~n d }~0 0 d S r )r �kwarg�response�put� StopIterationr9 )r< �requestr �e��methodr r �_do_local_generatorT s z4TaskManager.wrap_method.<locals>._do_local_generatorc sT z |j �� |ji |j��� W n0 tyN } z|j �|� W Y d }~n d }~0 0 d S r )rD rE r rC r9 )r< rG rH rI r r �_do_local_single\ s z1TaskManager.wrap_method.<locals>._do_local_singlec @ s e Zd Zdd� ZdS )z)TaskManager.wrap_method.<locals>.cmsg_reqc _ s" dd i| d< || _ || _|| _d S )Nr< �header)rD r rC )r rD r rC r r r r f s z2TaskManager.wrap_method.<locals>.cmsg_req.__init__N)r# r$ r% r r r r r �cmsg_reqe s rN c ? s� | j tt�� �kr.�|i |��D ] }|V q nZt�� }� |g|�R i |��}| j�|f� |�� }t |t �rpd S t |t �r�|�qZ|V qZd S r ) r+ �id� threading�current_thread�queue�Queuer* rE �getr7 rF r9 )r r rC r rD rG �rN rJ r r �_do_dispatch_generatoro s z7TaskManager.wrap_method.<locals>._do_dispatch_generatorc sp | j tt�� �kr �|i |��S tjdd�}� |g|�R i |��}| j�|f� |�� }t |t �rh|�n|S d S )Nr )�maxsize) r+ rO rP rQ rR rS r* rE rT r7 r9 )r r rC rD rG �retrU r r �_do_dispatch_single� s z4TaskManager.wrap_method.<locals>._do_dispatch_single)r �inspect�isgeneratorfunction)r rJ rK rL rV rY r2 �proxyr rU r � wrap_methodP s zTaskManager.wrap_method� c C st t |�D ]f}t||d �}t|d�rt|jt�r4|j}|� |� �}| �|�\}}}t| |t|| �� |g| j |< qd S )N�publish) �dirr8 �hasattrr7 r_ �strr] �setattrr r) )r Zapi_obj�prefix�namerJ r1 r2 r\ r r r � register_api� s zTaskManager.register_apic st dt � jj�i}tt�� �� _tdd� gt� fdd�gt t � j |�gi}|� _ zXt �� jj� jj� j � j�d��� j_ � �� jj d� � �� jj jd� t� �� j_W n: ty� } z"|� j_� jj�� W Y d }~d S d }~0 0 � jjD ] }d |d< � jjjf i |�� q� jj j �� D ]"\}}|D ]}� � ||� �q&�qd }d } g } |�s�� j � � \} } t | | �} g } �z�| D �]�}|� |j � j!g�}t"|�D �]T}z |d d } || |� W �q� t#�y: d |d v�r�d |d d < |d d dk �r$|d d d7 < � j�$d|f � | �%|� n� j�&d|f � Y n� t'�y� z|�(|� W n( t�y~ � j�&dt)�*� � Y n0 Y nd t+�y� d}Y �q�Y nF t,�y� Y W d S t�y� � j�&d|t)�*� f � Y n0 �q�t-�-� � j. tj/k�rtt-�-� � _.�qtW n� t�y� } zx� j�&d|� d| � �� z,� j�$d| � d�� � jj| j0�d� W n& t1�y� � j�$d| � �� Y n0 W Y d }~n d }~0 0 �qJt"� jjj2�D ]�} � jjj(| d d�} | d u�r�| j3d u�r�� j�$d | � �� | �4� � jj jd �r.� j�$d | � � jj �5| � n � j�$d � �q�� jj �6� � jj �4� � jj7j8D ]}|�4� �q`d S ) Nr> c S s |j �� S r )r6 r@ ��t�xr r r �<lambda>� � z!TaskManager.run.<locals>.<lambda>c s � j j�| d�S )Nr )r' r �markrg r r r rj � rk r Zdb_Zconfig_r1 FrM r< Zrcounterr � r z reschedule %szdrop %sz&could not invalidate event handler: %sTzcould not load event: %s %sz exception <z > in source zrequesting source z restartZrestartzkey error for )�synczclosing source Z db_cleanupzflush DB for the target %szleave DB for debug)9�lenr' Z_nlrO rP rQ r+ r r r r rB r) r ZDBSchemar �sourcesr( Zchannelrf r Zbonfigr9 Z _dbm_errorr? r@ �addr! r3 r* rT r � __class__r= �tupler r: r/ �errorr r4 � traceback� format_excr r r, r. Z gc_timeout�state�KeyError�cache�th�close�flush�commit�logger�handlers) r rA r) rH �specr1 r r2 �stop�sourceZ reschedule�eventsr< r r r �run� s� � � � �� �� zTaskManager.runN)r^ ) r# r$ r% r r3 r5 r= rB r] rf r� r r r r r& 5 s K r& ) rZ �loggingrR rP r, ru � functoolsr Zpyroute2r r^ r r� r r r r �messagesr r r r � getLoggerr# r( r �dictr r& r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка