ó
·EYc@s…
dd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
ddlmZ
ddlm	Z	
dd
l
Z
dd
lZdd
lZydd
l
Z
Wnek
r·


dd
lZ
n
XddlmZ
ddlmZ
ddlmZ
ejd	ƒ
Ze
jeƒ
Zd
ZdZd
Zd„Zdef
d„ƒYZdef
d„ƒYZ d„Z!dej"efd„ƒYZ#d
d
d„Z%d
S(iÿÿÿÿN(
tadapter(
t
exceptions(
timportutils(
tnetutils(
tencodeutils(
tutils(
texcsosprofiler.webspython-glanceclientii@sX-OpenStack-Request-IDc

Cstd
„t
j|ƒ
Dƒ
ƒ
S(sÐEncodes headers.

    Note: This should be used right before
    sending anything out.

    :param headers: Headers to encode
    :returns: Dictionary with encoded headers'
              names and values
    c
ss?|]5\}
}|dk	rt
j|
ƒ
t
j|ƒ
fV
qdS(
N(tNoneRtsafe_encode(t.0t
ht
v((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pys	<genexpr>8s
(tdicttsixt	iteritems(
theaders((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytencode_headers.s
	
t_BaseHTTPClientcBs)eZ
ed„ƒ
Zd
„Zd„ZRS(c
cs5|}
x(|
r0|jt
ƒ
}
|
s(Pn|
V
q	WdS(
N(treadt	CHUNKSIZE(tbodytchunk((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyt_chunk_body>s
	



cCs |
jd
dƒ}|j
ddƒ}|dk	r‚t|tjƒr‚ytj|ƒ
}d}Wq‚tk
r~


|j	|ƒ
}q‚Xn||
d
<|dk|d<|S(s6Handle the common parameters used to send the request.sContent-Typesapplication/octet-streamtdatasapplication/jsontstreamN(
tgettpopRt
isinstanceR
tstring_typestjsontdumpst	TypeErrorR(tselfRtkwargstcontent_typeR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyt_set_common_request_kwargsGs








cCs,
|
js4t
jd
|
jƒ
tj|
|
jƒ‚
n9|
jtjj	krm|
j
jdkrmtj|
ƒ
‚
n|
jj
dƒ
}|dkrt|
tƒ}n…|
j}|rÊ|jdƒ
rÊ|
jƒ}nXtj|ƒ
}y/tjdjg|D]}|^qïƒ
ƒ
}Wntk
r!



d}n
X|
|fS(Ns#Request returned failure status %s.s	/versionssContent-Typesapplication/octet-streamsapplication/jsont(toktLOGtdebugtstatus_codeRt
from_responsetcontenttrequeststcodestMULTIPLE_CHOICEStrequesttpath_urlRRt_close_after_streamRttextt
startswithRR
tStringIOtloadstjoint
ValueErrorR(R trespR"t	body_iterR*t
c((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyt_handle_response_s$
	



	


/



(t__name__t
__module__tstaticmethodRR#R:(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyR<s		t
HTTPClientcBsweZ
d„Zed
„ƒ
Zd„Zed„ƒ
Zd„Zd„Zd„Z	d„Z
d„Zd	„Zd
„Z
RS(cKs™
|
|_|j
d
ƒ
|_|j
dƒ
|_|j
dƒ
|_|j
dƒ
|_|jrx|jjd|jƒ|_ntjƒ|_	t
|j	jd<|jr¶|j|j	jd<nt|j
dd	ƒƒ
|_
|jjd
ƒ
r•
|j
dtƒ}|tkr
tjdtƒ
n|j
d
tƒtkr;
t|j	_n3|j
ddƒdk	rn
|j
dtƒ|j	_n|j
dƒ
|j
dƒ
f|j	_ndS(Ntidentity_headersttokentlanguage_headertglobal_request_idsX-Auth-Tokens
User-AgentsAccept-LanguagettimeoutiXthttpstssl_compressions3The "ssl_compression" argument has been deprecated.tinsecuretcacertR$t	cert_filetkey_file(tendpointRR?t
auth_tokenRARBRR+tSessiontsessiont
USER_AGENTRtfloatRCR2tTruetFalsetwarningstwarntDeprecationWarningtverifyRtcert(R RJR!tcompression((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyt__init__s0
	




	


	

	




c

Cs
tj
|ƒ
S(
N(Rturlsplit(
RJ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytparse_endpoint¥scCsa
d
|
g
}tj
|ƒ
}|j|jjƒ

x@tj|ƒ
D]/\}}dtj||ƒ}	|j	|	ƒ

q?W|jj
sŽ|j	dƒ

n2t|jj
tjƒrÀ|j	d|jj
ƒ

n|jj
ræ|j	d|jj
ƒ

n|r
t|tjƒr
|j	d|ƒ

n|j	|ƒ

djg|D]}
tj|
dd	ƒ

^q,
ƒ
}tj|ƒ

dS(
Nscurl -g -i -X %ss-H '%s: %s's-ks --cacert %ss --cert %s --key %ss-d '%s't
 terrorstignore(tcopytdeepcopytupdateRMRR
RRtsafe_headertappendRURRRVR5Rtsafe_decodeR&R'(R tmethodturlRRR!tcurltkeytvaluetheadertitemtmsg((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytlog_curl_request©s$









	
(
c
Csñ|jj
d
|j|jf}
d|
g
}|jjƒ}|jg|D]"\}}dtj||ƒ^qHƒ

|j	dƒ

|jj
dƒ
}|dkrµ|j|jdgƒ

ntj
djg|D]}tj|dd	ƒ

^qȃ
ƒ

dS(
Ng$@s
HTTP/%.1f %s %ss%s: %sR$sContent-Typesapplication/octet-streams

R\R](trawtversionR(treasonRtitemstextendRRaRbRR1R&R'R5RRc(R7tstatustdumpRt
kRR"t
x((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytlog_http_responseÅs



6





c	Ksêtj
|jd
iƒƒ
}|jrZx3tj|jƒ
D]\}}|j||ƒ
q7Wn|j||ƒ}|jdƒ
s‹|j	|d<n|j
rª|jt|j
ƒ
ntrÆ|j
tjƒƒ

nt|ƒ
}|jjdƒ
só|jdƒ
r	
d|j|f}nd|j|f}|j|
||||ƒ
y(|jj|
|d|d
||}	Wn
tjjk
r£

}

dtd|d	|
ƒ}tjd
|ƒ
‚
nÒtjjk
ræ

}

dtd|d	|
ƒ}tjd
|ƒ
‚
ntjk
r 
}

d|j |
f}tjd
|ƒ
‚
nUtj!tj"t#fk
rt
}

|j}d
i|d6|
d	6}tjd
|ƒ
‚
n
X|	j$jdƒ
}
|
r¾t%j&di|	jj'd6|	j(d6|
d6ƒ
n|j)|	ƒ
\}	}|j*|	ƒ

|	|fS(s¿Send an http request with the specified characteristics.

        Wrapper around httplib.HTTP(S)Connection.request to handle tasks such
        as setting headers and error handling.
        RsX-Auth-Tokent
/s%s%ss%s/%sRs'Error communicating with %(url)s: %(e)sRet
etmessages(Error finding address for %(url)s: %(e)ss Error finding address for %s: %ss+Error communicating with %(endpoint)s %(e)sRJsx-openstack-request-idsL%(method)s call to image for %(url)s used request id %(response_request_id)sRdtresponse_request_id(+R^R_RR?R
Rt
setdefaultR#RRKRBt
REQ_ID_HEADERtosprofiler_webR`tget_trace_id_headersRRJtendswithR2RlRMR.R+R
tTimeoutRRtInvalidEndpointtConnectionErrortCommunicationErrortsockettgaierrortendpoint_hostnameterrorRCtIOErrorRR&R'RdReR:Rv(R RdReR!RRtRRtconn_urlR7RxRyRJt
request_idR8((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyt_requestÓs`	


	

!





















	




	





cKs|jd
|
|S(NtHEAD(
R‹(R ReR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pythead
s
cKs|jd
|
|S(NtGET(
R‹(R ReR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyR 
s
cKs|jd
|
|S(NtPOST(
R‹(R ReR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytpost#
s
cKs|jd
|
|S(NtPUT(
R‹(R ReR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytput&
s
cKs|jd
|
|S(NtPATCH(
R‹(R ReR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytpatch)
s
cKs|jd
|
|S(NtDELETE(
R‹(R ReR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytdelete,
s
(R;R<RXR=RZRlRvR‹RRRR’R”R–(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyR>s	$		J					ccs0x|jd
|
ƒ
D]}|V
qW|j
ƒ
dS(sAIterate over the content and ensure the response is closed after.t
chunk_sizeN(titer_contenttclose(tresponseR—R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyR00
s
	t
SessionClientc
BseZ
d„Zd
„ZRS(cKsR|jd
t
ƒ
|jddƒ
|jddƒ|_tt|ƒj|
|

dS(Nt
user_agenttservice_typetimageRB(R{RNRRRBtsuperR›RX(R RMR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyRX=
s



c
KsŒ
|jd
iƒ}|j
r1|jt|j
ƒ
nt|d<|j||ƒ}y4tt|ƒj|
|d
t	|ƒ
d||}Wnût
jk
r


}
|jd|j
dƒ
ƒ
}d|jdƒ
|
jdƒ
f}dtd|d	|ƒ}	tjd
|	ƒ
‚
n~t
jk
r~

}
|jd|j
dƒ
ƒ
}d|jdƒ
|
jdƒ
f}dtd|d	|ƒ}	tjd
|	ƒ
‚
n
X|j|ƒ
S(NRt	raise_excRtauths%s/%sRws&Error communicating with %(url)s %(e)sReRxRys(Error finding address for %(url)s: %(e)s(RRBR{R|RQR#RŸR›R.Rtksa_exctConnectTimeouttget_endpointRtrstriptlstripRRRtConnectFailureRƒR:(
R ReRdR!RRR7RxR‰Ry((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyR.C
s2

	












"





"


(R;R<RXR.(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyR›;
s	cKs6|
rt|
|
S|r&t
||
Std
ƒ
‚
dS(NsBConstructing a client must contain either an endpoint or a session(R›R>tAttributeError(RJRMR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pytget_http_clientc
s






i
(&R^tloggingR„t
keystoneauth1RR
R¢t
oslo_utilsRRR+R
RRRtImportErrort
simplejsonRtglanceclient.commonRtglanceclientRt
try_importR}t	getLoggerR;R&RNRR|RtobjectRR>R0tAdapterR›RR©(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/glanceclient/common/http.pyt<module>s6















	C±	(