�
c�ec@s�dd
lZdd
l
Z
ddlmZ
ddlmZmZ
ddlmZm	Z	m
Z
mZ
ddlm
Z
mZmZ
def
d��YZdef
d	��YZd
ef
d��YZdef
d
��YZdef
d��YZd
S(i����N(
tRedis(tConnectionPoolt
Connection(tConnectionErrort
ResponseErrort
ReadOnlyErrortTimeoutError(t	iteritemst	nativestrtxrangetMasterNotFoundErrorc
BseZ
RS((t__name__t
__module__(((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR
s
tSlaveNotFoundErrorc
BseZ
RS((RR(((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR
s
tSentinelManagedConnectionc
Bs5eZ
d�Zd
�Zd�Zd�Zd�ZRS(c
Ks,|
jd
�
|_
tt|�j|
�
dS(Ntconnection_pool(tpopRtsuperRt__init__(tselftkwargs((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyRs

c
CsU|j}
d
t
|�
j|
jf}|jrQd|j|jf}||}n|S(Ns%s<service=%s%%s>s,host=%s,port=%s(RttypeRtservice_namethosttport(Rtpoolt
st	host_info((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt__repr__s
	

	



cCsl|
\|_|_
tt|�j�
|jjrh|jd
�

t|j	��
dkrht
d�
�
qhndS(NtPINGtPONGsPING failed(RRRRtconnectRtcheck_connectiontsend_commandRt
read_responseR(Rtaddress((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt
connect_to s






c
Cs~|jr
dS|j
jr2|j|j
j��

nHx?|j
j�D].}
y|j|
�
SWqBtk
ro


qBqBXqBWt�
dS(
N(t_sockRt	is_masterR$tget_master_addresst
rotate_slavesRR
(Rtslave((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR(s
	








c

CsWytt
|�j�SWn9tk
rR


|jjrL|j�
td
�
�
n�n
XdS(Ns"The previous master is now a slave(RRR"RRR&t
disconnectR(
R((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR"5s







(RRRRR$RR"(((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyRs

				
tSentinelConnectionPoolc
BsDeZ
dZd
�Zd�Zd�Zd�Zd�Zd�ZRS(s�
    Sentinel backed connection pool.

    If ``check_connection`` flag is set to True, SentinelManagedConnection
    sends a PING command right after establishing the connection.
    cKs�|jd
t
�|d
<|jdt�|_|jdt�|_tt|�j	|�
t
j|�
|jd<|
|_
||_dS(Ntconnection_classR&R R(tgetRRtTrueR&tFalseR RR+Rtweakreftproxytconnection_kwargsRtsentinel_manager(RRR3R((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyRLs






	
c

Cs,d
t|�
j
|j|jr$dp'dfS(Ns%s<service=%s(%s)tmasterR)(RRRR&(
R((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyRVs



c

Cs)tt
|�j�
d|_d|_dS(
N(RR+tresettNonetmaster_addresstslave_rr_counter(
R((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR5]s

	
cCsP|jp+|jo+|j
|
j|
jfk}tt|�}|oO|j|
�
S(
N(R&R7RRRR+towns_connection(Rt
connectiontchecktparent((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR9bs



	


c
CsP|jj
|j�
}
|jrL|j|
krL|
|_|jd
t�

qLn|
S(Ntinuse_connections(R3tdiscover_masterRR&R7R*R/(RR7((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR'is
	

	

	
c
cs�|jj
|j�
}
|
r�|jdkrLtjd
t|
�
d�|_nxItt|
�
�
D]2}|jdt|
�
|_|
|j}|V
q_Wny|j	�V
Wnt
k
r�


n
Xtd|j�
�
dS(sRound-robin slave balancerii
sNo slave found for %rN(R3tdiscover_slavesRR8R6trandomtrandinttlenR	R'R
R
(Rtslavest
_R)((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR(ts


"








(	RRt__doc__RRR5R9R'R((((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR+Ds	
				tSentinelcBsheZ
dZd
d
d�Zd�Zd�Zd�Zd�Zd�Z	e
ed�Ze
ed	�Z
RS(sr
    Redis Sentinel cluster client

    >>> from redis.sentinel import Sentinel
    >>> sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1)
    >>> master = sentinel.master_for('mymaster', socket_timeout=0.1)
    >>> master.set('foo', 'bar')
    >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1)
    >>> slave.get('foo')
    b'bar'

    ``sentinels`` is a list of sentinel nodes. Each node is represented by
    a pair (hostname, port).

    ``min_other_sentinels`` defined a minimum number of peers for a sentinel.
    When querying a sentinel, if it doesn't meet this threshold, responses
    from that sentinel won't be considered valid.

    ``sentinel_kwargs`` is a dictionary of connection arguments used when
    connecting to sentinel instances. Any argument that can be passed to
    a normal Redis connection can be specified here. If ``sentinel_kwargs`` is
    not specified, any socket_timeout and socket_keepalive options specified
    in ``connection_kwargs`` will be used.

    ``connection_kwargs`` are keyword arguments that will be used when
    establishing a connection to a Redis server.
    icKsu|dkr%d
�t
|�
D�
}n||_g|
D]!\}}t|||j�^q5|_||_||_dS(Nc
Ss.i|]$\}
}|
jd�
r||
�qS(
tsocket_(
t
startswith(t.0t
kt
v((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pys
<dictcomp>�s	
	
(R6Rtsentinel_kwargsRt	sentinelstmin_other_sentinelsR2(RRMRNRLR2thostnameR((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR�s
	
.
	
c
Cseg}
x<|jD]1}|
j
d
|jjd|jjdf�

qWdt|�
jdj|
�
fS(Ns%s:%sRRs%s<sentinels=[%s]>t
,(RMtappendRR2RRtjoin(Rtsentinel_addressestsentinel((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR�s


	




cCs>|
d
s|
ds|
dr#tS|
d|j
kr:tStS(NR&tis_sdowntis_odownsnum-other-sentinels(R/RNR.(RtstateR((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pytcheck_master_state�s




cCs�x�t|j
�
D]�\}}y|j�}Wnttfk
rH


qn
X|j|
�
}|r|j||
�r||j
d
|j
d
<|j
|<|d|dfSqWtd|
f
�
�
dS(s�
        Asks sentinel servers for the Redis master's address corresponding
        to the service labeled ``service_name``.

        Returns a pair (address, port) or raises MasterNotFoundError if no
        master is found.
        itipRsNo master found for %rN(t	enumerateRMtsentinel_mastersRRR-RXR
(RRtsentinel_noRTtmastersRW((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR>�s





"

cCsPg}xC|
D];}|d
s
|dr-q
n|j|d|df�

q
W|S(s1Remove slaves that are in an ODOWN or SDOWN stateRVRURYR(
RQ(RRCtslaves_aliveR)((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt
filter_slaves�s





cCsdx]|jD]R}y|j
|
�
}Wntttfk
rB


q
n
X|j|�
}|r
|Sq
WgS(
s;Returns a list of alive slaves for service ``service_name``(RMtsentinel_slavesRRRR_(RRRTRC((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyR?�s







cKs?t|d
<t
|j�
}|j|�

|d||
||��
S(sF
        Returns a redis client instance for the ``service_name`` master.

        A SentinelConnectionPool class is used to retrive the master's
        address before establishing a new connection.

        NOTE: If the master's address has changed, any cached connections to
        the old master are closed.

        By default clients will be a redis.Redis instance. Specify a
        different class to the ``redis_class`` argument if you desire
        something different.

        The ``connection_pool_class`` specifies the connection pool to use.
        The SentinelConnectionPool will be used by default.

        All other keyword arguments are merged with any connection_kwargs
        passed to this class and passed to the connection pool as keyword
        arguments to be used to initialize Redis connections.
        R&R(R.tdictR2tupdate(RRtredis_classtconnection_pool_classRR2((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt
master_for�s





	
cKs?t|d
<t
|j�
}|j|�

|d||
||��
S(s�
        Returns redis client instance for the ``service_name`` slave(s).

        A SentinelConnectionPool class is used to retrive the slave's
        address before establishing a new connection.

        By default clients will be a redis.Redis instance. Specify a
        different class to the ``redis_class`` argument if you desire
        something different.

        The ``connection_pool_class`` specifies the connection pool to use.
        The SentinelConnectionPool will be used by default.

        All other keyword arguments are merged with any connection_kwargs
        passed to this class and passed to the connection pool as keyword
        arguments to be used to initialize Redis connections.
        R&R(R/RaR2Rb(RRRcRdRR2((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt	slave_for
s





	
N(RRRER6RRRXR>R_R?RR+ReRf(((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyRF�s						

(R@R0tredis.clientRtredis.connectionR
Rtredis.exceptionsRRRRt
redis._compatRRR	R
R
RR+tobjectRF(((s?/opt/alt/python27/lib/python2.7/site-packages/redis/sentinel.pyt<module>
s


"1C