Viewing File: /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyc
ó
¡ôXc @ s¬ 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 „ Z d e
d „ Z d e
d „ Z d d „ Z
d e
d „ Z d e
d „ Z d S( iÿÿÿÿNc C sL t j d t d | f d i | d 6ƒ } | j ƒ t j j j | j ƒ d S( Nt targett argst kwargst
out_mpconn( t multiprocessingt Processt _delete_part_filest startt euca2oolst bundlet utilt waitpid_in_threadt pid( t in_mpconnR t del_p( ( sC /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyt create_bundle_part_deleter$ s
c C sˆ t j d t ƒ \ } } t j d t d | | | | f d i | d 6| d 6ƒ } | j ƒ | j ƒ | j ƒ t j j j
| j ƒ | S( Nt duplexR R R t part_write_semt debug( R t Pipet FalseR t _write_partsR t closeR R R
R R ( t infilet part_prefixt part_sizeR R t partinfo_result_rt partinfo_result_wt writer_p( ( sC /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyt create_bundle_part_writer, s
c C sx t j d t ƒ \ } } t j d t d | | f d i | d 6| d 6ƒ } | j ƒ | j ƒ t j j j
| j ƒ | S( NR R R R R R ( R R R R t _aggregate_mpconn_itemsR R R R R
R R ( R
R R t result_mpconn_rt result_mpconn_wt agg_p( ( sC /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyt create_mpconn_aggregator; s
c C s© t j j j d | | f ƒ zb yI xB t rf | j ƒ } t j | j ƒ | d k r% | j
| ƒ q% q% WWn t k
r| d SXWd | j ƒ | d k r¤ | j ƒ n Xd S( Nt
except_fds(
R R R
t
close_all_fdst Truet recvt ost unlinkt filenamet Nonet sendt EOFErrorR ( R
R t part( ( sC /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyR F s
c C s t j j j d | | | f ƒ g } z yF x? t rl | j ƒ } | j | ƒ | d k r. | j | ƒ q. q. WWn` t k
r³ y | j | ƒ WqÑ t
k
r¯ | s© d S‚ qÑ Xn t
k
rÐ | sÊ d S‚ n XWd | j ƒ | j ƒ | d k r| j ƒ n Xd S( NR# ( R R R
R$ R% R& t appendR* R+ R, t IOErrorR ( R
t
result_mpconnR R t resultst next_result( ( sC /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyR V s2
c C sö | | g } | d k rw t j d k rw y | j t | j j ƒ ƒ Wqw t k
r] d } qw t k
rs d } qw Xn t j
j j d | ƒ xbt
j ƒ D]T} | d k r¹ | j ƒ n d j | | ƒ } t j ƒ } t | d ƒ â }
d } | } xž | d k r•y | j t | t j ƒ ƒ }
Wn( t k
rM| sG| j ƒ d S‚ n X|
r‘|
j |
ƒ | j |
ƒ | t |
ƒ 8} | t |
ƒ 7} qø Pqø Wt j
j | | j ƒ d | ƒ } | j | ƒ Wd QX| | k rš | j ƒ | j ƒ d Sqš Wd S( Nt darwinR# s {0}.part.{1:02}t wi t SHA1( R* t syst platformR. t intt _semlockt handlet AttributeErrort
ValueErrorR R R
R$ t itertoolst countt acquiret formatt hashlibt sha1t opent readt mint BUFSIZER t writet updatet lent
BundlePartt hexdigestR+ ( R R R t partinfo_mpconnR R R# t part_not
part_fnamet part_digestR- t
bytes_writtent bytes_to_writet chunkt partinfo( ( sC /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyR u sL
( RA R= R R' R6 t euca2ools.bundle.pipesR t euca2ools.bundle.utilR* R R R R" R R R ( ( ( sC /usr/lib/python2.7/site-packages/euca2ools/bundle/pipes/fittings.pyt <module> s
Back to Directory
File Manager