File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/__pycache__/asynchronous.cpython-310.pyc
Back
o ;jv � @ s^ d Z ddlZddlZddlZddlZddlZddlZe�e �Z ej dd� �Z G dd� d�Z dS )z; Helpers/utils for working with tornado asynchronous stuff � Nc c s: � t jjjj�� }| �� z dV W |�� dS |�� w )zW A context manager that will set the current ioloop to io_loop for the context N)�salt�ext�tornado�ioloop�IOLoop�current� make_current)�io_loopZ orig_loop� r �K/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/asynchronous.py�current_ioloop s �r c @ sd e Zd ZdZ ddd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dS )� SyncWrappera� A wrapper to make Async classes synchronous This is uses as a simple wrapper, for example: asynchronous = AsyncClass() # this method would regularly return a future future = asynchronous.async_method() sync = SyncWrapper(async_factory_method, (arg1, arg2), {'kwarg1': 'val'}) # the sync wrapper will automatically wait on the future ret = sync.async_method() Nc C s� t jjjjdd�| _|d u rg }|d u ri }|d u r g }|d u r"g }|| _|| _|r0| j|| j< t| j�� ||i |��| _ W d � n1 sHw Y t t |t | j dg � ��| _ t t |t | j dg � ��| _d S )NF)r � async_methods� close_methods)r r r r r r � loop_kwarg�clsr �obj�list�set�getattr�_async_methods�_close_methods)�selfr �args�kwargsr r r r r r �__init__, s, �� �zSyncWrapper.__init__c C s& t | jd�r| j| jj7 _dS dS )z� We need the '_coroutines' attribute on classes until we can depricate tornado<4.5. After that 'is_coroutine_fuction' will always be available. � _coroutinesN)�hasattrr r r �r r r r �_populate_async_methodsK s �z#SyncWrapper._populate_async_methodsc C s d| j � d�S )Nz<SyncWrapper(cls=�))r r r r r �__repr__T s zSyncWrapper.__repr__c C s� | j D ]J}|| jv r| �|�}nzt| j|�}W n ty) t�d|| j� Y qw z|� W q ty@ t�d|| j� Y q tyM t� d� Y qw | j }|� � |j dd� d S )Nz No sync method %s on object %rz No async method %s on object %rz/Exception encountered while running stop methodT)Zall_fds) r r �_wrapr r �AttributeError�log�error� Exception� exceptionr �stop�close)r �methodr r r r r) W s& � �zSyncWrapper.closec C s || j v r | �|�S t| j|�S �N)r r" r r )r �keyr r r � __getattr__k s zSyncWrapper.__getattr__c s � �fdd�}|S )Nc sZ g }t j�j� | ||�jfd�}|�� |�� |d r |d S |d }|d �|d ��)N)�targetr r � � )� threading�Thread�_targetr �start�join�with_traceback)r r �results�thread�exc_info�r, r r r �wrapq s �z SyncWrapper._wrap.<locals>.wrapr )r r, r; r r: r r" p s zSyncWrapper._wrapc s` z|� � ���fdd��}|�d� |�|� W d S ty/ |�d� |�t�� � Y d S w )Nc s t �j��� i ���S r+ )r r r �r r, r r r r �<lambda>� s z%SyncWrapper._target.<locals>.<lambda>TF)Zrun_sync�appendr& �sysr9 )r r, r r r7 r �resultr r< r r3 � s �zSyncWrapper._targetc C s | S r+ r r r r r � __enter__� s zSyncWrapper.__enter__c C s | � � d S r+ )r) )r �exc_typeZexc_val�tbr r r �__exit__� s zSyncWrapper.__exit__)NNNNN) �__name__� __module__� __qualname__�__doc__r r r! r) r- r" r3 rA rD r r r r r s � r )rH � contextlib�loggingr? r1 Zsalt.ext.tornado.concurrentr Zsalt.ext.tornado.ioloop� getLoggerrE r$ �contextmanagerr r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings