?????????? ????????? - ??????????????? - /usr/lib/python3.9/site-packages/ansible/cli/scripts/__pycache__/ansible_connection_cli_stub.cpython-39.pyc
???????
a �)g�4 � @ sp 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 dlZd dlmZ d dlmZ d dlmZ d dlm Z m Z d dl m Z m Z m!Z!m"Z" d dl#m$Z$ d d l%m&Z&m'Z' d d l(m)Z) d d l*m+Z+ d d l,m-Z-m.Z. d d l/m0Z0 d dl1m2Z2 e0� Z3dd� Z4edd� �Z5G dd� de6�Z7ddd�Z8e9dk�rle8� dS )� )�absolute_import�division�print_functionN)�contextmanager)� constants)�option_helpers)�to_bytes�to_text)� Connection�ConnectionError� send_data� recv_data)� fork_process)�AnsibleJSONEncoder�AnsibleJSONDecoder)� PlayContext)�connection_loader)� unfrackpath� makedirs_safe)�Display)� JsonRpcServerc C sn t | �� �� �}| �|�}t|�|k r.td��t| �� �� �}|t�|�� � kr^td� |���|� dd�}|S )Nz"EOF found before data was completez/Read {0} bytes, but data did not match checksums \r� ) �int�readline�strip�read�len� Exceptionr �hashlibZsha1Z hexdigest�format�replace)Z byte_stream�size�dataZ data_hash� r# �S/usr/lib/python3.9/site-packages/ansible/cli/scripts/ansible_connection_cli_stub.py� read_stream( s r% c c sF t �| t jt jB d�}t�|tj� dV t�|tj� t �|� dS )z� Uses contextmanager to create and release a file lock based on the given path. This allows us to create locks using `with file_lock()` to prevent deadlocks related to failure to unlock properly. i� N) �os�open�O_RDWR�O_CREAT�fcntl�lockfZLOCK_EXZLOCK_UN�close)� lock_pathZlock_fdr# r# r$ � file_lock9 s r. c @ sJ e Zd ZdZddd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )�ConnectionProcessz� The connection process wraps around a Connection object that manages the connection to a remote device that persists over the playbook Nc C sB || _ || _|| _|| _|| _d | _t� | _d | _d | _ || _ d S )N) � play_context� socket_path� original_path� _task_uuid�fd� exceptionr �srv�sock� connection�_ansible_playbook_pid)�selfr4 r0 r1 r2 � task_uuid�ansible_playbook_pidr# r# r$ �__init__M s zConnectionProcess.__init__c C s� t � }i }�z��z&|�dd| j f� | jjrV| jjd dvrVtj�| j| jj�| j_t j | jj | jd| j | j d�| _ z| j j|d� W n> ty� } z&|�dt|�f� td ��W Y d }~n d }~0 0 | j| j _| j�| j � |�d d � tj�� �� D �� t�tjtj�| _ | j � | j� | j � d � |�d � W nN t �y� } z4|�| j � � � t|�|d< t!�"� |d< W Y d }~n d }~0 0 W ||d< | j#�$t%j&|t'd�� | j#�(� n*||d< | j#�$t%j&|t'd�� | j#�(� 0 d S )N�vvvvzcontrol socket path is %sr z~/z /dev/null)r; r< �Zdirect�debug�XUnable to decode JSON from response set_options. See the debug log for more information.c S s g | ] }d |f�qS )r> r# )�.0�msgr# r# r$ � <listcomp>r � z+ConnectionProcess.start.<locals>.<listcomp>� )r> z2local domain socket listeners started successfully�errorr5 �messages��cls))�list�appendr1 r0 Zprivate_key_filer& �path�joinr2 r �getr8 r3 r9 � set_optionsr r � _socket_pathr6 �register�extend�sys�stdout�getvalue� splitlines�socketZAF_UNIXZ SOCK_STREAMr7 ZbindZlistenr � pop_messages� traceback� format_excr4 �write�json�dumpsr r, )r: �optionsrH �result�excr# r# r$ �start\ s> � $ �zConnectionProcess.startc C s� �z��z,| j �d�}| j j�s0t�tj| j� t�tj| j� t�| j �d�� d | _ | j � � \}}t�d� t�tj| j � t |�}|s��q&|r�tjd| dd� t�t|dd��}|�d �d kr�| j js�| j �� t�| j �d �� | j�|�}t�d� |�rtjd | dd� t|t|�� q~|�� qW nV t�y� } z<t|d ��rj|j t j k�rtt � � | _ n t � � | _ W Y d }~n d }~0 0 W t �!d� | �"� nt �!d� | �"� 0 d S )N�persistent_log_messages�persistent_connect_timeoutr zjsonrpc request: %sT�Zlog_onlyZsurrogate_or_strict)�errors�methodZ exec_command�persistent_command_timeoutzjsonrpc response: %s�errnog�������?)#r8 � get_optionZ _conn_closed�signal�SIGALRM�connect_timeout�SIGTERM�handler�alarmr5 r7 Zaccept�command_timeoutr �displayr] �loadsr rO Z connectedZ_connectr6 Zhandle_requestr r r, r �hasattrri ZEINTRrZ r[ �time�sleep�shutdown)r: Z log_messages�s�addrr" ZrequestZresp�er# r# r$ �run� sD " � zConnectionProcess.runc C s* d| j �d� }tj|dd� t|��d S )Nz�persistent connection idle timeout triggered, timeout value is %s secs. See the timeout setting options in the Network Debug and Troubleshooting Guide.rd Tre �r8 rj rr r �r: Zsignum�framerC r# r# r$ rm � s �z!ConnectionProcess.connect_timeoutc C s* d| j �d� }tj|dd� t|��d S )Nz�command timeout triggered, timeout value is %s secs. See the timeout setting options in the Network Debug and Troubleshooting Guide.rh Tre r| r} r# r# r$ rq � s �z!ConnectionProcess.command_timeoutc C s" d| }t j |dd� t|��d S )Nz%signal handler called with signal %s.Tre )rr r r} r# r# r$ ro � s zConnectionProcess.handlerc C s( t dtj�| j� �}tj�| j�r�z�zR| jr8| j�� | jrv| j�� | j� d�rv| j� � D ]\}}t j |dd� q^W n t y� Y n0 W tj�| j�r�t� | j� t| jdd� t| jdd� n8tj�| j�r�t� | j� t| jdd� t| jdd� 0 tj�|��rt� |� t j d dd� dS ) z, Shuts down the local domain socket �%s/.ansible_pc_lock_%src Tre rQ NZ _connectedFzshutdown complete)r r& rM �splitr1 �existsr7 r, r8 rj rY rr r �remove�setattr)r: r- �_level�messager# r# r$ rw � s. � zConnectionProcess.shutdown)NN) �__name__� __module__� __qualname__�__doc__r= rb r{ rm rq ro rw r# r# r# r$ r/ H s %3r/ c C s$ t jdd�}t �|� |�d� |�d� |�| durB| dd� n| �} | jt_d}i }t� }d}tj j }tj }t � � t_ z@t|�}t|�} tj| dd �} tj|dd �} t� } | �| � W n@ ty� } z(d}|�t| �t�� d �� W Y d} ~ n d} ~ 0 0 |dk�r�tjd d d �}| j}| j}|� | j | j | j | j |�}t!t"j#�}t$|� t!|t%|d� �}t!dt&j'�(|� �}t)|���� t&j'�*|��s�|�+d� t&�,� }t&�-� \}}t.� }|dk�rDz6t&�/|� t&�0|d�}t1|| ||||�}|�2| � W n* t�y |�+dt�� f� d}Y n0 |dk�r0|�3� n|�4� t�5|� nBt&�/|� t&�0|d�}t6j|�7� t8d�}|�9|�:d�� |�|� n�|�+d� t;|�} z| j<| d� W n@ t=�y� } z&|�+dt| �f� t=d��W Y d} ~ n d} ~ 0 0 t| �} z| �>| � | �?|� W n^ t�yj } zDt@| t=��r>tA| dd�dk�r>n|�t| �t�� d �� W Y d} ~ n d} ~ 0 0 W d � n1 �s�0 Y t&j'�*|��r�|�9t;|��B� � |�+d tj �C� f� |�||d �� |t_ d |v �r�d}tjD�Et6jF|tGd�� nd}tj �Et6jF|tGd�� t�5|� dS ) z9 Called to initiate the connect to the remote device zansible-connection)�prog� playbook_pidr; NrF r �bytes)�encoding)rG r5 �sshT)Z class_only)Z directoryr )r> z/local domain socket does not exist, starting it�wrG �rrI rH )r> z-found existing local domain socket, using it!r? r@ rA �codei����r> )rH r1 r5 )H�opt_helpZcreate_base_parserZadd_verbosity_options� add_argument� parse_args� verbosityrr rK rT �stdin�bufferrU �io�StringIOr% �picklers r Z deserializer �updater rZ r[ r rO r� r; Z_create_control_pathZ remote_addr�portZ remote_userr8 r �CZPERSISTENT_CONTROL_PATH_DIRr �dictr& rM r� r. r� rL �getcwd�piper r, �fdopenr/ rb r{ rw �exitr] r r rS �popr rP r Zupdate_play_contextZset_check_prompt� isinstance�getattrrY rV �stderrr\ r^ r ) �args�parser�rcr` rH r1 r� Z saved_stdoutZ opts_dataZ init_dataZpc_datar_ r0 rz r� r< r; ZcpZtmp_pathr- r2 r� r� �pidZwfdZprocessZrfdr" Zconnra r# r# r$ �main� s� � �>� r� �__main__)N):Z __future__r r r �typeZ __metaclass__�argparser* r r� r& r� rk rX rT ru rZ ri r] � contextlibr Zansibler r� Zansible.cli.argumentsr r� Zansible.module_utils._textr r Z ansible.module_utils.connectionr r r r Z ansible.module_utils.servicer Zansible.parsing.ajsonr r Z ansible.playbook.play_contextr Zansible.plugins.loaderr Zansible.utils.pathr r Zansible.utils.displayr Zansible.utils.jsonrpcr rr r% r. �objectr/ r� r� r# r# r# r$ �<module> sH
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????