| Server IP : 85.193.89.191 / Your IP : 18.226.165.236 Web Server : Apache System : Linux 956367-cx40159.tmweb.ru 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : bitrix ( 600) PHP Version : 8.1.27 Disable Function : NONE MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python2.7/site-packages/ansible/plugins/connection/ |
Upload File : |
�
� �\c @` s d d l m Z m Z m Z e Z d Z d d l Z d d l Z d d l Z d d l
Z
d d l Z d d l Z d d l
Z
d d l m Z d d l m Z d d l m Z m Z m Z m Z d d l m Z d d l m Z d d l m Z m Z m Z d d
l m Z d d l! m" Z" m# Z# m$ Z$ d d l% m& Z& m' Z' d d
l( m) Z) m* Z* d d l+ m, Z, m- Z- y d d l. m/ Z/ Wn* e0 k
r�d d l1 m2 Z2 e2 � Z/ n Xd d f Z3 e4 a5 d e f d � � YZ6 e/ d � Z7 d � Z8 d e) f d � � YZ9 d S( i ( t absolute_importt divisiont print_functionsN&
connection: ssh
short_description: connect via ssh client binary
description:
- This connection plugin allows ansible to communicate to the target machines via normal ssh command line.
- Ansible does not expose a channel to allow communication between the user and the ssh process to accept
a password manually to decrypt an ssh key when using this connection plugin (which is the default). The
use of ``ssh-agent`` is highly recommended.
author: ansible (@core)
version_added: historical
options:
host:
description: Hostname/ip to connect to.
default: inventory_hostname
vars:
- name: ansible_host
- name: ansible_ssh_host
host_key_checking:
description: Determines if ssh should check host keys
type: boolean
ini:
- section: defaults
key: 'host_key_checking'
- section: ssh_connection
key: 'host_key_checking'
version_added: '2.5'
env:
- name: ANSIBLE_HOST_KEY_CHECKING
- name: ANSIBLE_SSH_HOST_KEY_CHECKING
version_added: '2.5'
vars:
- name: ansible_host_key_checking
version_added: '2.5'
- name: ansible_ssh_host_key_checking
version_added: '2.5'
password:
description: Authentication password for the C(remote_user). Can be supplied as CLI option.
vars:
- name: ansible_password
- name: ansible_ssh_pass
ssh_args:
description: Arguments to pass to all ssh cli tools
default: '-C -o ControlMaster=auto -o ControlPersist=60s'
ini:
- section: 'ssh_connection'
key: 'ssh_args'
env:
- name: ANSIBLE_SSH_ARGS
vars:
- name: ansible_ssh_args
version_added: '2.7'
ssh_common_args:
description: Common extra args for all ssh CLI tools
ini:
- section: 'ssh_connection'
key: 'ssh_common_args'
version_added: '2.7'
env:
- name: ANSIBLE_SSH_COMMON_ARGS
version_added: '2.7'
vars:
- name: ansible_ssh_common_args
ssh_executable:
default: ssh
description:
- This defines the location of the ssh binary. It defaults to ``ssh`` which will use the first ssh binary available in $PATH.
- This option is usually not required, it might be useful when access to system ssh is restricted,
or when using ssh wrappers to connect to remote hosts.
env: [{name: ANSIBLE_SSH_EXECUTABLE}]
ini:
- {key: ssh_executable, section: ssh_connection}
#const: ANSIBLE_SSH_EXECUTABLE
version_added: "2.2"
vars:
- name: ansible_ssh_executable
version_added: '2.7'
sftp_executable:
default: sftp
description:
- This defines the location of the sftp binary. It defaults to ``sftp`` which will use the first binary available in $PATH.
env: [{name: ANSIBLE_SFTP_EXECUTABLE}]
ini:
- {key: sftp_executable, section: ssh_connection}
version_added: "2.6"
vars:
- name: ansible_sftp_executable
version_added: '2.7'
scp_executable:
default: scp
description:
- This defines the location of the scp binary. It defaults to `scp` which will use the first binary available in $PATH.
env: [{name: ANSIBLE_SCP_EXECUTABLE}]
ini:
- {key: scp_executable, section: ssh_connection}
version_added: "2.6"
vars:
- name: ansible_scp_executable
version_added: '2.7'
scp_extra_args:
description: Extra exclusive to the ``scp`` CLI
vars:
- name: ansible_scp_extra_args
env:
- name: ANSIBLE_SCP_EXTRA_ARGS
version_added: '2.7'
ini:
- key: scp_extra_args
section: ssh_connection
version_added: '2.7'
sftp_extra_args:
description: Extra exclusive to the ``sftp`` CLI
vars:
- name: ansible_sftp_extra_args
env:
- name: ANSIBLE_SFTP_EXTRA_ARGS
version_added: '2.7'
ini:
- key: sftp_extra_args
section: ssh_connection
version_added: '2.7'
ssh_extra_args:
description: Extra exclusive to the 'ssh' CLI
vars:
- name: ansible_ssh_extra_args
env:
- name: ANSIBLE_SSH_EXTRA_ARGS
version_added: '2.7'
ini:
- key: ssh_extra_args
section: ssh_connection
version_added: '2.7'
retries:
# constant: ANSIBLE_SSH_RETRIES
description: Number of attempts to connect.
default: 3
type: integer
env:
- name: ANSIBLE_SSH_RETRIES
ini:
- section: connection
key: retries
- section: ssh_connection
key: retries
vars:
- name: ansible_ssh_retries
version_added: '2.7'
port:
description: Remote port to connect to.
type: int
default: 22
ini:
- section: defaults
key: remote_port
env:
- name: ANSIBLE_REMOTE_PORT
vars:
- name: ansible_port
- name: ansible_ssh_port
remote_user:
description:
- User name with which to login to the remote server, normally set by the remote_user keyword.
- If no user is supplied, Ansible will let the ssh client binary choose the user as it normally
ini:
- section: defaults
key: remote_user
env:
- name: ANSIBLE_REMOTE_USER
vars:
- name: ansible_user
- name: ansible_ssh_user
pipelining:
default: ANSIBLE_PIPELINING
description:
- Pipelining reduces the number of SSH operations required to execute a module on the remote server,
by executing many Ansible modules without actual file transfer.
- This can result in a very significant performance improvement when enabled.
- However this conflicts with privilege escalation (become).
For example, when using sudo operations you must first disable 'requiretty' in the sudoers file for the target hosts,
which is why this feature is disabled by default.
env:
- name: ANSIBLE_PIPELINING
#- name: ANSIBLE_SSH_PIPELINING
ini:
- section: defaults
key: pipelining
#- section: ssh_connection
# key: pipelining
type: boolean
vars:
- name: ansible_pipelining
- name: ansible_ssh_pipelining
private_key_file:
description:
- Path to private key file to use for authentication
ini:
- section: defaults
key: private_key_file
env:
- name: ANSIBLE_PRIVATE_KEY_FILE
vars:
- name: ansible_private_key_file
- name: ansible_ssh_private_key_file
control_path:
description:
- This is the location to save ssh's ControlPath sockets, it uses ssh's variable substitution.
- Since 2.3, if null, ansible will generate a unique hash. Use `%(directory)s` to indicate where to use the control dir path setting.
env:
- name: ANSIBLE_SSH_CONTROL_PATH
ini:
- key: control_path
section: ssh_connection
vars:
- name: ansible_control_path
version_added: '2.7'
control_path_dir:
default: ~/.ansible/cp
description:
- This sets the directory to use for ssh control path if the control path setting is null.
- Also, provides the `%(directory)s` variable for the control path setting.
env:
- name: ANSIBLE_SSH_CONTROL_PATH_DIR
ini:
- section: ssh_connection
key: control_path_dir
vars:
- name: ansible_control_path_dir
version_added: '2.7'
sftp_batch_mode:
default: 'yes'
description: 'TODO: write it'
env: [{name: ANSIBLE_SFTP_BATCH_MODE}]
ini:
- {key: sftp_batch_mode, section: ssh_connection}
type: bool
vars:
- name: ansible_sftp_batch_mode
version_added: '2.7'
scp_if_ssh:
default: smart
description:
- "Prefered method to use when transfering files over ssh"
- When set to smart, Ansible will try them until one succeeds or they all fail
- If set to True, it will force 'scp', if False it will use 'sftp'
env: [{name: ANSIBLE_SCP_IF_SSH}]
ini:
- {key: scp_if_ssh, section: ssh_connection}
vars:
- name: ansible_scp_if_ssh
version_added: '2.7'
use_tty:
version_added: '2.5'
default: 'yes'
description: add -tt to ssh commands to force tty allocation
env: [{name: ANSIBLE_SSH_USETTY}]
ini:
- {key: usetty, section: ssh_connection}
type: bool
vars:
- name: ansible_ssh_use_tty
version_added: '2.7'
N( t wraps( t constants( t AnsibleAuthenticationFailuret AnsibleConnectionFailuret AnsibleErrort AnsibleFileNotFound( t AnsibleOptionsError( t selectors( t PY3t text_typet binary_type( t shlex_quote( t to_bytest to_nativet to_text( t BOOLEANSt boolean( t ConnectionBaset BUFSIZE( t unfrackpatht
makedirs_safe( t display( t Displays" Traceback (most recent call last):s PHP Parse error:t$ AnsibleControlPersistBrokenPipeErrorc B` s e Z d Z RS( s ControlPersist broken pipe ( t __name__t
__module__t __doc__( ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyR 9 s c C` s� | d k r� | d d k r� d j | � } | d k r@ d } n | rX d j | � } n" d j | t | d j � � � } t | � � q� | d d k r� d
} | r� d j | � } q� d j | t | d j � � � } q� n | d d k rxt } x( t D] } | | d k r� t } Pq� q� W| rxd } | rDd j | � } n" d j | t | d � j � � } t | � � qxn d | d k o�d k n r�d } | r�d j | � } n" d j | t | d � j � � } | j | d | �n d S( Nt sshpassi i s_ Invalid/incorrect username/password. Skipping remaining {0} retries to prevent account lockout:s Invalid/incorrect password:s" {0} <error censored due to no log>s {0} {1}i i i i i s sshpass error:i� s& Failed to connect to the host via ssh:i� t host( i i i i i ( t formatR t rstripR t Truet b_NOT_SSH_ERRORSt FalseR t vvv( t remaining_retriest commandt return_tuplet no_logR R t msgt SSH_ERRORt signature( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt
_handle_error> s@ "(
" "c ` s t � � � f d � � } | S( s+
Decorator to retry ssh/scp/sftp in the case of a connection failure
Will retry if:
* an exception is caught
* ssh returns 255
Will not retry if
* sshpass returns 5 (invalid password, to prevent account lockouts)
* remaining_tries is < 2
* retries limit reached
c ` s� t t j � d } d | d } xqt | � D]c} | d } | d k r� | j j r� t | t � r� t j � | _
d t | j
d d d d d �| d <n y yY � | | | � } | j j r� t
j d | d d
| j �n t
j | d
| j �Wn� t k
r�| d } | j j rht | t � rht j � | _
d t | j
d d d d d �| d <n t
j d � � | | | � } n X| | d } t | | d | | j j | j � PWq. t k
r�} � q. t t f k
r�} | | d k r� q�d | d }
|
d
k r$d
}
n t | t � rMd | d | |
f } n d | d | | |
f } t
j | d
| j �t j |
� q. q. Xq. W| S( Ni s %s...i s -dt nonstringt
simplereprt errorst surrogate_or_stricts/ rc=%s, stdout and stderr censored due to no logR u. RETRYING BECAUSE OF CONTROLPERSIST BROKEN PIPEi i sP ssh_retry: attempt: %d, ssh return code is 255. cmd (%s), pausing for %d secondssR ssh_retry: attempt: %d, caught exception(%s) from cmd (%s), pausing for %d seconds( t intt Ct ANSIBLE_SSH_RETRIESt ranget
_play_contextt passwordt
isinstancet listt ost pipet sshpass_pipeR R) R R% R R R- R R t Exceptiont vvt timet sleep( t selft argst kwargst remaining_triest cmd_summaryt attemptt cmdR( R& t et pauseR* ( t func( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt wrapped{ sL
'* !
*
#
( R ( RJ RK ( ( RJ sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt
_ssh_retryo s =t
Connectionc B` s e Z d Z d Z e Z e e j � j d g � Z
d � Z d � Z e
e e d � � Z e
d � � Z e
d � � Z d � Z d � Z d
� Z e
d � � Z d � Z e e d
� Z e e e d � � Z e d � � Z e e d � Z d � Z d � Z d � Z d � Z RS( s ssh based connections t ssht runasc O` sb t t | � j | | � | j j | _ | j j | _ | j j | _ t j
| _ t j | _
d S( N( t superRM t __init__R6 t remote_addrR t portt remote_usert userR3 t ANSIBLE_SSH_CONTROL_PATHt control_patht ANSIBLE_SSH_CONTROL_PATH_DIRt control_path_dir( RA RB RC ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyRQ � s c C` s | S( N( ( RA ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _connect� s c C` s� d | | | f } | r* | d | 7} n | rG | d t | � 7} n t j � } | j t | � � | j � } d | d } | S( s7 Make a hash for the controlpath based on con attributess %s-%s-%ss -%ss %(directory)s/i
( R t hashlibt sha1t updateR t hexdigest( R RS RU t
connectiont pidt pstringt mt digestt cpath( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _create_control_path� s c C` sn t d k rj yA t j d g d t j d t j d t j �} | j � t a Wqj t k
rf t a qj Xn t S( NR t stdint stdoutt stderr( t SSHPASS_AVAILABLEt Nonet
subprocesst Popent PIPEt communicateR" t OSErrorR$ ( t p( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _sshpass_available� s -
c C` s[ t } t } xB d � | D� D]0 } d | k r8 t } q d | k r t } q q W| | f S( s
Takes a command array and scans it for ControlPersist and ControlPath
settings and returns two booleans indicating whether either was found.
This could be smarter, e.g. returning false if ControlPersist is 'no',
but for now we do it simple way.
c s` s | ] } | j � Vq d S( N( t lower( t .0t a( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pys <genexpr>� s t controlpersistt controlpath( R$ R" ( t b_commandRu Rv t b_arg( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _persistence_controls� s
c C` sD t j d | d j d � | D� � f d | j j �| | 7} d S( s�
Adds arguments to the ssh command and displays a caller-supplied explanation of why.
:arg b_command: A list containing the command to add the new arguments to.
This list will be modified by this method.
:arg b_args: An iterable of new arguments to add. This iterable is used
more than once so it must be persistent (ie: a list is okay but a
StringIO would not)
:arg explanation: A text string containing explaining why the arguments
were added. It will be displayed with a high enough verbosity.
.. note:: This function does its work via side-effect. The b_command list has the new arguments appended.
u
SSH: %s: (%s)s )(c s` s | ] } t | � Vq d S( N( R ( Rs Rt ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pys <genexpr> s R N( R t vvvvvt joinR6 RR ( RA Rw t b_argst explanation( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _add_args s
6c G` s� g } | j j rl | j � s- t d � � n t j � | _ | d d t | j d d d d d �g 7} n | d k r� | t | j j d d �g 7} n | t | d d �g 7} | d
k r t j
r | j j r� d d g } | j | | d
� n | d d g 7} n | j j d k r+| j
d � n | j j r�g | j | j j � D] } t | d d �^ qM} | j | | d � n t j s�d* } | j | | d � n | j j d+ k r�d d t | j j d d d d �f } | j | | d � n | j j } | rJd d t t j j | � d d �d f } | j | | d � n | j j sl| j | d, d � n | j j } | r�| j | d d t | j j d d �f d � n | j | d d t | j j d d d d �f d! � x� d" d# j | � f D]o } t | j | d+ � } | d+ k r�g | j | � D] } t | d d �^ q2} | j | | d$ | � q�q�W| j | � \ }
} |
rft | _ | sft | j � } t | d d �}
t |
d% � t j |
t j! � s�t d& t" | � � � n | j# s!| j$ | j% | j | j& � | _# n d d' t | j# t' d( | � d d �f } | j | | d) � qfn | r�| g | D] } t | � ^ qv7} n | S(- s�
Takes a binary (ssh, scp, sftp) and optional extra arguments and returns
a command line as an array that can be passed to subprocess.Popen.
sU to use the 'ssh' connection type with passwords, you must install the sshpass programR s -di R. R/ R0 R1 RN t sftps -os BatchMode=nou disable batch mode for sshpasss -bt -i s -vvvu ansible.cfg set ssh_argss StrictHostKeyChecking=nou4 ANSIBLE_HOST_KEY_CHECKING/host_key_checking disableds Port=u0 ANSIBLE_REMOTE_PORT/remote_port/ansible_port sets IdentityFile="t "uJ ANSIBLE_PRIVATE_KEY_FILE/private_key_file/ansible_ssh_private_key_file sets KbdInteractiveAuthentication=nosI PreferredAuthentications=gssapi-with-mic,gssapi-keyex,hostbased,publickeys PasswordAuthentication=nou) ansible_password/ansible_ssh_pass not sets User=u8 ANSIBLE_REMOTE_USER/remote_user/ansible_user/user/-u sets ConnectTimeout=u ANSIBLE_TIMEOUT/timeout setu ssh_common_argsu {0}_extra_argsu PlayContext set %si� s Cannot write to ControlPath %ss ControlPath=t directoryu, found only ControlPersist; added ControlPath( s -os StrictHostKeyChecking=noN( s -os KbdInteractiveAuthentication=nos -osI PreferredAuthentications=gssapi-with-mic,gssapi-keyex,hostbased,publickeys -os PasswordAuthentication=no(( R6 R7 Rq R R: R; R< R t ssh_executableR3 t DEFAULT_SFTP_BATCH_MODER~ t verbosityt appendt ssh_argst _split_ssh_argst HOST_KEY_CHECKINGRS Rj t private_key_filet patht
expanduserRT t timeoutR t getattrRy R" t _persistentR RY R t accesst W_OKR RW Re R RU t dict( RA t binaryt
other_argsRw R| Rt t keyRU t optt attrRu Rv t cpdirt b_cpdir( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _build_command s� 0 "
1 ( ,
% .
,&c C` sv t j d � y! | j t | � � | j � Wn* t t f k
rZ t d | j � � n Xt j d t | � � d S( s�
Writes initial data to the stdin filehandle of the subprocess and closes
it. (The handle must be closed; otherwise, for example, "sftp -b -" will
just hang forever waiting for more commands.)
s Sending initial datasb SSH Error: data could not be sent to remote host "%s". Make sure this host can be reached over sshs Sent initial data (%d bytes)N(
R t debugt writeR t closeRo t IOErrorR R t len( RA t fht in_data( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _send_initial_data� s
c C` s, y | j � Wn t t f k
r' n Xd S( s& Terminate a process, ignoring errors N( t terminateRo R� ( Rp ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _terminate_process� s c
C` s� g } x\| j t � D]K} t | � j d � } t } | j j r� | j | � r� t j d | | | f � t | j
d <t } n� | j j r� | j | � r� t j d | | | f � t | j
d <t } n~ | r | j
| � r t j d | | | f � t | j
d <n? | rK| j | � rKt j d | | | f � t | j
d <n | s | j | � q q Wd
} | r�| d j d � r�| d } | d } n d
j | � | f S(
si
Takes a string, extracts complete lines from it, tests to see if they
are a prompt, error message, etc., and sets appropriate flags in self.
Prompt and success lines are removed.
Returns the processed (i.e. possibly-edited) output and the unprocessed
remainder (to be processed with the next chunk) as strings.
s
s* become_prompt: (source=%s, state=%s): '%s't
become_prompts+ become_success: (source=%s, state=%s): '%s't become_successs) become_error: (source=%s, state=%s): '%s't become_errors2 become_nopasswd_error: (source=%s, state=%s): '%s't become_nopasswd_errort i����s
( t
splitlinesR" R R! R$ R6 t promptt check_password_promptR R� t _flagst success_keyt check_become_successt check_incorrect_passwordt check_missing_passwordR� t endswithR{ (
RA t sourcet statet b_chunkt sudoablet outputt b_linet display_linet suppress_outputt remainder( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _examine_output� s2
c C` s� t t t t t | � � � } t j d j d j | � � d | j �d" } t
| t t f � rp t
| � } n t t t
| � � } | sRy� t j � \ } } t r� | j j r� t j | d | d t j d t j d | j �} n' t j | d | d t j d t j �} t j | d d � } t j | � WqRt t f k
rNd" } qRXn | s�t r�| j j r�t j | d t j d t j d t j d | j �} n* t j | d t j d t j d t j �} | j } n | j j rxt j | j d � y+ t j | j d
t
| j j � d � Wn= t k
r`}
|
j t j k sW| j � d" k ra� qan Xt j | j d
� n d d
d d g } | j! d � } t
| j" d � � | k rG| rG| j j# r�| j! d � } t j$ d | | | j j# f � qG| j j% rG| j j& rG| j! d
� } t j$ d | | | j j& f � qGn d }
} d } } t' d t( d t( d t( d t( � | _) d | j j* } xF | j+ | j, f D]2 } t- j- | t- j. t- j- | t- j/ � t j0 B� q�Wt1 j2 � } | j3 | j+ t1 j4 � | j3 | j, t1 j4 � | | d k rC| rC| j5 | | � | d
7} n zYxRt6 r�| j � } | j7 | � } | s�| | j! d
� k r�| d" k r�Pn | j8 | � t9 d | t: |
� f � � q�n x� | D]� \ } } | j; | j+ k rG| j+ j< � } | d k r | j= | j+ � d
} n | | 7} t j$ d | t | � f � q�| j; | j, k r�| j, j< � } | d k r�| j= | j, � n | | 7} t j$ d | t | � f � q�q�W| | j! d � k rC| r| j> d | | | | � \ } } |
| 7}
| } n | ra| j> d | | | | � \ } } | | 7} | } qan |
| 7}
| | 7} d } } | | d k r�| j) d r�t j$ d � | j t
| j j? � d � | j@ � t( | j) d <| d
7} q�| j) d r�| d
7} q�n | | d
k r| j) d r-t j d � t( | j) d <| d
7} q| j) d rzt j d � | j8 | � t( | j) d <t9 d | j jA � � q| j) d r�t j d � | j8 | � t( | j) d <t9 d | j jA � � q| j) d rt j d! � | j8 | � t( | j) d <t9 d | j jA � � qn | | d k rM| r@| j5 | | � n | d
7} n | d" k r}| jB � sm| rqPn d } qIqI| jB � sI| jC � PqIqIWWd" | j � | j � XtD jE r�| d d# k r�| jF d$ k r�t9 d% � � q�n d& | k p d' | k } | jF d k r* | r* t9 d( � � n d) | k } | jF d* k rZ | rZ tG d+ � � n | jF d* k r� | r� | r� tH d, | j � � n | jF |
| f S(- sL
Starts the command and communicates with it until it ends.
u
SSH: EXEC {0}u R Rf Rg Rh t pass_fdst wbi i s
t awaiting_promptt awaiting_escalationt
ready_to_sendt
awaiting_exitR� u Initial state: %s: %sR� R� R� R� R� i s9 Timeout (%ds) waiting for privilege escalation prompt: %ss" stdout chunk (state=%s):
>>>%s<<<
s" stderr chunk (state=%s):
>>>%s<<<
s) Sending become_pass in response to prompts Escalation succeededs Escalation faileds Incorrect %s passwords Escalation requires passwords Missing %s passwords Escalation prompt repeatedNR i s� Using a SSH password instead of a key is not possible because Host Key checking is enabled and sshpass does not support this. Please add this host's fingerprint to your known_hosts file to manage this host.s( Bad configuration option: ControlPersists, unknown configuration option: ControlPersists� using -c ssh on certain older ssh versions may not support ControlPersist, set ANSIBLE_SSH_ARGS="" (or ssh_args in [ssh_connection] section of the config file) before running agains4 mux_client_hello_exchange: write packet: Broken pipei� sH SSH Error: data could not be sent because of ControlPersist broken pipe.sb SSH Error: data could not be sent to remote host "%s". Make sure this host can be reached over ssh(I R9 t mapR R R R% R R{ R Rj R8 R R
R t ptyt openptyR R6 R7 Rk Rl Rm R< R: t fdopenR� Ro R� Rf R� t errnot EPIPEt pollt indext
get_optionR� R� t becomeR� R� R$ R� R� Rg Rh t fcntlt F_SETFLt F_GETFLt
O_NONBLOCKR
t DefaultSelectort registert
EVENT_READR� R" t selectR� R R t fileobjt readt
unregisterR� t become_passt flusht
become_methodt get_mapt waitR3 R� t
returncodeR R ( RA RG R� R� t checkrct display_cmdRp t mastert slaveRf RH t statesR� t b_stdoutt b_stderrt b_tmp_stdoutt b_tmp_stderrR� t fdt selectorR� t eventsR� t eventR� t b_outputt
b_unprocessedt controlpersisterrort controlpersist_broken_pipe( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _bare_run� s (3'
6* +$
! $'
0
"
$"
"
c C` s | j | | d | d | �S( s= Wrapper around _bare_run that retries the connection
R� R� ( R� ( RA RG R� R� R� ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _run� s c C` s/ d | j } g } | j j } | d k rp | d# k rF t d � � n | d k rd d d d g } q| g } n� t j } t | t � s� | j � } | t
k r� t | d t �} q� | d k r� t d � � q� n | d k r� d d d g } n! | t
k r d g } n d g } x�| D]�} d } }
} | d k r�| j | j d � t | � � } d
j | t | � t | � � }
t |
d d �}
| j | |
d
t �\ } }
} n�| d k rS| j d � } | d k r| j | d j | t | � � | � } n' | j | | d j | t | � � � } d }
| j | |
d
t �\ } }
} n� | d k rL| d k r�| j d | t f d t �\ } }
} t t | d d �d � � } | j |
� Wd QXqLt t | d d �d � � } t | j � d d �}
Wd QX|
sd } n d } | j d | t | f d |
d t �\ } }
} n | d k re| |
| f St | � d k rt j d d | | f � t j d d t |
� � t j d d t | � � qqW| d k r�t d! | t | � f � � n4 t d" t | � t | � t |
� t | � f � � d S($ Ns [%s]t smartR t scpt pipeds9 transfer_method needs to be one of [smart|sftp|scp|piped]t stricts0 scp_if_ssh needs to be one of [smart|True|False]t sftp_executableu {0} {1} {2}
R. t passthruR� t scp_executablet getu {0}:{1}s dd if=%s bs=%sR� R0 R1 s wb+t rbs count=0R� s dd of=%s bs=%s%sR� i i R* sS %s transfer mechanism failed on %s. Use ANSIBLE_DEBUG=1 to see detailed informations %si� s( Failed to connect to the host via %s: %ss' failed to transfer file to %s %s:
%s
%s( R� s sftps scpR� ( R R6 t ssh_transfer_methodRj R R3 t DEFAULT_SCP_IF_SSHR8 t boolRr R R R$ R" R� R� R R R R� t exec_commandR t openR� R� R� R t warningR� R R R ( RA t in_patht out_patht sftp_actionR t methodsR� t
scp_if_ssht methodR� Rg Rh RG R� R� t out_filet ft count( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt _file_transport_command sp
!!$ *'$ ( 4
! c
C` s� t t | � j | d | d | �t j d j | j j � d | j j �| j j } | j
d � } | r� | r� | r� | d | j | f } n | | j | f } | j | � } | j
| | d | �\ } } } | | | f S( s" run a command on the remote host R� R� u& ESTABLISH SSH CONNECTION FOR USER: {0}R t use_ttys -tt( RP RM R� R R% R R6 RT RR R� R� R R� R� (
RA RG R� R� R� R
RB R� Rg Rh ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyR� Y s "( !c C` s� t t | � j | | � t j d j | | � d | j �t j j t
| d d �� sw t d j t | � � � � n | j
| | d � S( s& transfer a file from local to remote u PUT {0} TO {1}R R0 R1 s" file or module does not exist: {0}t put( RP RM t put_fileR R% R R R: R� t existsR R R R ( RA R R ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyR u s
" c C` sN t t | � j | | � t j d j | | � d | j �| j | | d � S( s# fetch a file from remote to local u FETCH {0} TO {1}R R� ( RP RM t
fetch_fileR R% R R R ( RA R R ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyR � s "c C` sS | j | j j d d | j � } | j | � \ } } g | D] } | j d � r= | ^ q= } t } | r� t | � d k r� | d j d d � d } t j
j | � r� t } q� n | r� t } n | rEt
j d | � t j | d t j d
t j d t j �} | j � \ } }
| j � } | d k rEt
j d |
� qEn | j � d S(
Ns -Ot stops ControlPath=i t =i i����u sending stop: %sRf Rg Rh s Failed to reset connection:%s( R� R6 R� R Ry t
startswithR$ R� t splitR: R� R
R" R R% Rk Rl Rm Rn R� R� R� ( RA RG Ru Rv Rt t cp_argt run_resett cp_pathRp Rg Rh t status_code( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt reset� s$ !( * c C` s
t | _ d S( N( R$ t
_connected( RA ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyR� � s ( R R R t transportR" t has_pipeliningt frozensetR3 t BECOME_METHODSt
differencet become_methodsRQ RZ t staticmethodRj Re Rq Ry R~ R� R� R� R� R� RL R� R R� R R R R� ( ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyRM � s2
�
.� T (: t
__future__R R R t typet
__metaclass__t
DOCUMENTATIONR� R� R[ R: R� Rk R? t functoolsR t ansibleR R3 t ansible.errorsR R R R R t ansible.compatR
t ansible.module_utils.sixR R R
t ansible.module_utils.six.movesR t ansible.module_utils._textR R R t) ansible.module_utils.parsing.convert_boolR R t ansible.plugins.connectionR R t ansible.utils.pathR R t __main__R t ImportErrort ansible.utils.displayR R# Rj Ri R R- RL RM ( ( ( sB /usr/lib/python2.7/site-packages/ansible/plugins/connection/ssh.pyt <module> sB � "
1 L