관리-도구
편집 파일: timeout.cpython-39.opt-1.pyc
a �)g� � @ sR d dl mZmZmZ eZd dlZd dlmZ dZ dZ G dd� de �Z d dd�ZdS ) � )�absolute_import�division�print_functionN� c @ s e Zd ZdS )� TimeoutErrorN)�__name__� __module__� __qualname__� r r �F/usr/lib/python3.9/site-packages/ansible/module_utils/facts/timeout.pyr s r � Timer expiredc s( � fdd�}t � �r$� }d� ||�S |S )z� Timeout decorator to expire after a set number of seconds. This raises an ansible.module_utils.facts.TimeoutError if the timeout is hit before the function completes. c s � �fdd�}|S )Nc s� �}|d u r t � �d�pt}tjdd�}|�� | |�}|�� zDz|�|�W W |�� S tj yv t d| ��Y n0 W |�� n |�� 0 d S )N�GATHER_TIMEOUT� )Z processesz Timer expired after %s seconds) �globals�get�DEFAULT_GATHER_TIMEOUT�mpZ ThreadPoolZ apply_async�closeZ terminate�multiprocessingr )�args�kwargsZ timeout_value�pool�res)�func�secondsr r �wrapper( s �z+timeout.<locals>.decorator.<locals>.wrapperr )r r �r )r r � decorator' s ztimeout.<locals>.decoratorN)�callable)r Z error_messager r r r r �timeout! s r )Nr )Z __future__r r r �typeZ __metaclass__r Zmultiprocessing.poolr r r r � Exceptionr r r r r r �<module> s