File: //lib/python2.7/site-packages/s3transfer/utils.pyc
�
P$�_c @ sv 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 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 d d l m Z d d l m Z d d l m Z d d l m Z d Z d
d- Z d
d. Z e j e � Z e j e e e f Z d d � Z d � Z d � Z d � Z d d � Z" d � Z# d � Z$ d � Z% d e& f d � � YZ' d e& f d � � YZ( d e& f d � � YZ) d e& f d � � YZ* d e& f d � � YZ+ d! e& f d" � � YZ, d# e& f d$ � � YZ- d% e. f d& � � YZ/ d' e& f d( � � YZ0 d) e0 f d* � � YZ1 d+ e& f d, � � YZ2 d S(/ i����N( t defaultdict( t IncompleteReadError( t ReadTimeoutError( t SOCKET_ERROR( t rename_file( t seekable( t fallocatei' i i i i i c C s d j d � t | � D� � S( Nt c s s! | ] } t j t j � Vq d S( N( t randomt choicet stringt hexdigits( t .0t _( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pys <genexpr>2 s ( t joint range( t
num_digits( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt random_file_extension1 s c K s2 | d k r. t | j d � r. | j j � n d S( Nt PutObjectt
UploadPartt signal_not_transferring( R R ( t hasattrt bodyR ( t requestt operation_namet kwargs( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR 5 s c K s2 | d k r. t | j d � r. | j j � n d S( NR R t signal_transferring( s PutObjects
UploadPart( R R R ( R R R ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR ; s c C s t t j | t | � � � S( N( t intt matht ceilt float( t sizet part_size( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt calculate_num_partsA s c C sd | | } | | d k rB d } | d k rP t | d � } qP n | | d } d | | f } | S( s� Calculate the range parameter for multipart downloads/copies
:type part_size: int
:param part_size: The size of the part
:type part_index: int
:param part_index: The index for which this parts starts. This index starts
at zero
:type num_parts: int
:param num_parts: The total number of parts in the transfer
:returns: The value to use for Range parameter on downloads or
the CopySourceRange parameter for copies
i R s bytes=%s-%sN( t Nonet str( R t
part_indext num_partst
total_sizet start_ranget end_ranget range_param( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt calculate_range_parameterE s
c C se g } xX | j j j D]G } d | } t | | � r | j t j t | | � d | �� q q W| S( s Retrieves callbacks from a subscriber
:type transfer_future: s3transfer.futures.TransferFuture
:param transfer_future: The transfer future the subscriber is associated
to.
:type callback_type: str
:param callback_type: The type of callback to retrieve from the subscriber.
Valid types include:
* 'queued'
* 'progress'
* 'done'
:returns: A list of callbacks for the type specified. All callbacks are
preinjected with the transfer future.
t on_t future( t metat call_argst subscribersR t appendt functoolst partialt getattr( t transfer_futuret
callback_typet callbackst
subscribert
callback_name( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt
get_callbacksb s
c C s+ | r' x | D] } | d | � q
Wn d S( s� Calls all progress callbacks
:param callbacks: A list of progress callbacks to invoke
:param bytes_transferred: The number of bytes transferred. This is passed
to the callbacks. If no bytes were transferred the callbacks will not
be invoked because no progress was achieved. It is also possible
to receive a negative amount which comes from retrying a transfer
request.
t bytes_transferredN( ( R6 R: t callback( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt invoke_progress_callbacks� s
c C s@ i } x3 | j � D]% \ } } | | k r | | | <q q W| S( so Gets a dictionary filtered by whitelisted keys
:param original_dict: The original dictionary of arguments to source keys
and values.
:param whitelisted_key: A list of keys to include in the filtered
dictionary.
:returns: A dictionary containing key/values from the original dictionary
whose key was included in the whitelist
( t items( t
original_dictt whitelisted_keyst
filtered_dictt keyt value( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt get_filtered_dict� s
t CallArgsc B s e Z d � Z RS( c K s1 x* | j � D] \ } } t | | | � q
Wd S( s� A class that records call arguments
The call arguments must be passed as keyword arguments. It will set
each keyword argument as an attribute of the object along with its
associated value.
N( R= t setattr( t selfR t argRB ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt __init__� s ( t __name__t
__module__RH ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRD � s t FunctionContainerc B s) e Z d Z d � Z d � Z d � Z RS( s� An object that contains a function and any args or kwargs to call it
When called the provided function will be called with provided args
and kwargs.
c O s | | _ | | _ | | _ d S( N( t _funct _argst _kwargs( RF t funct argsR ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH � s c C s d | j | j | j f S( Ns' Function: %s with args %s and kwargs %s( RL RM RN ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt __repr__� s c C s | j | j | j � S( N( RL RM RN ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt __call__� s ( RI RJ t __doc__RH RQ RR ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRK � s t CountCallbackInvokerc B sA e Z d Z d � Z e d � � Z d � Z d � Z d � Z RS( s� An abstraction to invoke a callback when a shared count reaches zero
:param callback: Callback invoke when finalized count reaches zero
c C s. t j � | _ | | _ d | _ t | _ d S( Ni ( t threadingt Lockt _lockt _callbackt _countt Falset
_is_finalized( RF R; ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH � s c C s | j � | j SWd QXd S( N( RW RY ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt
current_count� s
c C s; | j �, | j r" t d � � n | j d 7_ Wd QXd S( s Increment the count by ones; Counter has been finalized it can no longer be incremented.i N( RW R[ t RuntimeErrorRY ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt increment� s
c C sf | j �W | j d k r( t d � � n | j d 8_ | j r\ | j d k r\ | j � n Wd QXd S( s Decrement the count by onei s, Counter is at zero. It cannot dip below zeroi N( RW RY R] R[ RX ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt decrement� s
c C s9 | j �* t | _ | j d k r/ | j � n Wd QXd S( s� Finalize the counter
Once finalized, the counter never be incremented and the callback
can be invoked once the count reaches zero
i N( RW t TrueR[ RY RX ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt finalize� s
( RI RJ RS RH t propertyR\ R^ R_ Ra ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRT � s
t OSUtilsc B sb e Z d Z d � Z d � Z d
d � Z d � Z d � Z d � Z d � Z
d � Z d � Z RS( i� c C s t j j | � S( N( t ost patht getsize( RF t filename( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt
get_file_size� s c C s t j | | | | d t �S( Nt enable_callbacks( t
ReadFileChunkt
from_filenameRZ ( RF Rg t
start_byteR R6 ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt open_file_chunk_reader� s c
C s" t | | | d | d t d | �S( NR6 Ri t close_callbacks( Rj RZ ( RF t fileobjt
chunk_sizet full_file_sizeR6 Rn ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt# open_file_chunk_reader_from_fileobj� s c C s
t | | � S( N( t open( RF Rg t mode( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRs s c C s) y t j | � Wn t k
r$ n Xd S( s+ Remove a file, noop if file does not exist.N( Rd t removet OSError( RF Rg ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt remove_file s
c C s t | | � d S( N( R ( RF t current_filenamet new_filename( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR s c C sx t j j | � s t St j | � j } t j | � r; t St j | � rN t St j | � ra t St j
| � rt t St S( s Checks to see if a file is a special UNIX file.
It checks if the file is a character special device, block special
device, FIFO, or socket.
:param filename: Name of the file
:returns: True if the file is a special file. False, if is not.
( Rd Re t existsRZ t statt st_modet S_ISCHRR` t S_ISBLKt S_ISFIFOt S_ISSOCK( t clsRg Rt ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt is_special_file s c C sb t j t � } t j j | � } t j j | � } | | j t | � | } t j j | | � S( N( Rd t extsepR Re t dirnamet basenamet _MAX_FILENAME_LENt lenR ( RF Rg t suffixRe t namet
temp_filename( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt get_temp_filename0 s
c C sZ y, | j | d � � } t | | � Wd QXWn' t t f k
rU | j | � � n Xd S( Nt wb( Rs R Rv t IOErrorRw ( RF Rg R t f( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt allocate7 s
N(
RI RJ R� Rh Rm R" Rr Rs Rw R R� R� R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRc � s t DeferredOpenFilec B st e Z d d e d � Z d � Z e d � � Z d d � Z d � Z d � Z
d � Z d � Z d
� Z
d � Z RS(
i t rbc C s1 | | _ d | _ | | _ | | _ | | _ d S( s� A class that defers the opening of a file till needed
This is useful for deferring opening of a file till it is needed
in a separate thread, as there is a limit of how many open files
there can be in a single thread for most operating systems. The
file gets opened in the following methods: ``read()``, ``seek()``,
and ``__enter__()``
:type filename: str
:param filename: The name of the file to open
:type start_byte: int
:param start_byte: The byte to seek to when the file is opened.
:type mode: str
:param mode: The mode to use to open the file
:type open_function: function
:param open_function: The function to use to open the file
N( t _filenameR" t _fileobjt _start_bytet _modet _open_function( RF Rg Rl Rt t
open_function( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH A s
c C sV | j d k rR | j | j | j � | _ | j d k rR | j j | j � qR n d S( Ni ( R� R" R� R� R� R� t seek( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt _open_if_needed\ s c C s | j S( N( R� ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� b s c C s | j � | j j | � S( N( R� R� t read( RF t amount( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� f s
c C s | j � | j j | � d S( N( R� R� t write( RF t data( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� j s
c C s | j � | j j | � d S( N( R� R� R� ( RF t where( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� n s
c C s# | j d k r | j S| j j � S( N( R� R" R� t tell( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� r s c C s | j r | j j � n d S( N( R� t close( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� w s c C s | j � | S( N( R� ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt __enter__{ s
c O s | j � d S( N( R� ( RF RP R ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt __exit__ s N( RI RJ Rs RH R� Rb R� R" R� R� R� R� R� R� R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� @ s Rj c B s� e Z d e d d � Z e d e d � � Z d � Z d d � Z d � Z d � Z
d � Z d � Z d � Z
d � Z d
� Z d � Z d � Z d
� Z d � Z RS( c C s� | | _ | j j � | _ | j | j d | d | j d | �| _ d | _ | | _ | d k ro g | _ n | | _ | | _ | d k r� | | _ n d S( s�
Given a file object shown below::
|___________________________________________________|
0 | | full_file_size
|----chunk_size---|
f.tell()
:type fileobj: file
:param fileobj: File like object
:type chunk_size: int
:param chunk_size: The max chunk size to read. Trying to read
pass the end of the chunk size will behave like you've
reached the end of the file.
:type full_file_size: int
:param full_file_size: The entire content length associated
with ``fileobj``.
:type callbacks: A list of function(amount_read)
:param callbacks: Called whenever data is read from this object in the
order provided.
:type enable_callbacks: boolean
:param enable_callbacks: True if to run callbacks. Otherwise, do not
run callbacks
:type close_callbacks: A list of function()
:param close_callbacks: Called when close is called. The function
should take no arguments.
t requested_sizeRl t actual_file_sizei N(
R� R� R� t _calculate_file_sizet _sizet _amount_readt
_callbacksR" t _callbacks_enabledt _close_callbacks( RF Ro Rp Rq R6 Ri Rn ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH � s # c C sJ t | d � } | j | � t j | j � � j } | | | | | | � S( s[ Convenience factory function to create from a filename.
:type start_byte: int
:param start_byte: The first byte from which to start reading.
:type chunk_size: int
:param chunk_size: The max chunk size to read. Trying to read
pass the end of the chunk size will behave like you've
reached the end of the file.
:type full_file_size: int
:param full_file_size: The entire content length associated
with ``fileobj``.
:type callbacks: function(amount_read)
:param callbacks: Called whenever data is read from this object.
:type enable_callbacks: bool
:param enable_callbacks: Indicate whether to invoke callback
during read() calls.
:rtype: ``ReadFileChunk``
:return: A new instance of ``ReadFileChunk``
R� ( Rs R� Rd t fstatt filenot st_size( R� Rg Rl Rp R6 Ri R� t file_size( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRk � s
c C s | | } t | | � S( N( t min( RF Ro R� Rl R� t max_chunk_size( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s
c C s� | d k r | j | j } n t | j | j | � } | j j | � } | j t | � 7_ | j d k r� | j r� t | j t | � � n | S( N(
R" R� R� R� R� R� R� R� R� R< ( RF R� t amount_to_readR� ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s c C s0 | j � t | j d � r, | j j � n d S( NR ( t enable_callbackR R� R ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR � s
c C s0 | j � t | j d � r, | j j � n d S( NR ( t disable_callbackR R� R ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR � s
c C s
t | _ d S( N( R` R� ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s c C s
t | _ d S( N( RZ R� ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s c C sY | j j | j | � | j d k rL | j rL t | j d | | j �n | | _ d S( NR: ( R� R� R� R� R" R� R< R� ( RF R� ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s
c C sG | j d k r6 | j r6 x | j D]
} | � q" Wn | j j � d S( N( R� R" R� R� R� ( RF R; ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s c C s | j S( N( R� ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� s c C s | j S( N( R� ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt __len__ s c C s | S( N( ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� s c O s | j � d S( N( R� ( RF RP R ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� s c C s
t g � S( N( t iter( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt __iter__ s N( RI RJ R" R` RH t classmethodRk R� R� R R R� R� R� R� R� R� R� R� R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRj � s" 0 t StreamReaderProgressc B s# e Z d Z d d � Z d � Z RS( s< Wrapper for a read only stream that adds progress callbacks.c C s. | | _ | | _ | d k r* g | _ n d S( N( t _streamR� R" ( RF t streamR6 ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH s c O s/ | j j | | � } t | j t | � � | S( N( R� R� R< R� R� ( RF RP R RB ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� & s N( RI RJ RS R" RH R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� s t NoResourcesAvailablec B s e Z RS( ( RI RJ ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� , s t
TaskSemaphorec B s& e Z d � Z e d � Z d � Z RS( c C s t j | � | _ d S( sq A semaphore for the purpose of limiting the number of tasks
:param count: The size of semaphore
N( RU t Semaphoret
_semaphore( RF t count( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH 1 s c C s9 t j d | � | j j | � s5 t d | � � n d S( s� Acquire the semaphore
:param tag: A tag identifying what is acquiring the semaphore. Note
that this is not really needed to directly use this class but is
needed for API compatibility with the SlidingWindowSemaphore
implementation.
:param block: If True, block until it can be acquired. If False,
do not block and raise an exception if cannot be aquired.
:returns: A token (can be None) to use when releasing the semaphore
s Acquiring %ss Cannot acquire tag '%s'N( t loggert debugR� t acquireR� ( RF t tagt blocking( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� 8 s c C s( t j d | | f � | j j � d S( st Release the semaphore
:param tag: A tag identifying what is releasing the semaphore
:param acquire_token: The token returned from when the semaphore was
acquired. Note that this is not really needed to directly use this
class but is needed for API compatibility with the
SlidingWindowSemaphore implementation.
s Releasing acquire %s/%sN( R� R� R� t release( RF R� t
acquire_token( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� H s ( RI RJ RH R` R� R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� 0 s t SlidingWindowSemaphorec B s5 e Z d Z d � Z d � Z e d � Z d � Z RS( s� A semaphore used to coordinate sequential resource access.
This class is similar to the stdlib BoundedSemaphore:
* It's initialized with a count.
* Each call to ``acquire()`` decrements the counter.
* If the count is at zero, then ``acquire()`` will either block until the
count increases, or if ``blocking=False``, then it will raise
a NoResourcesAvailable exception indicating that it failed to acquire the
semaphore.
The main difference is that this semaphore is used to limit
access to a resource that requires sequential access. For example,
if I want to access resource R that has 20 subresources R_0 - R_19,
this semaphore can also enforce that you only have a max range of
10 at any given point in time. You must also specify a tag name
when you acquire the semaphore. The sliding window semantics apply
on a per tag basis. The internal count will only be incremented
when the minimum sequence number for a tag is released.
c C sR | | _ t t � | _ i | _ t j � | _ t j | j � | _ i | _
d S( N( RY R R t _tag_sequencest _lowest_sequenceRU RV RW t Conditiont
_conditiont _pending_release( RF R� ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH k s c C s | j � | j SWd QXd S( N( RW RY ( RF ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR\ u s
c C s� t j d | � | j j � z� | j d k rn | sH t d | � � qn x# | j d k rj | j j � qK Wn | j | } | d k r� | | j | <n | j | c d 7<| j d 8_ | SWd | j j � Xd S( Ns Acquiring %si s Cannot acquire tag '%s'i (
R� R� R� R� RY R� t waitR� R� R� ( RF R� R� t sequence_number( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� y s
c C s� | } t j d | | � | j j � zP| | j k rK t d | � � n | j | } | j | | k r| j | c d 7<| j d 7_ | j j � | j j
| g � } x� | r| j | | d k r� | j � | j | c d 7<| j d 7_ q� Pq� Wno | j | | k o$| k n r_| j j | g � j
| � | j | j d t � n t d | | f � � Wd | j j � Xd S( Ns Releasing acquire %s/%ss$ Attempted to release unknown tag: %si i����t reverses; Attempted to release unknown sequence number %s for tag: %s( R� R� R� R� R� t
ValueErrorR� RY t notifyR� t gett popt
setdefaultR0 t sortR` R� ( RF R� R� R� t max_sequencet queued( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s4
# ( RI RJ RS RH R\ R` R� R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� U s
t ChunksizeAdjusterc B s8 e Z e e e d � Z d d � Z d � Z d � Z RS( c C s | | _ | | _ | | _ d S( N( t max_sizet min_sizet max_parts( RF R� R� R� ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyRH � s c C s4 | } | d k r' | j | | � } n | j | � S( s� Get a chunksize close to current that fits within all S3 limits.
:type current_chunksize: int
:param current_chunksize: The currently configured chunksize.
:type file_size: int or None
:param file_size: The size of the file to upload. This might be None
if the object being transferred has an unknown size.
:returns: A valid chunksize that fits within configured limits.
N( R" t _adjust_for_max_partst _adjust_for_chunksize_limits( RF t current_chunksizeR� t chunksize( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt adjust_chunksize� s c C sh | | j k r0 t j d | j | f � | j S| | j k r` t j d | j | f � | j S| Sd S( Ns@ Chunksize greater than maximum chunksize. Setting to %s from %s.s= Chunksize less than minimum chunksize. Setting to %s from %s.( R� R� R� R� ( RF R� ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s c C s� | } t t j | t | � � � } x< | | j k rc | d 9} t t j | t | � � � } q( W| | k r� t j d | | f � n | S( Ni s[ Chunksize would result in the number of parts exceeding the maximum. Setting to %s from %s.( R R R R R� R� R� ( RF R� R� R� R% ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s
# N(
RI RJ t MAX_SINGLE_UPLOAD_SIZEt MIN_UPLOAD_CHUNKSIZEt MAX_PARTSRH R" R� R� R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyR� � s
i @i (3 R t timeR1 R Rd t socketR{ R
t loggingRU t iot collectionsR t botocore.exceptionsR R t s3transfer.compatR R R R R� R� R� t getLoggerRI R� t timeoutt S3_RETRYABLE_DOWNLOAD_ERRORSR R R R! R" R* R9 R< RC t objectRD RK RT Rc R� Rj R� t ExceptionR� R� R� R� ( ( ( s4 /usr/lib/python2.7/site-packages/s3transfer/utils.pyt <module>
sR
0OC�%_