관리-도구
편집 파일: wait_for_connection.cpython-39.pyc
a �)g� � @ s~ d dl mZmZmZ eZd dlZd dlmZmZ d dl m Z d dl m Z d dl mZ e� ZG dd� de�ZG d d � d e �ZdS ) � )�absolute_import�division�print_functionN)�datetime� timedelta)�to_text)� ActionBase)�Displayc @ s e Zd ZdS )�TimedOutExceptionN)�__name__� __module__� __qualname__� r r �N/usr/lib/python3.9/site-packages/ansible/plugins/action/wait_for_connection.pyr s r c sD e Zd ZdZed�ZdZdZdZdZ d dd�Z d � fd d � Z � Z S )� ActionModuleF)�connect_timeout�delay�sleep�timeout� r � iX c C s� t �� t|d� }d }t �� |k r�z ||� |r>t�d| � W d S ty� } z0|}|rlt�d||f � t�|� W Y d }~qd }~0 0 qtd||f ��d S )N)�secondsz wait_for_connection: %s successzBwait_for_connection: %s fail (expected), retrying in %d seconds...z timed out waiting for %s: %s) r Zutcnowr �display�debug� Exception�timer r ) �selfZwhatr r � what_descr Z max_end_time�e�errorr r r �do_until_success_or_timeout- s "z(ActionModule.do_until_success_or_timeoutNc s\ �d u rt � �t� jj�d� j��}t� jj�d� j��}t� jj�d� j��}t� jj�d� j��}� j j r�t � d� t dd�S t t� ��|��}~� �fdd �}t�� } |r�t�|� z<t� jd �r� j� jj||d |d � � j|||d |d � W n: t�y0 } z d|d< t| �|d< W Y d } ~ n d } ~ 0 0 t�� | } | j|d< � �� jj j � |S )Nr r r r z,wait_for_connection: skipping for check_modeT)Zskippedc sn t �d� � jr"�d �� jd� z� j�� W n tyB Y n0 � jdt� �d�}|d dkrjt d��dS ) z Test ping module, if available z0wait_for_connection: attempting ping module testZ ansible_factsNzansible.legacy.ping)Z module_nameZ module_args� task_varsZpingZpongzping test failed) r �vvvZ_discovered_interpreter_key�pop� _connection�reset�AttributeErrorZ_execute_module�dictr )r Z ping_result�r r! r r �ping_module_testO s z*ActionModule.run.<locals>.ping_module_test�transport_testzconnection port up)r r zping module testZfailed�msg�elapsed) r' �intZ_task�args�get�DEFAULT_CONNECT_TIMEOUT� DEFAULT_DELAY� DEFAULT_SLEEP�DEFAULT_TIMEOUTZ _play_contextZ check_moder r" �superr �runr Znowr r �hasattrr$ r r* r r r Z_remove_tmp_pathZ_shellZtmpdir) r �tmpr! r r r r �resultr) �startr r, �� __class__r( r r5 ? s4 " zActionModule.run)r )NN) r r r ZTRANSFERS_FILES� frozensetZ _VALID_ARGSr0 r1 r2 r3 r r5 � __classcell__r r r: r r $ s r )Z __future__r r r �typeZ __metaclass__r r r Zansible.module_utils._textr Zansible.plugins.actionr Zansible.utils.displayr r r r r r r r r �<module> s