관리-도구
편집 파일: async_wrapper.cpython-39.opt-1.pyc
a �)g�- � @ s< d dl mZmZmZ eZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl Z d dlZd dlZd dlZd dlZd dlmZmZ e jd dkZe�de j�e� � e�ejdd� e j dd� � � e� � \Z Z d a!d d � Z"d d d �Z#dd� Z$dd� Z%dd� Z&dd� Z'dd� Z(dd� Z)dd� Z*e+d k�r8e*� dS ) � )�absolute_import�division�print_functionN)�to_text�to_bytes� z ansible-%szInvoked with %s� � � c C s t � t j| � d S �N)�syslog� LOG_NOTICE)�msg� r �A/usr/lib/python3.9/site-packages/ansible/modules/async_wrapper.py�notice$ s r c C s. | d urt t�| �� tj�� t�|� d S r )�print�json�dumps�sys�stdout�flush�exit)�resZexit_msgr r r �end( s r c C s zt �� } | dkrt� W n: tyT t�� d }td|j|jf dd�d� Y n0 t �� t � t dd�� zt �� } | dkr�t� W n: ty� t�� d }td|j|jf dd�d� Y n0 t d d �}t � |� � tj� � � t � |� � tj� � � t � |� � tj� � � d S ) Nr r zfork #1 failed: %d (%s) T)r �failedZ022� zfork #2 failed: %d (%s) z /dev/null�w)�os�forkr �OSErrorr �exc_info�errno�strerror�setsid�umask�int�open�dup2�fileno�stdinr �stderr)�pid�eZdev_nullr r r �daemonize_self/ s( " " r. c C s� g }| � � }t|�D ] \}}|�� }|�d�r q<qtd��||d� }tt|��D ]\}}|�� �d�rT qxqTtd��|dkr�|t|�| d� }|�dd� |� � |dt|�| � }d� |�|fS ) a\ Used to filter unrelated output around module JSON output, like messages from tcagetattr, or where dropbear spews MOTD on every single command (which is nuts). Filters leading lines before first line-starting occurrence of '{', and filter all trailing lines after matching close character (working from the bottom of output). �{zNo start of json char foundN�}zNo end of json char foundr z2Module invocation had junk after the JSON data: %s� ) � splitlines� enumerate�strip� startswith� ValueError�reversed�endswith�len�append�join)�data�warnings�lines�start�lineZreverse_end_offsetZ trailing_junkr r r �_filter_non_json_linesP s" rA c C st t | d��V}|�d�}|dd� dkr6W d � d S |d|�d�� �� �d�W d � S 1 sf0 Y d S )N�rbi r � s #!� � )r' �read�indexr4 �split)Z module_pathZ module_fd�headr r r �_get_interpreterx s rJ c C sF zt �| � W n2 ty@ } z|jtjkr,� W Y d }~n d }~0 0 d S r )r �makedirsr r" ZEEXIST)�pathr- r r r �_make_temp_dir� s rM c C s� t d }t|d�}znz|�t�| �� W n@ ttfyh } z$td|t|�f � |�W Y d }~n d }~0 0 W |� � t � |t � n|� � t � |t � 0 d S )Nz.tmpr zfailed to write to %s: %s) �job_pathr' �writer r �IOErrorr r �str�closer �rename)�infoZjobfileZtjobr- r r r �jwrite� s �rU c C s� t dd|d�� i }t�d� t�� d}d}d}z�dd� t�| �D �}t|d �}|r`|| }tj|dtj tj tj d �}|� � \}}t r�|� d d �}|� d d �}t |�\}} t�|�}| r�|�d g �} t| t�s�| g} | �| � | |d < |r�||d < t |� W n� ttf�yH t�� d } d| t| �||d�}||d< t |� Y n< ttf�y� d| ||t� � d�}||d< t |� Y n0 d S )Nr r )�started�finished�ansible_job_idTr c S s g | ]}t |d d��qS )Zsurrogate_or_strict)�errors)r )�.0�cr r r � <listcomp>� � z _run_module.<locals>.<listcomp>F)�shellr* r r+ zutf-8�surrogateescaper= r+ )r �cmdr �outdatar+ rX )r r` r< r+ r ) rU � ipc_notifier�sendrR �shlexrH rJ � subprocess�Popen�PIPEZ communicate�PY3�decoderA r �loads�get� isinstance�list�extendr rP r r! r r6 � Exception� traceback� format_exc) Z wrapped_cmd�jid�resultra Zfiltered_outdatar+ r` Z interpreterZscriptZ json_warningsZmodule_warningsr- r r r � _run_module� sb � � �rt c C sH t tj�dk r tddd�d� dtjd t�� f } tjd }tjd }tjd }d tj�|�vrhd}n"t tj�dkr�tjd d k}nd }|d kr�d||f }n|}d}tj� dd�}tj� |�}tj� || �a z t |� W nL t�y( } z2tdd|t| �f tt�� �d�d� W Y d } ~ n d } ~ 0 0 �z�t�� } | �r�t�� d} | dk�rtt�d��rd�qtn | d } �qH�qHtd� tddd| t | d�d� �n`t�� t� td� t�� } | �r�t�� t�� t|�} t�| | � td| | f � t� |� t� | tj �dk�r�td| | f � t� |� | | } | dk�r�d d| d �}t |� td | � t� | t!j"� td | � t� d� |�s�t#�$tj�|�d� t|� �q�td � |�s�t#�$tj�|�d� t� n*td!t�� � t%|| � td"t�� � W nF t�yB } z,td#| � tdd$| d�d%� W Y d } ~ n d } ~ 0 0 d S )&N� Tzpusage: async_wrapper <jid> <time_limit> <modulescript> <argsfile> [-preserve_tmp] Humans, do not call directly!)r r r z%s.%drC r � z-tmp-z -preserve_tmpF�_z%s %sZANSIBLE_ASYNC_DIRz~/.ansible_asyncz#could not create directory: %s - %s)r r � exception� r g�������?z"Return async_wrapper task started.)r rV rW rX Z results_fileZ _ansible_suppress_tmpdir_deletezStarting module and watcherzStart watching %s (%s))r r z%s still running (%s)zTimeout exceeded)r r Z child_pidz Timeout reached, now killing %szSent kill to group %s zDone in kid B.zStart module (%s)zModule complete (%s)z error: %szFATAL ERROR: %sz async_wrapper exited prematurely)&r9 r �argvr r �getpidrL �dirname�environrk � expanduserr; rN rM ro r rp rq r rb rR � ipc_watcherZpollr r. r& �setpgid�time�sleep�waitpid�WNOHANGrU �killpg�signal�SIGKILL�shutil�rmtreert )rr Z time_limitZwrapped_moduleZargsfileZ preserve_tmpr` �stepZ async_dirZjobdirr- r, ZretriesZsub_pidZ remainingr r r r �main� s� �� �� �� r� �__main__)Nr ),Z __future__r r r �typeZ __metaclass__r" r rd r� r re r rp r� r� r ZmultiprocessingZansible.module_utils._textr r � version_inforh ZopenlogrL �basename�__file__r r; rz ZPiper rb rN r r r. rA rJ rM rU rt r� �__name__r r r r �<module> s> " !( E