File: //lib/python2.7/site-packages/leapp/libraries/stdlib/call.pyo
�
g��fc @ s� d d l m Z d d l Z d d l Z d d l Z d d l Z y d d l m Z Wn! e k
rw d d l m
Z n Xd d l m Z d d l
m Z m Z m Z m Z m Z d Z d Z d Z d
d d d d � Z d
� d
� d
d d d d d � Z d S( i����( t print_functionN( t which( t find_executable( t string_types( t POLL_HUPt POLL_INt POLL_OUTt POLL_PRIt EventLoopi i i s utf-8iP c s� x" � D] } | j | t t B� q W| rB | j | d t � n d } t � }
t � � | rf d n d } d � � D� } � r� d � � D� }
� f d � � D� } n � f d � } x�| j r}t |
� | k r}| j | � } x�| D]�\ } } | t k r%|
j | � | j
| � n | t t B@d k r�| | � } t j | | � } | | | f | � � r�|
| c | | j
| � 7<xP d |
| k r�|
| j d d � \ } } | |
| <| | | f | � q�Wn | | c | 7<q� | t k r� | \ } } | |
k r q� n | t j | | | � 7} | t | � k rv|
j | � | j
| � t j | � qvq� q� Wq� W� r�x? |
j � D]. \ } } | r�| | | | � f | � q�q�Wn | S( Ni i c S s i | ] } t � | � q S( ( t bytes( t .0t fd( ( s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pys
<dictcomp>- s c S s i | ] } d | � q S( t ( ( R
R ( ( s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pys
<dictcomp>/ s c s% i | ] } t j � � � | � q S( ( t codecst getincrementaldecoder( R
R ( t encoding( s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pys
<dictcomp>0 s c s � j | � d S( s�
File descriptors passed via `read_fds` are always representing [stdout, stderr],
since arrays start at index 0, we need to add 1 to get the real symbolic value
`STDOUT` or `STDERR`.
i ( t index( R ( t read_fds( s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pyt _get_fd_type2 s s
( t registerR R R t sett lent closedt pollR t addt
unregistert ost readt decodet splitt writet closet items( t epR t callback_rawt callback_linebufferedR R t timeoutt buffer_sizeR t offsett huppedt num_expectedt buft linebufst decodersR t eventst eventt fd_typeR t pret postt wfdt datat lb( ( R R s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pyt
_multiplex sV
#c C s d S( N( t None( R t value( ( s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pyt <lambda>b s c C s� t | t t f � s$ t d � � n t | � sU t | d d � rd | j j d k rd t d � � n t | � s� t | d d � r� | j j d k r� t d � � n t | t � s� t | t
� s� | d k r� t d � � n t | t � s t | t
� s | d k rt d � � n t j
j � } | r[t | t � sKt d � � n | j | � n | j d
d � } t | d d | �s�t t j t j t j � | d � � n t j � \ }
} t j � \ } }
d \ } } t t } } t | t � r t } nT t | t � r*t } t j � \ } } n* | d k rTt d j t | � � � � n t j � } | d k r�t � } t j | � t j |
� i } | r�| | j | � f | d
<t j | � n t! | |
| g | | d | d | d | | �} t j" � \ } } | j � t j |
� t j | � | d @| d ?d @} } i | d 6| d 6| d 6} | s�| j i | |
d 6| | d 6� n5 | j i | |
j# | � d 6| | j# | � d 6� | S| d k r�| r�t j$ | t% � n | rt j | � t j$ | t% � n t j |
� t j | � t j$ | t& � t j$ |
t' � y t j( | d | d | �Wq�t k
r�} t) j* j+ d j | d t, | � � � t j- d � q�Xn d S( s�
:param command: The command to execute
:type command: list, tuple
:param encoding: Decode output or encode input using this encoding
:type encoding: str
:param poll_timeout: Timeout used by epoll to wait certain amount of time for activity on file descriptors
:type poll_timeout: int
:param read_buffer_size: How much data are we going to read from the file descriptors each iteration.
The default value of 80 chosen to correspond with suggested terminal line width
:type read_buffer_size: int
:param callback_raw: Callback executed on raw data (before decoding) as they are read from file descriptors
:type callback_raw: ((fd: int, fd_type: int), buffer: bytes) -> None
:param callback_linebuffered: Callback executed on decoded lines as they are read from the file descriptors
:type callback_linebuffered: ((fd: int, fd_type: int), value: str) -> None
:param stdin: String or a file descriptor that will be written to stdin of the child process
:type stdin: int, str
:param env: Environment variables to use for execution of the command
:type env: dict
:return: {'stdout' : stdout, 'stderr': stderr, 'signal': signal, 'exit_code': exit_code, 'pid': pid}
:rtype: dict
:raises: OSError if an executable is missing or has wrong permissions
:raises: CalledProcessError if the cmd has non-zero exit code and `checked` is False
:raises: TypeError if any input parameters have an invalid type
:raises: valueError if any of input parameters have an invalid value
s+ command parameter has to be a list or tuplet __code__i s@ callback_raw parameter has to be callable accepting 2 parameterssI callback_linebuffered parameter has to be callable accepting 2 parametersi s: poll_timeout parameter has to be integer greater than zeros> read_buffer_size parameter has to be integer greater than zeros$ env parameter has to be a dictionaryt PATHt paths> stdin has to be either a file descriptor or string, not "{!s}"R R$ R% R i� i t signalt exit_codet pidt stdoutt stderrt envs Error: Cannot execute {}: {}
i N( NN(. t
isinstancet listt tuplet TypeErrort callablet getattrR5 R8 t co_argcountt intt boolt
ValueErrorR t environt copyt dictt updatet getR t OSErrort errnot ENOENTt strerrort pipet Falset TrueR t formatt typet forkR R t encodeR4 t waitR t dup2t STDINt STDOUTt STDERRt execvpet sysR? R t strt _exit( t commandR" R# R t poll_timeoutt read_buffer_sizet stdinR@ RK t _pathR> t wstdoutR? t wstderrt fstdint wstdint stdin_fdt stdin_strR= R! t extraR t statusR; R< t rett e( ( s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pyt _callb s�
$ ++(
&( t
__future__R R
RQ R Ra t shutilR t ImportErrort distutils.spawnR t leapp.compatR t leapp.libraries.stdlib.eventloopR R R R R R] R^ R_ R5 R4 Rs ( ( ( s? /usr/lib/python2.7/site-packages/leapp/libraries/stdlib/call.pyt <module> s
(I