ó
¡ôXc @ sX d d l Z d d l Z d d l Z d d „ Z d „ Z d „ Z d „ Z d „ Z d S( iÿÿÿÿNc C s2 d d g } | d k rš x | D]t } | d k r4 q t | t ƒ rS | j | ƒ q t | d ƒ rx | j | j ƒ ƒ q t d j t | ƒ ƒ ƒ ‚ q Wn g } d } xI t | ƒ D]; } | | k rÛ | j | | f ƒ n t
| | d ƒ } q³ W| j | d f ƒ x& | D] } t j | d | d ƒ q Wd S( Ni i t filenos* {0} must be an int or have a fileno methodi i (
t Nonet
isinstancet intt appendt hasattrR t
ValueErrort formatt reprt sortedt maxt ost
closerange( t
except_fdst except_filenost except_fdt
fileno_rangest next_range_mint
except_filenot fileno_range( ( s9 /usr/lib/python2.7/site-packages/euca2ools/bundle/util.pyt
close_all_fds s(
c C sk t j d d d | d d d f d t j ƒ} | j ƒ \ } } | j ƒ j d d ƒ d
j d d ƒ j ƒ S(
Nt opensslt x509s -ins -fingerprints -sha1s -nooutt stdoutt =i iÿÿÿÿt :t ( t
subprocesst Popent PIPEt communicatet stript rsplitt replacet lower( t
cert_filenameR t fingerprintt _( ( s9 /usr/lib/python2.7/site-packages/euca2ools/bundle/util.pyt get_cert_fingerprint9 s
c C s1 t j ƒ \ } } t j | ƒ t j | d ƒ f S( Nt w( R t pipet fdopen( t pipe_rt pipe_w( ( s9 /usr/lib/python2.7/site-packages/euca2ools/bundle/util.pyt open_pipe_fileobjsA s c C s2 t j d t d | f ƒ } t | _ | j ƒ d S( s
Start a thread that calls os.waitpid on a particular PID to prevent
zombie processes from hanging around after they have finished.
t targett argsN( t threadingt Threadt
_wait_for_pidt Truet daemont start( t pidt
pid_thread( ( s9 /usr/lib/python2.7/site-packages/euca2ools/bundle/util.pyt waitpid_in_threadF s c C s5 | r1 y t j | d ƒ Wq1 t k
r- q1 Xn d S( Ni ( R t waitpidt OSError( R5 ( ( s9 /usr/lib/python2.7/site-packages/euca2ools/bundle/util.pyR1 P s
( R R R/ R R R& R, R7 R1 ( ( ( s9 /usr/lib/python2.7/site-packages/euca2ools/bundle/util.pyt <module> s