�
c�ec@s*dd
lm
Z

ddlmZ
ddlmZ
ddlmZ
ddlZddlZddl	Z	ddl
Z
ddlZddlZddl
mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z 
ddl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/
ddl0m1Z1
yddl2Z2e3Z4Wne5k
r�



e6Z4n
Xi
ej7e6Z8e4r�
e9e2d	�r�
d
e8e2j:<d
e8e2j;<n
d
e8e2j<<ne
j=e8krde8e
j=<ne>e8j?��
Z@e1r�ddlAZAeeAjB�
ZCeCed�
kZDeCed
�
kZEeCed�
kZFeEr�deAjBZGejHeG�

ne3ZIeEr�e6ZInndZJdZKdZLdZMdZNeO�ZPdeOf
d��YZQdeOf
d��YZRdeOf
d��YZSdeRf
d��YZTdeRf
d��YZUe1r]eUZVneTZVdeOf
d ��YZWd!eWf
d"��YZXd#eWf
d$��YZYd%d&d'd(d)fZZd*�Z[ie\d+6e\d,6e[d-6e[d.6e]d/6e]d06e[d16Z^d2eOf
d3��YZ_d4e_f
d5��YZ`dS(6i����(
tunicode_literals(
t
StrictVersion(
tchain(
ttimeN(txrangetimaptunicodetlongt	nativestrt
basestringt	iteritemst	LifoQueuetEmptytFullturlparsetparse_qstrecvt	recv_intotunquotetBlockingIOErrortsendalltshutdowntssl_wrap_socket(tAuthenticationErrort$AuthenticationWrongNumberOfArgsErrortBusyLoadingErrortChildDeadlockedErrortConnectionErrort	DataErrortExecAbortErrortInvalidResponsetNoPermissionErrort
NoScriptErrort
ReadOnlyErrort
RedisErrort
ResponseErrortTimeoutError(
tHIREDIS_AVAILABLEuSSLWantReadErrorii���u0.1.3u0.1.4u1.0.0u`redis-py works best with hiredis >= 0.1.4. You're running hiredis %s. Please consider upgrading.t
*t
$s
tuConnection closed by server.tEncodercBs,eZ
dZd
�Zd�Zed�
ZRS(u=Encode strings to bytes-like and decode bytes-like to stringscCs|
|_||_
||_dS(
N(tencodingtencoding_errorstdecode_responses(tselfR*R+R,((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt__init__bs
	
	
cCs�t|
t
tf�r|
St|
t�r7td
�
�
nt|
t�r[t|
�
j�}
n[t|
tt	f�r�t
|
�
j�}
n1t|
t�s�t|
�
j
}td|�
�
nt|
t�r�|
j|j|j�}
n|
S(u=Return a bytestring or bytes-like representation of the valueuNInvalid input of type: 'bool'. Convert to a bytes, string, int or float first.uLInvalid input of type: '%s'. Convert to a bytes, string, int or float first.(t
isinstancetbytest
memoryviewtboolRtfloattreprtencodetintRtstrR	ttypet__name__RR*R+(R-tvaluettypename((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR5gs










cCs^|js|rZt
|
t�r-|
j�}
nt
|
t�rZ|
j|j|j�}
qZn|
S(
u:Return a unicode string from the bytes-like representation(R,R/R1ttobytesR0tdecodeR*R+(R-R:tforce((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR=}s




(R9t
__module__t__doc__R.R5tFalseR=(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR)_s
		t
BaseParsercBskeZ
iied6ed
6ed6ed6ed6d6ed6ed6ed6ed	6ed
6e	d6Z
d�ZRS(
umax number of clients reachedu(Client sent AUTH, but no password is setuinvalid passwordu,wrong number of arguments for 'auth' commandu,wrong number of arguments for 'AUTH' commanduERRu	EXECABORTuLOADINGuNOSCRIPTuREADONLYuNOAUTHuNOPERMcCs{|
jd
�
d}||j
krq|
t|�
d}
|j
|}t|t�rg|j|
t�}n||
�
St|
�
S(uParse an error responseu
 ii
(tsplittEXCEPTION_CLASSEStlenR/tdicttgetR#(R-tresponset
error_codetexception_class((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytparse_error�s








(R9R?RRRRRR R!RRDRK(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRB�s










tSocketBuffercBs_eZ
d�Zed
��
Zdeed�Zd�Z	d�Z
d�Zd�Zd�Z
RS(	cCs@|
|_||_
||_tj�|_d
|_d
|_dS(Ni(t_socktsocket_read_sizetsocket_timeouttiotBytesIOt_buffert
bytes_writtent
bytes_read(R-tsocketRNRO((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.�s
	
	
	
	c

Cs|j|j
S(
N(RSRT(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytlength�sc
Cs�
|j}|j
}|j}|j|j�

d
}|tk	}zB
y�|rY|j|�

nx�tr�t|j|�}	t	|	t
�r�t|	�
d
kr�tt
�
�
n|j|	�

t|	�
}
|j|
7_||
7}|
dk	r�|
|kr�q\ntSWWn�tjk
r&



|r"
td�
�
ntStk
r}

}
tj|jd�}|rd
|j|krd
tStd|jf
�
�
n
XWd|r�
|j|j�

nXdS(NiuTimeout reading from socketi����u#Error while reading from socket: %s(RMRNRRtseekRStSENTINELt
settimeouttTrueRR/R0RERtSERVER_CLOSED_CONNECTION_ERRORtwritetNoneRUttimeoutR$RAtNONBLOCKING_EXCEPTIONSt#NONBLOCKING_EXCEPTION_ERROR_NUMBERSRGt	__class__terrnotargsRO(
R-RVR^traise_on_timeouttsockRNtbuftmarkertcustom_timeouttdatatdata_lengthtextallowed((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt_read_from_socket�sB	
	
	





	
!








	









cCs%t|j
�
p$|jd
|
dt�S(NR^Rd(R2RVRmRA(R-R^((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytcan_read�s


cCs�|
d
}
|
|jkr0|j
|
|j�

n|jj|j�

|jj|
�
}|jt|�
7_|j|jkr�|j�
n|d S(Nii����(	RVRmRRRWRTtreadRERStpurge(R-RVRi((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRo�s






c
Cs�|j}
|
j
|j�

|
j�}x9|jt�
s`|j�
|
j
|j�

|
j�}q(W|jt|�
7_|j|jkr�|j	�
n|d
 S(Ni����(
RRRWRTtreadlinetendswithtSYM_CRLFRmRERSRp(R-RfRi((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRq�s
	







c

Cs3|jj
d
�

|jj�
d
|_d
|_dS(Ni(RRRWttruncateRSRT(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRp

s



	
c

CsEy|j�
|j
j�
Wntk
r.


n
Xd|_
d|_dS(
N(RpRRtcloset	ExceptionR]RM(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRu
s






	
N(R9R?R.tpropertyRVR]RXRZRmRnRoRqRpRu(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRL�s
	

*				tPythonParserc
BsDeZ
dZd
�Zd�Zd�Zd�Zd�Zd�ZRS(uPlain Python parsing classcCs(|
|_d|_d|_d|_dS(
N(RNR]tencoderRMRR(R-RN((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.$
s
	
	
	
c

Cs&y|j�
Wnt
k
r!


n
XdS(
N(t
on_disconnectRv(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt__del__*
s




cCs:|
j|_t
|j|j|
j�|_|
j|_d
S(uCalled when the socket connectsN(RMRLRNRORRRy(R-t
connection((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt
on_connect0
s

	


c

Cs>d
|_
|jd
k	r1|jj�
d
|_nd
|_d
S(u"Called when the socket disconnectsN(R]RMRRRuRy(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRz8
s
	




cCs|jo|jj
|
�
S(
N(RRRn(R-R^((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRn@
s
c
Csz
|jj
�}
|
s$tt�
�
n|
d
 |
d
}}|d	krXtd|
�
�
n|dkr�t|�
}|j|�
}t|t�r�|�
n|S|dkr�n�|dkr�t|�
}n�|dkr
t	|�
}|dkr�dS|jj|�
}nP|dkrR
t	|�
}|dkr*
dSgt|�
D]}|j
�^q7
}nt|t�rv
|jj|�
}n|S(
Ni
t
-t
+t
:R'R&uProtocol Error: %ri����(R~RR�R'R&(RRRqRR[RRRKR/RR6R]RoRt
read_responseR0RyR=(R-trawtbyteRHterrorRVt
i((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�C
s:






	









(


(	R9R?R@R.R{R}RzRnR�(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRx"
s

					t
HiredisParsercBsSeZ
dZd
�Zd�Zd�Zd�Zd�Zee	d�Z
d�ZRS(u*Parser class for connections using HirediscCs:tst
d
�
�
n|
|_tr6t|
�
|_ndS(NuHiredis is not installed(R%R"RNtHIREDIS_USE_BYTE_BUFFERt	bytearrayRR(R-RN((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.s
s



	
c

Cs&y|j�
Wnt
k
r!


n
XdS(
N(RzRv(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR{{
s




cCs�|
j|_|
j
|_itd
6|jd6}tsBt|d<n|
jjra|
jj	|d<nt
rz|
jj|d<ntj
|�|_t|_dS(Nu
protocolErroru
replyErroruencodinguerrors(RMROt_socket_timeoutRRKt HIREDIS_SUPPORTS_CALLABLE_ERRORSR#RyR,R*t HIREDIS_SUPPORTS_ENCODING_ERRORSR+thiredistReadert_readerRAt_next_response(R-R|tkwargs((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR}�
s












c

Csd|_
d|_t|_dS(
N(R]RMR�RAR�(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRz�
s
	
	
cCse|jst
t�
�
n|jtkra|jj�|_|jtkra|jd
|
dt�SntS(NR^Rd(R�RR[R�RAtgetstread_from_socketRZ(R-R^((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRn�
s
	






c	Cs�
|j}|
t
k	}zN
y�|r1|j|
�

ntr�t|j|j�}|d
krgtt�
�
n|jj	|jd
|�
nVt
|j|j�}t|t
�s�t|�
d
kr�tt�
�
n|jj	|�

tSWn�tjk
r




|r
td�
�
ntStk
ra

}
tj|jd�}|rH
|j|krH
tStd|jf
�
�
n
XWd|r
|j|j�

nXdS(NiuTimeout reading from socketi����u#Error while reading from socket: %s(RMRXRYR�RRRRR[R�tfeedRRNR/R0RERZRUR^R$RAR_R`RGRaRbRcR�(	R-R^RdReRhtbufflentbufferRkRl((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��
s8
	








"











c
CsC
|jst
t�
�
n|jtk	r=|j}
t|_|
S|jj�}
x)|
tkrw|j�
|jj�}
qOWts�t|
t	�r�|j
|
jd
�
}
q�t|
t�r�|
r�t|
d
t	�r�|j
|
d
jd
�
|
d
<q�nt|
t
�r

|
�
n5t|
t�r?
|
r?
t|
d
t
�r?
|
d
�
n|
S(Ni(
R�RR[R�RAR�R�R�R/R#RKRctlist(R-RH((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��
s,
	

	
	









$
	




(R9R?R@R.R{R}RzRnRXRZR�R�(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�q
s

					&t
ConnectioncBs�eZ
dZd
dddddeddeddeeddddd�Zd�Zd	�Zd
�Z	d�Z
d�Zd
�Zd�Z
d�Zd�Zd�Zd�Zed�
Zd�Zdd�
Zd�Zd�Zd�ZRS(u4Manages TCP communication to and from a Redis serveru	localhosti�iuutf-8ustricti
cCs�tj
�|_|
|_t|�
|_||_||_||_||_	||_
|p]||_||_|pui|_
|	|_|
|_||_d
|_t|||
�|_d|_|d|�
|_g|_d|_dS(NiRNip(tostgetpidtpidthostR6tporttdbtusernametclient_nametpasswordROtsocket_connect_timeouttsocket_keepalivetsocket_keepalive_optionstsocket_typetretry_on_timeoutthealth_check_intervaltnext_health_checkR)RyR]RMt_parsert_connect_callbackst_buffer_cutoff(R-R�R�R�R�ROR�R�R�R�R�R*R+R,tparser_classRNR�R�R�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.�
s(
	

	
	
	
	
	

	

	
	
	
	

	

	
c
CsLd
jg|j
�D]\}
}d|
|f^q�
}d|jj|fS(Nu
,u%s=%su%s<%s>(tjointrepr_piecesRaR9(R-t
kt
vt	repr_args((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt__repr__s
8
c
CsPd
|jfd|j
fd|jfg}
|jrL|
jd|jf�

n|
S(Nuhostuportudbuclient_name(R�R�R�R�tappend(R-tpieces((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�s

	

c

Cs&y|j�
Wnt
k
r!


n
XdS(
N(t
disconnectRv(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR{s




cCs|jj
|
�

dS(
N(R�R�(R-tcallback((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytregister_connect_callback$s
c

Cs
g|_dS(
N(
R�(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytclear_connect_callbacks's
c
Cs�|jr
d
Sy|j
�}
WnJtjk
r?


td�
�
n+tjk
ri
}
t|j|�
�
�
n
X|
|_y|j�
Wnt	k
r�


|j
�
�n
Xx|jD]}||�

q�Wd
S(u5Connects to the Redis server if not already connectedNuTimeout connecting to server(RMt_connectRUR^R$R�Rt_error_messageR}R"R�R�(R-Ret
eR�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytconnect*s 	






	






c
Csn
d}
x=
t
j|j|j|jt
j�D]
}|\}}}}}d}y�t
j
|||�}|jt
jt
j	d
�
|j
r�|jt
jt
jd
�
x6t
|j�
D]"\}	}
|jt
j|	|
�
q�Wn|j|j�

|j|�

|j|j�

|SWq+t
jk
rA

}
|}
|dk	rB
|j�
qB
q+Xq+W|
dk	r[
|
�
nt
jd�
�
dS(uCreate a TCP socket connectioni
u)socket.getaddrinfo returned an empty listN(R]RUtgetaddrinfoR�R�R�tSOCK_STREAMt
setsockopttIPPROTO_TCPtTCP_NODELAYR�t
SOL_SOCKETtSO_KEEPALIVER
R�RYR�R�ROR�Ru(R-terrtrestfamilytsocktypetprotot	canonnametsocket_addressReR�R�t
_((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�Bs.





	








	
cCs_t|
j
�
d
kr3d|j|j|
j
dfSd|
j
d|j|j|
j
d
fSdS(Ni
uError connecting to %s:%s. %s.iu!Error %s connecting to %s:%s. %s.(RERcR�R�(R-t	exception((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�js



c
Csh
|jj
|�

|js"|jr�|jrF|j|jp=d
f}
n|jf
}
|jddt|
�


y|j�}Wn6tk
r�


|jd|jdt�

|j�}n
Xt|�
dkr�t	d�
�
q�n|j
r
|jdd|j
�
t|j��
dkr
td�
�
q
n|jrd
|jd	|j�
t|j��
dkrd
td
�
�
qd
ndS(u=Initialize the connection, authenticate and select a databaseuuAUTHtcheck_healthuOKuInvalid Username or PassworduCLIENTuSETNAMEuError setting client nameuSELECTuInvalid DatabaseN(
R�R}R�R�tsend_commandRAR�RRRR�RR�(R-t	auth_argst
auth_response((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR}ts*
	





	


	


c

Cs�|jj
�
|jd
kr d
Sy<tj�|jkrNt|jtj	�
n|jj
�
Wntjk
rr


n
Xd
|_d
S(u!Disconnects from the Redis serverN(R�RzRMR]R�R�R�RRUt	SHUT_RDWRRuR�(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s









c

Cs�|jr�t
�|jkr�y>|jd
dt�


t|j��
dkrXtd�
�
nWq�ttfk
r�


|j	�
|jd
dt�


t|j��
dkr�td�
�
q�q�XndS(u3Check the health of the connection with a PING/PONGuPINGR�uPONGu#Bad response from PING health checkN(
R�RR�R�RARR�RR$R�(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s











cCs2
|js|j
�
n|r)|j�
ny@t|
t�rG|
g
}
nx|
D]}t|j|�
qNWWn�tjk
r�


|j�
t	d
�
�
n�tj
k
r

}
|j�
t|j�
dkr�d|jd}}n|jd}|jd}t
d||f�
�
ntk
r-



|j�
�n
XdS(u2Send an already packed command to the Redis serveruTimeout writing to socketi
uUNKNOWNiu%Error %s while writing to socket. %s.N(RMR�R�R/R7RRUR^R�R$R�RERcRt
BaseException(R-tcommandR�titemR�Rbterrmsg((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytsend_packed_command�s.	




























c
Os,|j|j
|
�d
|jdt��


dS(u+Pack and send a command to the Redis serverR�ucheck_healthN(R�tpack_commandRGRZ(R-RcR�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s
cCs5|j}|s%|j
�
|j}n|jj|
�
S(
u8Poll the socket to see if there's data that can be read.(RMR�R�Rn(R-R^Re((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRn�s
	




c
Cs�y|jj
�}
Wn�tjk
rO


|j�
td
|j|jf�
�
n_tjk
r�
}
|j�
t	d|j|j|j
f�
�
ntk
r�


|j�
�n
X|jr�t
�|j|_nt|
t�r�|
�
n|
S(u0Read the response from a previously sent commanduTimeout reading from %s:%su#Error while reading from %s:%s : %s(R�R�RUR^R�R$R�R�R�RRcR�R�RR�R/R#(R-RHR�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s$















	

	
c
Gs�
g}t|
d
t
�r@t|
d
j�j��
|
d}
n1d|
d
krqt|
d
j��
|
d}
ntjttt	|
�
�
j�t
f�
}|j}x�t|j
j|
�D]�}t	|�
}t	|�
|ks�||ks�t|t�rC
tj|tt|�
j�t
f�
}|j|�

|j|�

t
}q�tj|tt|�
j�t
|t
f�
}q�W|j|�

|S(u2Pack a series of arguments into the Redis protocolii
t
 (R/RttupleR5RCt	SYM_EMPTYR�tSYM_STARR7RERsR�RRyR1t
SYM_DOLLARR�(R-Rctoutputtbufft
buffer_cutofftargt
arg_length((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s*
'

!*	




!




	




c	Cs
g}g}d
}|j}x�|
D]�}x�|j
|�D]�}t|�
}||ksq||ksqt|t�r�|jtj|�
�

d
}g}n||ks�t|t�r�|j|�

q8|j|�

||7}q8Wq"W|r�|jtj|�
�

n|S(u.Pack multiple commands into the Redis protocoli(R�R�RER/R1R�R�R�(	R-tcommandsR�R�t
buffer_lengthR�tcmdtchunktchunklen((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt
pack_commandss&


	







	




N(R9R?R@R]RAt
DefaultParserR.R�R�R{R�R�R�R�R�R}R�R�RZR�R�RnR�R�R�(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��
s2



	


		
					(	
	'	
				"t
SSLConnectioncBs)eZ
dddded
�Zd�ZRS(urequiredcKs�tst
d
�
�
ntt|�j|�
|
|_||_|dkrUtj	}n_t
|t�r�itj	d6tjd6tj
d6}||kr�t
d|�
�
n||}n||_||_||_dS(Nu$Python wasn't built with SSL supportunoneuoptionalurequiredu-Invalid SSL Certificate Requirements Flag: %s(t
ssl_availableR"tsuperR�R.tkeyfiletcertfileR]tsslt	CERT_NONER/R	t
CERT_OPTIONALt
CERT_REQUIREDt	cert_reqstca_certstcheck_hostname(R-tssl_keyfiletssl_certfilet
ssl_cert_reqstssl_ca_certstssl_check_hostnameR�t	CERT_REQS((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.6s(
	
	
















	
	
c
Cs�tt
|�j�}
ttd
�r�tj�}|j|_|j|_|j	ry|j
ry|jd|j	d|j
�
n|jr�|j
|j�

nt||
d|j�
}
n3tt|
d|jd|j
d|j	d|j�}
|
S(u Wrap the socket with SSL supportucreate_default_contextR�R�tserver_hostnameR�R�(R�R�R�thasattrR�tcreate_default_contextR�R�tverify_modeR�R�tload_cert_chainR�tload_verify_locationsRR�(R-Retcontext((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�Qs$








	



	
	
	

N(R9R?R]RAR.R�(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�4s

tUnixDomainSocketConnectioncBsSeZ
dd
d	d	d	ddeeedd
d	d�
Zd�Zd�Zd�ZRS(
uiuutf-8ustricti
cCs�tj
�|_|
|_||_||_|
|_||_||_|	|_	||_
d
|_t|||�|_
d|_|
d|�
|_g|_d|_dS(NiRNip(R�R�R�tpathR�R�R�R�ROR�R�R�R)RyR]RMR�R�R�(R-R
R�R�R�ROR*R+R,R�R�RNR�R�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.ls
	
	
	
	
	
	
	
	
	

	

	
c
CsDd
|jfd|j
fg}
|jr@|
jd|jf�

n|
S(Nupathudbuclient_name(R
R�R�R�(R-R�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s

	

c
Cs<tjtj
tj�}
|
j|j�

|
j|j�

|
S(
u&Create a Unix domain socket connection(RUtAF_UNIXR�RYROR�R
(R-Re((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s


cCsSt|
j
�
d
kr-d|j|
j
dfSd|
j
d|j|
j
d
fSdS(Ni
u(Error connecting to unix socket: %s. %s.iu+Error %s connecting to unix socket: %s. %s.(RERcR
(R-R�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s



N(	R9R?R]RAR�R.R�R�R�(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR

js




			u
0u
FuFALSEu
NuNOc

CsK|dks|d
krdSt
|t�rA|j�tkrAtSt|�
S(Nu(R]R/R	tuppert
FALSE_STRINGSRAR2(
R:((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytto_bool�s



!

usocket_timeoutusocket_connect_timeoutusocket_keepaliveuretry_on_timeoutumax_connectionsuhealth_check_intervalussl_check_hostnametConnectionPoolcBs�eZ
dZeded
��
Zedd�Zd�Z	d�Z
d�Zd�Zd�Z
d�Zd	�Zd
�Zed�
ZRS(
uGeneric connection poolcKs%t|
�
}
i}x�t
t|
j�
�
D]�\}}|r(t|�
d
kr(tj|�
}|r�y||d
�
||<Wq�ttfk
r�


t	j
td|�
�

q�Xq�|d
||<q(q(W|rC
|
jr�t
|
j�
nd}	|
jr�t
|
j�
nd}
|
jr
t
|
j�
nd}|
jr:
t
|
j�
nd}n0|
jpO
d}	|
jp^
d}
|
j}|
j}|
jdkr�
|ji|	d6|
d6|d6td6�

n�|
jdkrc|ji|d
6t|
jp�
d�
d6|	d6|
d6�

d
|krD|rDy t|jdd��
|d
<WqDttfk
r@


qDXn|
jd	kr�t|d<q�ndjd�
}
td|
�
�
t|jd
|p�d
��
|d
<|j|�

d|kr�t	j
td�
�

|jd�
|d<nd|krt	j
td�
�

|jd�
|d<n||�S(u
        Return a connection pool configured from the given URL.

        For example::

            redis://[[username]:[password]]@localhost:6379/0
            rediss://[[username]:[password]]@localhost:6379/0
            unix://[[username]:[password]]@/path/to/socket.sock?db=0

        Three URL schemes are supported:

        - ```redis://``
          <https://www.iana.org/assignments/uri-schemes/prov/redis>`_ creates a
          normal TCP socket connection
        - ```rediss://``
          <https://www.iana.org/assignments/uri-schemes/prov/rediss>`_ creates
          a SSL wrapped TCP socket connection
        - ``unix://`` creates a Unix Domain Socket connection

        There are several ways to specify a database number. The parse function
        will return the first specified option:
            1. A ``db`` querystring option, e.g. redis://localhost?db=0
            2. If using the redis:// scheme, the path argument of the url, e.g.
               redis://localhost/0
            3. The ``db`` argument to this function.

        If none of these options are specified, db=0 is used.

        The ``decode_components`` argument allows this function to work with
        percent-encoded URLs. If this argument is set to ``True`` all ``%xx``
        escapes will be replaced by their single-character equivalents after
        the URL has been parsed. This only applies to the ``hostname``,
        ``path``, ``username`` and ``password`` components.

        Any additional querystring arguments and keyword arguments will be
        passed along to the ConnectionPool class's initializer. The querystring
        arguments ``socket_connect_timeout`` and ``socket_timeout`` if supplied
        are parsed as float values. The arguments ``socket_keepalive`` and
        ``retry_on_timeout`` are parsed to boolean values that accept
        True/False, Yes/No values to indicate state. Invalid types cause a
        ``UserWarning`` to be raised. In the case of conflicting arguments,
        querystring arguments always win.

        iu)Invalid value for `%s` in connection URL.uunixuusernameupasswordupathuconnection_classuredisuredissuhosti�uportudbu
/uu, uredis://u	rediss://uunix://u8Redis URL must specify one of the following schemes (%s)ucharsetu/"charset" is deprecated. Use "encoding" insteaduencodinguerrorsu5"errors" is deprecated. Use "encoding_errors" insteaduencoding_errorsN(uredisurediss(uredis://u	rediss://uunix://(RR
RtqueryREtURL_QUERY_ARGUMENT_PARSERSRGt	TypeErrort
ValueErrortwarningstwarntUserWarningR�RR]R�R
thostnametschemetupdateR

R6R�treplacetAttributeErrorR�R�tDeprecationWarningtpop(tclsturlR�tdecode_componentsR�turl_optionstnameR:tparserR�R�R
R
t
valid_schemes((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytfrom_url�sl.
"






	




!

	
	
	




	





 





"

	




	


cKsu|p	d}t|t
tf�s.|dkr=td�
�
n|
|_||_||_tj�|_	|j
�
dS(u�

        Create a connection pool. If max_connections is set, then this
        object raises redis.ConnectionError when the pool's limit is reached.

        By default, TCP connections are created unless connection_class is
        specified. Use redis.UnixDomainSocketConnection for unix sockets.

        Any additional keyword arguments are passed to the constructor of
        connection_class.
        iiiu,"max_connections" must be a positive integerNI�(R/R6RR
tconnection_classtconnection_kwargstmax_connectionst	threadingtLockt
_fork_locktreset(R-R
R 
R
((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.0s
"
	
	
	

c

Cs)d
t|�
j
t|j|j��
fS(Nu%s<%s>(R8R9R4R
R
(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR�Os


c

Cs@tj
�|_d
|_g|_t�|_tj�|_	dS(Ni(
R!
R"
t_lockt_created_connectionst_available_connectionstsett_in_use_connectionsR�R�R�(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR$
Us


	
	
c
Cs�|jt
j�kr�t�d
}
t}x/t�|
krY|jjt�
}|r+Pq+q+W|sit�
nz&|jt
j�kr�|j�
nWd|jj	�
XndS(Ni(
R�R�R�RRAR#
tacquireRR$
trelease(R-t
timeout_attacquired((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt	_checkpidfs#







	

c	Os�|j�
|j
�H
y|jj�}Wntk
rF


|j�}n
X|jj|�

Wd
QXyp|j�
y|j	�r�t
d�
�
nWn@t
k
r�


|j�
|j�
|j	�r�t
d�
�
q�n
XWn!tk
r�


|j
|�

�n
X|S(uGet a connection from the poolNuConnection has datauConnection not ready(R.
R%
R'
R
t
IndexErrortmake_connectionR)
taddR�RnRR�R�R+
(R-tcommand_nametkeystoptionsR|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytget_connection�s*























c
	CsF|j}
t
d
|
jdd�d|
jdd�d|
jdt��S(	u,Return an encoder based on encoding settingsR*uencodinguutf-8R+uencoding_errorsustrictR,udecode_responses(R
R)RGRA(R-R�((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pytget_encoder�s
	



c

Cs@|j|j
kr!td
�
�
n|jd7_|j|j�S(uCreate a new connectionuToo many connectionsi
(R&
R 
RR
R
(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR0
�s


c	Cs�|j�
|j
�l
y|jj|
�

Wntk
r;


n
X|j|
�
r^|jj|
�

n|jd
8_|
j	�
dSWdQXdS(u(Releases the connection back to the pooli
N(
R.
R%
R)
tremovetKeyErrortowns_connectionR'
R�R&
R�(R-R|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR+
�s










cCs|
j|jkS(
N(
R�(R-R|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR9
�s
cCs`|j�
|j
�G
|
r2t|j|j�}n	|j}x|D]}|j�
qBWWd
QXd
S(u�
        Disconnects connections in the pool

        If ``inuse_connections`` is True, disconnect connections that are
        current in use, potentially by other threads. Otherwise only disconnect
        connections that are idle in the pool.
        N(R.
R%
RR'
R)
R�(R-tinuse_connectionstconnectionsR|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s




	
	

N(R9R?R@tclassmethodR]RAR
R�R.R�R$
R.
R5
R6
R0
R+
R9
RZR�(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR
�s


z			6	!					tBlockingConnectionPoolcBsPeZ
dZd
deed�Zd�Zd�Zd�Zd�Z	d�Z
RS(	u6
    Thread-safe blocking connection pool::

        >>> from redis.client import Redis
        >>> client = Redis(connection_pool=BlockingConnectionPool())

    It performs the same function as the default
    ``:py:class: ~redis.connection.ConnectionPool`` implementation, in that,
    it maintains a pool of reusable connections that can be shared by
    multiple redis clients (safely across threads if required).

    The difference is that, in the event that a client tries to get a
    connection from the pool when all of connections are in use, rather than
    raising a ``:py:class: ~redis.exceptions.ConnectionError`` (as the default
    ``:py:class: ~redis.connection.ConnectionPool`` implementation does), it
    makes the client wait ("blocks") for a specified number of seconds until
    a connection becomes available.

    Use ``max_connections`` to increase / decrease the pool size::

        >>> pool = BlockingConnectionPool(max_connections=10)

    Use ``timeout`` to tell it either how many seconds to wait for a connection
    to become available, or to block forever:

        # Block forever.
        >>> pool = BlockingConnectionPool(timeout=None)

        # Raise a ``ConnectionError`` after five seconds if a connection is
        # not available.
        >>> pool = BlockingConnectionPool(timeout=5)
    i2icKs8||_||_
tt|�jd
|d|
|�
dS(NR
R 
(tqueue_classR^R�R=
R.(R-R 
R^R
R>
R
((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR.s	
	



c

Csg|j|j
�
|_x3trJy|jjd�

Wqtk
rF


PqXqWg|_tj	�|_
dS(
N(R>
R 
tpoolRZt
put_nowaitR]R
t_connectionsR�R�R�(
R-((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR$
%s
	




		c
Cs&|j|j
�}
|jj|
�

|
S(
uMake a fresh connection.(R
R
RA
R�(R-R|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR0
=s

cOs
|j�
d}y"|jjd
td|j�}Wntk
rQ


td�
�
n
X|dkrm|j�}nyp|j	�
y|j
�r�td�
�
nWn@tk
r�


|j�
|j	�
|j
�r�td�
�
q�n
XWn!tk
r



|j
|�

�n
X|S(u7
        Get a connection, blocking for ``self.timeout`` until a connection
        is available from the pool.

        If the connection returned is ``None`` then creates a new connection.
        Because we use a last-in first-out queue, the existing connections
        (having been returned to the pool after the initial ``None`` values
        were added) will be returned before ``None`` values. This means we only
        create new connections when we need to, i.e.: the actual number of
        connections will only increase in response to demand.
        tblockR^uNo connection available.uConnection has datauConnection not readyN(R.
R]R?
RGRZR^RRR0
R�RnR�R�R+
(R-R2
R3
R4
R|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR5
Cs,


"

















cCsc|j�
|j
|
�
s7|
j�
|jjd
�

d
Sy|jj|
�

Wntk
r^


n
Xd
S(u)Releases the connection back to the pool.N(R.
R9
R�R?
R@
R]R
(R-R|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR+
ws







c
Cs,|j�
x|j
D]}
|
j�
qWd
S(u(Disconnects all connections in the pool.N(R.
RA
R�(R-R|((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR��s


(R9R?R@R�RR.R$
R0
R5
R+
R�(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR=
�s 


			4	(at
__future__Rtdistutils.versionR
t	itertoolsRRRbRPR�RUR!
R
t
redis._compatRRRRRR	R
RRR
RRRRRRRRRtredis.exceptionsRRRRRRRRRR R!R"R#R$tredis.utilsR%R�RZR�tImportErrorRAtEWOULDBLOCKR`R�tSSLWantReadErrortSSLWantWriteErrortSSLErrorR�R�R3
R_R�t__version__thiredis_versionR�tHIREDIS_SUPPORTS_BYTE_BUFFERR�tmsgR

R�R�R�RsR�R[tobjectRXR)RBRLRxR�R�R�R�R

R
R
R3R6R	
R
R=
(((sA/opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt<module>
s�








|^












	









	(#xOz
	�D63	







�G