/usr/lib/python2.6/site-packages/swiftclient
Edit: /usr/lib/python2.6/site-packages/swiftclient/client.pyc (54983B)
;vVc " @ s d Z d d k Z d d k Z d d k Z d d k Z d d k l Z d d k l Z l Z d d k
l Z d d k l
Z d d k l Z l Z d d k l Z l Z d d k Z d d k l Z d d
k l Z d d k l Z l Z l Z d e _ dA Z dB Z dC Z e! d dD D Z" y d d k l# Z# Wn, e$ j
o d e i% f d YZ# n Xe e i& e d j o, d d k' l( Z( d Z) e) e i* i+ _, n e i- d Z. e. i/ e# d! Z0 d" d# Z
d$ Z1 d% Z2 d& e3 f d' YZ4 d( e3 f d) YZ5 d* Z6 d+ Z7 d, Z8 d- Z9 d. Z: d/ Z; d0 Z< d d d d d e> d d1 Z? d d d2 Z@ d d d d3 ZA d d d d d d d e> d d4 ZB d d d d5 ZC d d d d d6 ZD d d d d7 ZE d d d d8 ZF d d d d d d d9 ZG d d d: ZH d d d d d d d d d d d d d d d; ZI d d d d< ZJ d d d d d d d d d d= ZK d> ZL d? e3 f d@ YZM d S(E s0
OpenStack Swift client library used internally
iN( t
StrictVersion( t RequestExceptiont SSLError( t http_client( t quote( t urlparset
urlunparse( t sleept time( t version( t ClientException( t
LengthWrappert ReadableToIterablet parse_api_responsei s 1.0t 1i s 2.0t 2i s 3.0t 3i c c s x | ] } d | Vq Wd S( s
x-%s-meta-N( ( t .0t type_( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pys
+ s t containert accountt object( t NullHandlerR c B s# e Z d Z d Z d Z RS( c C s d S( N( ( t selft record( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt handle2 s c C s d S( N( ( R R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt emit5 s c C s
d | _ d S( N( t Nonet lock( R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt
createLock8 s ( t __name__t
__module__R R R ( ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR 1 s s 2.0.0( t CaseInsensitiveDictc C s* | o t | | _ n
t | _ d S( N( R t headers( R R! ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt prepare_unicode_headers@ s t swiftclientc C sO t i t i p d Sd g } x_ | D]W } | d j o | i d q( | d j o | i d | q( | i d | q( Wd | j o> x; | d D]+ } d
| | d | f } | i | q Wn | i d j o
t i } n
t i } | d d
i | | d | i | i | d | i
| o | d | n d S( Ns curl -it HEADs -It GETt POSTt PUTs -X %ss %sR! s -H "%s: %s"i, s REQ: %st s RESP STATUS: %s %ss RESP HEADERS: %ss
RESP BODY: %s( s GETs POSTs PUT( t loggert isEnabledFort loggingt INFOt appendt statust debugt infot joint reasont
getheaders( t argst kwargst respt bodyt string_partst elementt headert
log_method( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt http_logK s.
t /c C sM t i o t | d | St | } t | t o t | | S| Sd S( s
Patched version of urllib.quote that encodes utf8 strings before quoting.
On Python 3, call directly urllib.parse.quote().
t safeN( t sixt PY3t _quotet encode_utf8t
isinstancet bytes( t valueR> ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR j s
c C s* t | t i o | i d } n | S( Nt utf8( RC R? t text_typet encode( RE ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyRB x s c C s| h } xo | i D]a \ } } t | } | i } t | t i o | i t o t | } n | | | /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt encode_meta_headers~ s
t _ObjectBodyc B s> e Z d Z d Z d d Z d Z d Z d Z RS( s=
Readable and iterable object body response wrapper.
c C s | | _ | | _ d S( s
Wrap the underlying response
:param resp: the response to wrap
:param chunk_size: number of bytes to return each iteration/next call
N( R6 t
chunk_size( R R6 RQ ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt __init__ s c C s | i i | S( N( R6 t read( R t length( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyRS s c C s | S( N( ( R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt __iter__ s c C s- | i i | i } | p
t n | S( N( R6 RS RQ t
StopIteration( R t buf( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt next s
c C s
| i S( N( RX ( R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt __next__ s N( R R t __doc__RR R RS RU RX RY ( ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyRP s
t HTTPConnectionc B sY e Z d d e e d d d Z d Z d d d d Z d d d d Z d Z RS( c C sc | | _ t | | _ | i i | _ | i i | _ h | _ t i | _ d | i _ | i i d j o t
d | i i | f n | | i d <| o | o | | i d ". This
may be overridden on a per-request basis by
explicitly setting the user-agent header on
a call to request().
:param timeout: socket read timeout value, passed directly to
the requests library.
:raises ClientException: Unable to handle protocol scheme
t httpt httpss# Unsupported scheme "%s" in url "%s"t verifys Proxy's missing schemes %s://%st proxiest streams python-swiftclient-%st timeoutN( s https https( t urlR t
parsed_urlt netloct hostt portt
requests_argst requestst Sessiont request_sessionR R! t schemeR
t Truet swiftclient_versiont version_stringt default_user_agent( R Rb t proxyt cacertt insecuret ssl_compressionRo Ra t proxy_parsed( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyRR s4
%
c O s | i i | | S( s< Final wrapper before requests call, to be patched in tests ( Rj t request( R t argt kwarg( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt _request s c
C s | d j o
h } n
t | } d | j o | i | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyRu s
c C s | i d | | | | S( s
Use python-requests files upload
:param data: Use data generator for chunked-transfer
:param files: Use files for default transfer
R' ( Ru ( R R| Ry R! Rz ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt
putrequest s c s| i i i _ i i i f d } d f d } f d } | i _ | i _ | i _ i S( s. Adapt requests response to httplib interface c s i i i S( N( R6 R! RI ( ( R ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR3 s c s | i | S( N( RJ ( t kt v( t
old_getheader( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt getheader s c s4 i i i | | } | p i i n | S( N( R6 t rawRS t close( R4 R5 t chunk( R ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt releasing_read s N( R6 t status_codeR. R R R R3 RS ( R R3 R R ( ( R R s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt getresponse s N( R R R t FalseRR Rx Ru R} R ( ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR[ s 9 c O s t | | } | i | f S( s4 :returns: tuple of (parsed url, connection object) ( R[ Rc ( Rv Rw t conn( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt http_connection# s c K s | i d d } | i d t } | i d d } t | d | d | d | \ } } d }
| i |
| i d h | d 6| d 6 | i } | i } t | |
f h | | | i d } | i
d j p | i
d
j p | oE | o= t d d | i d
| i
d | i d | i
d | i n | o: t t | } | d }
d |
| d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt get_auth_1_0) s. /
c K s* | i h d d 6 t | | | | | S( Ns 2.0t auth_version( t updatet get_auth_keystone( t auth_urlR R t
os_optionsR5 ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt get_keystoneclient_2_0H s c C s yh | t j o d d k l } n d d k l } d d k l } t i d i t | | f SWn t
j
o t d n Xd S( Ni( t client( t
exceptionst keystoneclients
Auth versions 2.0 and 3 require python-keystoneclient, install it or use Auth
version 1.0 which requires ST_AUTH, ST_USER, and ST_KEY environment
variables to be set or overridden with -A, -U, or -K.( t AUTH_VERSIONS_V3t keystoneclient.v3R t keystoneclient.v2_0R R R+ t getLoggert
addHandlerR t ImportErrorR
( R t ksclientR ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt _import_keystone_clientO s
c $ K s1 | i d t } | i d d } | i d d } t i t i o t p t } t | \ } }
y | i d | d | d | i d d | i d d | i d d
| i d
d | i d d | i d d
| i d
d | i d d | i d d | d | i d d | d | d | } Wnf |
i
j
o0 d } | t j o
d } n t | n) |
i
j
o }
t d |
n X| i d p d } | i d p d } y4 | i i d d d | i d d | d | } Wn& |
i j
o t d | n X| | i f S( sr
Authenticate against a keystone server.
We are using the keystoneclient library for authentication.
Rr Ra R s 2.0t usernamet passwordt tenant_namet tenant_idt user_idt user_domain_namet user_domain_idt project_namet
project_idt project_domain_namet project_domain_idR/ Rq R s: Unauthorized. Check username, password and tenant name/id.sY Unauthorized. Check username/id, password, tenant name/id and user/tenant domain name/id.s Authorization Failure. %st service_types object-storet
endpoint_typet publicURLt attrt regiont filter_valuet region_names8 Endpoint for %s not found - have you specified a region?N( R R R R) R* R+ t DEBUGRl R t Clientt UnauthorizedR R
t AuthorizationFailuret service_catalogt url_fort EndpointNotFoundt
auth_token( R R R R R5 Rr Ra R R/ R R t _ksclientt msgt errR R t endpoint( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR b sP
c
K s | i d d } | i d h } d \ } } | i d d } | i d t } | i d d }
| t j o: t | | | | i d d | d | d |
\ } } n*| t t j o| o; | i d o* d | j o | i d \ | d <} n | i d o | d | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt get_auth sH
%
c C sl | d j o[ h } x* | i D] \ } } | | | i /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt store_response s
c C s | p t | } n | o t | | | | | | | } | d }
xX |
oP |
d d } t | | | | | | | d }
|
o | d i |
qI qI W| S| \ } } d }
| o |
d t | 7}
n | o |
d | 7}
n | o |
d t | 7}
n | o |
d t | 7}
n d | i |
f } h | d
6} | o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s\
*
c
C s< | o | \ } } n t | \ } } d } h | d 6} | o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt head_account2 s*
c C s | o | \ } } n t | \ } } d } | | d <| o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt post_accountV s(
c C s: | p t | } n |
o t | | | | | | | | | | | } | d }
x |
o | p |
d d } n$ |
d i d |
d i d } t | | | | | | | | | | | d }
|
o | d i |
qU qU W| S| \ } } d | i t | f } d } | o | d t | 7} n | o | d | 7} n | o | d t | 7} n | o | d
t | 7} n | o | d t | 7} n | o | d t | 7} n h | d
6} | o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR ~ st
#
c C s | o | \ } } n t | \ } } d | i t | f } d } h | d 6}
| o | |
d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt head_container s4
%
c
C su | o | \ } } n t | \ } } d | i t | f } d }
| p
h } n | | d <| o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pys s t 0s Content-LengthR( s %s%sR! i i, s Container PUT failedR R R R R R N( R R R Ru R RS R R< R R. R
Rk Re R2 (
Rb R R R! R R R R R R R{ R6 R7 ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt
put_container s0
% c
C sd | o | \ } } n t | \ } } d | i t | f } d }
| | d <| o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pys E s R s Content-LengthR( s %s%sR! i i, s Container POST failedR R R R R R N( R R R Ru R RS R< R R R. R
Rk Re R2 (
Rb R R R! R R R R R R R{ R6 R7 ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt post_container, s,
%
c
C sB | o | \ } } n t | \ } } d | i t | f } h | d 6} | o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt delete_containerW s(
%
c
C s | o | \ }
} n t | \ }
} d |
i t | t | f } | o | d | 7} n d }
| o
| i n h } | | d <| o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt
get_object s@ "
%
%c C sq | o | \ } } n t | \ } } d | i t | t | f } d } h | d 6}
| o | |
d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt head_object s. "
%
c C s |
o |
\ } } n t | d | \ } } | i } | o# d | i d t | f } n | o# d | i d t | f } n | o | d | 7} n | o t | } n h } | o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt
put_object sr & ##
%
c
C sB | o | \ } } n t | \ } } d | i t | t | f }
| | d <| o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt post_objectV s$ "
%
c
C s | o | \ }
} n t | d | \ }
} |
i } | o# d | i d t | f } n | o# d | i d t | f } n | o | d | 7} n | o t | } n h } | o | | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt
delete_object~ s: ## %
c C s | \ } } | i d | i d | i } | i } t | i d f h h d 6| | | i d j p | i d j oC t d d | i d | i d | i d
| i d | i
d | n h } x* | i D] \ } } | | | i /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt get_capabilities s &
t
Connectionc B sa e Z d Z d d d d d d e d d d d d d e e e d d Z d Z d Z d Z d d Z
d
Z d Z d Z
d d d d e d
Z d d Z d Z d d d d d d e d Z d d d Z d d Z d d Z d Z d d d d d Z d d d d d d d d Z d d Z d d d Z d d Z RS( s{
Convenience class to make requests that will also retry the request
Requests will have an X-Auth-Token header whose value is either
the preauthtoken or a token obtained from the auth service using
the user credentials provided as args to the constructor. If
os_options includes a service_username then requests will also have
an X-Service-Token header whose value is a token obtained from the
auth service using the service credentials. In this case the request
url will be set to the storage_url obtained from the auth service
for the service user, unless this is overridden by a preauthurl.
i i i@ R c C sG | | _ | | _ | | _ | | _ d | _ d | _ | | _ | | _ | | _ | | _
t | p h | _ |
o |
| i d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyRR s6 &
c C s | i oq t | i t o^ t | i d j oH | i d } t | d o' t | i o | i d | _ q{ n d S( Ni R ( R RC t tuplet lenR t callableR R ( R R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR # s
c C sm t | i | i | i d | i d | i d | i d | i d | i d | i \ | _
| _ | i
| i f S( NR R R Rq Rr Ra ( R R R R R R R Rq Rr Ra Rb R ( R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR - s c C s | i } h } | i d d | d <| i d d | d <| i d d | d <| i d d } | i d d } t | i | | d | i d | i d | d
| i d | i d | i S(
Nt service_project_nameR R R R t service_keyR R R Rq Rr Ra (
R R R R R R R Rq Rr Ra ( R t optst service_optionst service_userR ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt get_service_auth7 s
c
C s? t | o | n | i d | i d | i d | i d | i S( NRq Rr Rs Ra ( R Rb Rq Rr Rs Ra ( R Rb ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR I s
c C sh | d j oW d | j oJ | d } d | j o | d i | n | g | d <| i | n d S( NR t response_dicts( R R- R ( R t target_dictR5 R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt _add_response_dictP s
c
O s2 d | _ t } | i } | i d d } x| i | i j o| i d 7_ y| i p | i o% | i \ | _ | _ d | _ n | i
o0 | i o% | i \ | _ | _ d | _ n t
| _ | i p | i | _ n | i | d <| d j o h | d /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt _retryY sr
!
c C s | i d t S( s Wrapper for :func:`head_account`N( R3 R R ( R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c
C s. | i d t d | d | d | d | d | S( s Wrapper for :func:`get_account`R R R R R N( R3 R R ( R R R R R R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s | i d t | d | S( s Wrapper for :func:`post_account`R N( R3 R R ( R R! R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s | i d t | S( s" Wrapper for :func:`head_container`N( R3 R R ( R R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s= | i d t | d | d | d | d | d | d | d | S( s! Wrapper for :func:`get_container`R R R R R R R N( R3 R R ( R R R R R R R R R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s | i d t | d | d | S( s! Wrapper for :func:`put_container`R! R N( R3 R R ( R R R! R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s | i d t | | d | S( s" Wrapper for :func:`post_container`R N( R3 R R ( R R R! R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s | i d t | d | S( s$ Wrapper for :func:`delete_container`R N( R3 R R ( R R R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s | i d t | | S( s Wrapper for :func:`head_object`N( R3 R R ( R R t obj( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c
C s. | i d t | | d | d | d | d | S( s Wrapper for :func:`get_object`R R R R! N( R3 R R ( R R R4 R R R R! ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c s f d } t | t p | o
d
} nl | } | i d j oU t | d d
}
t | d d
|
o& o |
f d } q n | i | t | d | d | d | d | d
| d | d |
S( s Wrapper for :func:`put_object`c s t d f d S( NsN put_object(%r, %r, ...) failure and no ability to reset contents for reupload.( R
( R4 R5 ( R4 R ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt _default_reset s i t tellt seekc s
S( ( ( t aR~ ( t orig_posR7 ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt s R R RQ R R! R R N( RC R R R t getattrR3 R
( R R R4 R R R RQ R R! R R R5 R- R6 ( ( R7 R R9 R4 s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR
s
c C s | i d t | | | d | S( s Wrapper for :func:`post_object`R N( R3 R R ( R R R4 R! R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C s" | i d t | | d | d | S( s! Wrapper for :func:`delete_object`R R N( R3 R R ( R R R4 R R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s c C sv | p | i } | p | i \ } } n t | i } t | i } | d | d } | i | } t | S( Ns ://s /info( Rb R R Rk Rd R R ( R Rb t _Rk Rd R ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR s N( R R RZ R R Rl RR R R R# R R& R3 R R R R R R R R R R R
R R R ( ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyR sD
>
;
( s 1.0R i ( s 2.0R i ( s 3.0R i ( s containerR s object(N RZ R( Rh R+ R t distutils.versionR t requests.exceptionsR R t six.movesR t six.moves.urllib.parseR RA R R R R R? R# R Rm t swiftclient.exceptionsR
t swiftclient.utilsR R R
t _MAXHEADERSR R R R RM R R t Handlert __version__t requests.structuresR R" t modelst PreparedRequestt prepare_headersR R) R R< RB RO R RP R[ R R R R R R R R R R R R R R R R R R R R
R R R R ( ( ( s> /tmp/pip-build-cD3xZi/python-swiftclient/swiftclient/client.pyt s
w 4 E B$ ' R +,*'? ( j' 8