Root Zanli
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
alt
/
python27
/
lib
/
python2.7
/
site-packages
/
redis
/
Filename :
connection.pyc
back
Copy
� ���fc @ s* d d l m Z d d l m Z d d l m Z d d l m 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 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 m Z m Z m Z m Z d d l! 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/ d d l0 m1 Z1 y d d l2 Z2 e3 Z4 Wn e5 k r�e6 Z4 n Xi e j7 e 6Z8 e4 r�e9 e2 d � r�d e8 e2 j: <d e8 e2 j; <n d e8 e2 j< <n e j= e8 k rd e8 e j= <n e> e8 j? � � Z@ e1 r�d d lA ZA e eA jB � ZC eC e d � k ZD eC e d � k ZE eC e d � k ZF eE r�d eA jB ZG e jH eG � n e3 ZI eE r�e6 ZI n n d ZJ d ZK d ZL d ZM d ZN eO � ZP d eO f d � � YZQ d eO f d � � YZR d eO f d � � YZS d eR f d � � YZT d eR f d � � YZU e1 r]eU ZV n eT ZV d eO f d � � YZW d! eW f d" � � YZX d# eW f d$ � � YZY d% d& d' d( d) f ZZ d* � Z[ i e\ d+ 6e\ d, 6e[ d- 6e[ d. 6e] d/ 6e] d0 6e[ d1 6Z^ d2 eO f d3 � � YZ_ d4 e_ f d5 � � YZ` d S(6 i����( t unicode_literals( t StrictVersion( t chain( t timeN( t xranget imapt unicodet longt nativestrt basestringt iteritemst LifoQueuet Emptyt Fullt urlparset parse_qst recvt recv_intot unquotet BlockingIOErrort sendallt shutdownt ssl_wrap_socket( t AuthenticationErrort$ AuthenticationWrongNumberOfArgsErrort BusyLoadingErrort ChildDeadlockedErrort ConnectionErrort DataErrort ExecAbortErrort InvalidResponset NoPermissionErrort NoScriptErrort ReadOnlyErrort RedisErrort ResponseErrort TimeoutError( t HIREDIS_AVAILABLEu SSLWantReadErrori i���u 0.1.3u 0.1.4u 1.0.0u` redis-py works best with hiredis >= 0.1.4. You're running hiredis %s. Please consider upgrading.t *t $s t u Connection closed by server.t Encoderc B s, e Z d Z d � Z d � Z e d � Z RS( u= Encode strings to bytes-like and decode bytes-like to stringsc C s | | _ | | _ | | _ d S( N( t encodingt encoding_errorst decode_responses( t selfR* R+ R, ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt __init__b s c C s� t | t t f � r | St | t � r7 t d � � n t | t � r[ t | � j � } n[ t | t t f � r� t | � j � } n1 t | t � s� t | � j } t d | � � n t | t � r� | j | j | j � } n | S( u= Return a bytestring or bytes-like representation of the valueuN Invalid input of type: 'bool'. Convert to a bytes, string, int or float first.uL Invalid input of type: '%s'. Convert to a bytes, string, int or float first.( t isinstancet bytest memoryviewt boolR t floatt reprt encodet intR t strR t typet __name__R R* R+ ( R- t valuet typename( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR5 g s c C s^ | j s | rZ t | t � r- | j � } n t | t � rZ | j | j | j � } qZ n | S( u: Return a unicode string from the bytes-like representation( R, R/ R1 t tobytesR0 t decodeR* R+ ( R- R: t force( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR= } s ( R9 t __module__t __doc__R. R5 t FalseR= ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR) _ s t BaseParserc B sk e Z i i e d 6e d 6e d 6e d 6e d 6d 6e d 6e d 6e d 6e d 6e d 6e d 6Z d � Z RS( u max number of clients reachedu( Client sent AUTH, but no password is setu invalid passwordu, wrong number of arguments for 'auth' commandu, wrong number of arguments for 'AUTH' commandu ERRu EXECABORTu LOADINGu NOSCRIPTu READONLYu NOAUTHu NOPERMc C s{ | j d � d } | | j k rq | t | � d } | j | } t | t � rg | j | t � } n | | � St | � S( u Parse an error responseu i i ( t splitt EXCEPTION_CLASSESt lenR/ t dictt getR# ( R- t responset error_codet exception_class( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt parse_error� s ( R9 R? R R R R R R R! R RD RK ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRB � s t SocketBufferc B s_ e Z d � Z e d � � Z d e e d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s@ | | _ | | _ | | _ t j � | _ d | _ d | _ d S( Ni ( t _sockt socket_read_sizet socket_timeoutt iot BytesIOt _buffert bytes_writtent bytes_read( R- t socketRN RO ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. � s c C s | j | j S( N( RS RT ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt length� s c C s� | j } | j } | j } | j | j � d } | t k } zBy� | rY | j | � n x� t r� t | j | � } t | t � r� t | � d k r� t t � � n | j | � t | � } | j | 7_ | | 7} | d k r� | | k r� q\ n t SWWn� t j k r&| r"t d � � n t St k r}} t j | j d � } | rd| j | k rdt St d | j f � � n XWd | r�| j | j � n Xd S( Ni u Timeout reading from socketi����u# Error while reading from socket: %s( RM RN RR t seekRS t SENTINELt settimeoutt TrueR R/ R0 RE R t SERVER_CLOSED_CONNECTION_ERRORt writet NoneRU t timeoutR$ RA t NONBLOCKING_EXCEPTIONSt# NONBLOCKING_EXCEPTION_ERROR_NUMBERSRG t __class__t errnot argsRO ( R- RV R^ t raise_on_timeoutt sockRN t buft markert custom_timeoutt datat data_lengtht ext allowed( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt _read_from_socket� sB ! c C s% t | j � p$ | j d | d t � S( NR^ Rd ( R2 RV Rm RA ( R- R^ ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt can_read� s c C s� | d } | | j k r0 | j | | j � n | j j | j � | j j | � } | j t | � 7_ | j | j k r� | j � n | d S( Ni i����( RV Rm RR RW RT t readRE RS t purge( R- RV Ri ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRo � s c C s� | j } | j | j � | j � } x9 | j t � s` | j � | j | j � | j � } q( W| j t | � 7_ | j | j k r� | j � n | d S( Ni����( RR RW RT t readlinet endswitht SYM_CRLFRm RE RS Rp ( R- Rf Ri ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRq � s c C s3 | j j d � | j j � d | _ d | _ d S( Ni ( RR RW t truncateRS RT ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRp s c C sE y | j � | j j � Wn t k r. n Xd | _ d | _ d S( N( Rp RR t closet ExceptionR] RM ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRu s N( R9 R? R. t propertyRV R] RX RZ Rm Rn Ro Rq Rp Ru ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRL � s * t PythonParserc B sD e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z RS( u Plain Python parsing classc C s( | | _ d | _ d | _ d | _ d S( N( RN R] t encoderRM RR ( R- RN ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. $ s c C s& y | j � Wn t k r! n Xd S( N( t on_disconnectRv ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt __del__* s c C s: | j | _ t | j | j | j � | _ | j | _ d S( u Called when the socket connectsN( RM RL RN RO RR Ry ( R- t connection( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt on_connect0 s c C s> d | _ | j d k r1 | j j � d | _ n d | _ d S( u" Called when the socket disconnectsN( R] RM RR Ru Ry ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRz 8 s c C s | j o | j j | � S( N( RR Rn ( R- R^ ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRn @ s c C sz | j j � } | s$ t t � � n | d | d } } | d k rX t d | � � n | d k r� t | � } | j | � } t | t � r� | � n | S| d k r� n� | d k r� t | � } n� | d k rt | � } | d k r� d S| j j | � } nP | d k rRt | � } | d k r*d Sg t | � D] } | j � ^ q7} n t | t � rv| j j | � } n | S( Ni t -t +t :R' R& u Protocol Error: %ri����( R~ R R� R' R& ( RR Rq R R[ R R RK R/ R R6 R] Ro R t read_responseR0 Ry R= ( R- t rawt byteRH t errorRV t i( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� C s: (( R9 R? R@ R. R{ R} Rz Rn R� ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRx " s t HiredisParserc B sS e Z d Z d � Z d � Z d � Z d � Z d � Z e e d � Z d � Z RS( u* Parser class for connections using Hiredisc C s: t s t d � � n | | _ t r6 t | � | _ n d S( Nu Hiredis is not installed( R% R" RN t HIREDIS_USE_BYTE_BUFFERt bytearrayRR ( R- RN ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. s s c C s& y | j � Wn t k r! n Xd S( N( Rz Rv ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR{ { s c C s� | j | _ | j | _ i t d 6| j d 6} t sB t | d <n | j j ra | j j | d <n t rz | j j | d <n t j | � | _ t | _ d S( Nu protocolErroru replyErroru encodingu errors( RM RO t _socket_timeoutR RK t HIREDIS_SUPPORTS_CALLABLE_ERRORSR# Ry R, R* t HIREDIS_SUPPORTS_ENCODING_ERRORSR+ t hiredist Readert _readerRA t _next_response( R- R| t kwargs( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR} � s c C s d | _ d | _ t | _ d S( N( R] RM R� RA R� ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRz � s c C se | j s t t � � n | j t k ra | j j � | _ | j t k ra | j d | d t � Sn t S( NR^ Rd ( R� R R[ R� RA t getst read_from_socketRZ ( R- R^ ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRn � s c C s� | j } | t k } zNy� | r1 | j | � n t r� t | j | j � } | d k rg t t � � n | j j | j d | � nV t | j | j � } t | t � s� t | � d k r� t t � � n | j j | � t SWn� t j k r | rt d � � n t St k ra} t j | j d � } | rH| j | k rHt St d | j f � � n XWd | r| j | j � n Xd S( Ni u Timeout reading from socketi����u# Error while reading from socket: %s( RM RX RY R� R RR R R[ R� t feedR RN R/ R0 RE RZ RU R^ R$ RA R_ R` RG Ra Rb Rc R� ( R- R^ Rd Re Rh t bufflent bufferRk Rl ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s8 "c C sC | j s t t � � n | j t k r= | j } t | _ | S| j j � } x) | t k rw | j � | j j � } qO Wt s� t | t � r� | j | j d � } q� t | t � r� | r� t | d t � r� | j | d j d � | d <q� n t | t � r | � n5 t | t � r?| r?t | d t � r?| d � n | S( Ni ( R� R R[ R� RA R� R� R� R/ R# RK Rc t list( R- RH ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s, $ ( R9 R? R@ R. R{ R} Rz Rn RX RZ R� R� ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� q s &t Connectionc B s� e Z d Z d d d d d d e d d e d d e e d d d 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 e d � Z d � Z d d � Z d � Z d � Z d � Z RS( u4 Manages TCP communication to and from a Redis serveru localhosti� i u utf-8u stricti c C s� t j � | _ | | _ t | � | _ | | _ | | _ | | _ | | _ | | _ | p] | | _ | | _ | pu i | _ | | _ | | _ | | _ d | _ t | | | � | _ d | _ | d | � | _ g | _ d | _ d S( Ni RN ip ( t ost getpidt pidt hostR6 t portt dbt usernamet client_namet passwordRO t socket_connect_timeoutt socket_keepalivet socket_keepalive_optionst socket_typet retry_on_timeoutt health_check_intervalt next_health_checkR) Ry R] RM t _parsert _connect_callbackst _buffer_cutoff( R- R� R� R� R� RO R� R� R� R� R� R* R+ R, t parser_classRN R� R� R� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. � s( c C sL d j g | j � D] \ } } d | | f ^ q � } d | j j | f S( Nu ,u %s=%su %s<%s>( t joint repr_piecesRa R9 ( R- t kt vt repr_args( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt __repr__ s 8c C sP d | j f d | j f d | j f g } | j rL | j d | j f � n | S( Nu hostu portu dbu client_name( R� R� R� R� t append( R- t pieces( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� s c C s& y | j � Wn t k r! n Xd S( N( t disconnectRv ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR{ s c C s | j j | � d S( N( R� R� ( R- t callback( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt register_connect_callback$ s c C s g | _ d S( N( R� ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt clear_connect_callbacks' s c C s� | j r d Sy | j � } WnJ t j k r? t d � � n+ t j k ri } t | j | � � � n X| | _ y | j � Wn t k r� | j � � n Xx | j D] } | | � q� Wd S( u5 Connects to the Redis server if not already connectedNu Timeout connecting to server( RM t _connectRU R^ R$ R� R t _error_messageR} R" R� R� ( R- Re t eR� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt connect* s c C sn d } x=t j | j | j | j t j � D]} | \ } } } } } d } y� t j | | | � } | j t j t j d � | j r� | j t j t j d � x6 t | j � D]" \ } } | j t j | | � q� Wn | j | j � | j | � | j | j � | SWq+ t j k rA} | } | d k rB| j � qBq+ Xq+ W| d k r[| � n t j d � � d S( u Create a TCP socket connectioni u) socket.getaddrinfo returned an empty listN( R] RU t getaddrinfoR� R� R� t SOCK_STREAMt setsockoptt IPPROTO_TCPt TCP_NODELAYR� t SOL_SOCKETt SO_KEEPALIVER R� RY R� R� RO R� Ru ( R- t errt rest familyt socktypet protot canonnamet socket_addressRe R� R� t _( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� B s. c C s_ t | j � d k r3 d | j | j | j d f Sd | j d | j | j | j d f Sd S( Ni u Error connecting to %s:%s. %s.i u! Error %s connecting to %s:%s. %s.( RE Rc R� R� ( R- t exception( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� j s c C sh | j j | � | j s" | j r� | j rF | j | j p= d f } n | j f } | j d d t | �y | j � } Wn6 t k r� | j d | j d t �| j � } n Xt | � d k r� t d � � q� n | j r | j d d | j � t | j � � d k r t d � � q n | j rd| j d | j � t | j � � d k rdt d � � qdn d S( u= Initialize the connection, authenticate and select a databaseu u AUTHt check_healthu OKu Invalid Username or Passwordu CLIENTu SETNAMEu Error setting client nameu SELECTu Invalid DatabaseN( R� R} R� R� t send_commandRA R� R R R R� R R� ( R- t auth_argst auth_response( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR} t s* c C s� | j j � | j d k r d Sy< t j � | j k rN t | j t j � n | j j � Wn t j k rr n Xd | _ d S( u! Disconnects from the Redis serverN( R� Rz RM R] R� R� R� R RU t SHUT_RDWRRu R� ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s c C s� | j r� t � | j k r� y> | j d d t �t | j � � d k rX t d � � n Wq� t t f k r� | j � | j d d t �t | j � � d k r� t d � � q� q� Xn d S( u3 Check the health of the connection with a PING/PONGu PINGR� u PONGu# Bad response from PING health checkN( R� R R� R� RA R R� R R$ R� ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s c C s2 | j s | j � n | r) | j � n y@ t | t � rG | g } n x | D] } t | j | � qN WWn� t j k r� | j � t d � � n� t j k r} | j � t | j � d k r� d | j d } } n | j d } | j d } t d | | f � � n t k r-| j � � n Xd S( u2 Send an already packed command to the Redis serveru Timeout writing to socketi u UNKNOWNi u% Error %s while writing to socket. %s.N( RM R� R� R/ R7 R RU R^ R� R$ R� RE Rc R t BaseException( R- t commandR� t itemR� Rb t errmsg( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt send_packed_command� s. c O s, | j | j | � d | j d t � �d S( u+ Pack and send a command to the Redis serverR� u check_healthN( R� t pack_commandRG RZ ( R- Rc R� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s c C s5 | j } | s% | j � | j } n | j j | � S( u8 Poll the socket to see if there's data that can be read.( RM R� R� Rn ( R- R^ Re ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyRn � s c C s� y | j j � } Wn� t j k rO | j � t d | j | j f � � n_ t j k r� } | j � t d | j | j | j f � � n t k r� | j � � n X| j r� t � | j | _ n t | t � r� | � n | S( u0 Read the response from a previously sent commandu Timeout reading from %s:%su# Error while reading from %s:%s : %s( R� R� RU R^ R� R$ R� R� R� R Rc R� R� R R� R/ R# ( R- RH R� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s$ c G s� g } t | d t � r@ t | d j � j � � | d } n1 d | d k rq t | d j � � | d } n t j t t t | � � j � t f � } | j } x� t | j j | � D]� } t | � } t | � | k s� | | k s� t | t � rCt j | t t | � j � t f � } | j | � | j | � t } q� t j | t t | � j � t | t f � } q� W| j | � | S( u2 Pack a series of arguments into the Redis protocoli i t ( R/ R t tupleR5 RC t SYM_EMPTYR� t SYM_STARR7 RE Rs R� R Ry R1 t SYM_DOLLARR� ( R- Rc t outputt bufft buffer_cutofft argt arg_length( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s* '!* ! c C s g } g } d } | j } x� | D]� } x� | j | � D]� } t | � } | | k sq | | k sq t | t � r� | j t j | � � d } g } n | | k s� t | t � r� | j | � q8 | j | � | | 7} q8 Wq" W| r� | j t j | � � n | S( u. Pack multiple commands into the Redis protocoli ( R� R� RE R/ R1 R� R� R� ( R- t commandsR� R� t buffer_lengthR� t cmdt chunkt chunklen( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt pack_commands s& N( R9 R? R@ R] RA t DefaultParserR. R� R� R{ R� R� R� R� R� R} R� R� RZ R� R� Rn R� R� R� ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s2 ( ' "t SSLConnectionc B s) e Z d d d d e d � Z d � Z RS( u requiredc K s� t s t d � � n t t | � j | � | | _ | | _ | d k rU t j } n_ t | t � r� i t j d 6t j d 6t j d 6} | | k r� t d | � � n | | } n | | _ | | _ | | _ d S( Nu$ Python wasn't built with SSL supportu noneu optionalu requiredu- Invalid SSL Certificate Requirements Flag: %s( t ssl_availableR" t superR� R. t keyfilet certfileR] t sslt CERT_NONER/ R t CERT_OPTIONALt CERT_REQUIREDt cert_reqst ca_certst check_hostname( R- t ssl_keyfilet ssl_certfilet ssl_cert_reqst ssl_ca_certst ssl_check_hostnameR� t CERT_REQS( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. 6 s( c C s� t t | � j � } t t d � r� t j � } | j | _ | j | _ | j ry | j ry | j d | j d | j � n | j r� | j | j � n t | | d | j �} n3 t t | d | j d | j d | j d | j �} | S( u Wrap the socket with SSL supportu create_default_contextR� R� t server_hostnameR� R� ( R� R� R� t hasattrR� t create_default_contextR� R� t verify_modeR� R� t load_cert_chainR� t load_verify_locationsR R� ( R- Re t context( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� Q s$ N( R9 R? R] RA R. R� ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� 4 s t UnixDomainSocketConnectionc B sS e Z d d d d d d d e e e d d d d � Z d � Z d � Z d � Z RS( u i u utf-8u stricti c C s� t j � | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ | | _ d | _ t | | | � | _ d | _ | d | � | _ g | _ d | _ d S( Ni RN ip ( R� R� R� t pathR� R� R� R� RO R� R� R� R) Ry R] RM R� R� R� ( R- R R� R� R� RO R* R+ R, R� R� RN R� R� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. l s c C sD d | j f d | j f g } | j r@ | j d | j f � n | S( Nu pathu dbu client_name( R R� R� R� ( R- R� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s c C s< t j t j t j � } | j | j � | j | j � | S( u& Create a Unix domain socket connection( RU t AF_UNIXR� RY RO R� R ( R- Re ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s c C sS t | j � d k r- d | j | j d f Sd | j d | j | j d f Sd S( Ni u( Error connecting to unix socket: %s. %s.i u+ Error %s connecting to unix socket: %s. %s.( RE Rc R ( R- R� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s N( R9 R? R] RA R� R. R� R� R� ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR j s u 0u Fu FALSEu Nu NOc C sK | d k s | d k r d St | t � rA | j � t k rA t St | � S( Nu ( R] R/ R t uppert FALSE_STRINGSRA R2 ( R: ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt to_bool� s !u socket_timeoutu socket_connect_timeoutu socket_keepaliveu retry_on_timeoutu max_connectionsu health_check_intervalu ssl_check_hostnamet ConnectionPoolc B s� e Z d Z e d e d � � Z e d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � Z RS( u Generic connection poolc K s% t | � } i } x� t t | j � � D]� \ } } | r( t | � d k r( t j | � } | r� y | | d � | | <Wq� t t f k r� t j t d | � � q� Xq� | d | | <q( q( W| rC| j r� t | j � n d } | j r� t | j � n d } | j r t | j � n d } | j r:t | j � n d } n0 | j pOd } | j p^d } | j } | j } | j d k r�| j i | d 6| d 6| d 6t d 6� n� | j d k rc| j i | d 6t | j p�d � d 6| d 6| d 6� d | k rD| rDy t | j d d � � | d <WqDt t f k r@qDXn | j d k r�t | d <q�n d j d � } t d | � � t | j d | p�d � � | d <| j | � d | k r�t j t d � � | j d � | d <n d | k rt j t d � � | j d � | 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. i u) Invalid value for `%s` in connection URL.u unixu usernameu passwordu pathu connection_classu redisu redissu hosti� u portu dbu /u u , u redis://u rediss://u unix://u8 Redis URL must specify one of the following schemes (%s)u charsetu/ "charset" is deprecated. Use "encoding" insteadu encodingu errorsu5 "errors" is deprecated. Use "encoding_errors" insteadu encoding_errorsN( u redisu rediss( u redis://u rediss://u unix://( R R R t queryRE t URL_QUERY_ARGUMENT_PARSERSRG t TypeErrort ValueErrort warningst warnt UserWarningR� R R] R� R t hostnamet schemet updateR R6 R� t replacet AttributeErrorR� R� t DeprecationWarningt pop( t clst urlR� t decode_componentsR� t url_optionst nameR: t parserR� R� R R t valid_schemes( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt from_url� sl . " ! " c K su | p d } t | t t f � s. | d k r= t d � � n | | _ | | _ | | _ t j � | _ | j � d S( 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. i i i u, "max_connections" must be a positive integerNI � ( R/ R6 R R t connection_classt connection_kwargst max_connectionst threadingt Lockt _fork_lockt reset( R- R R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. 0 s " c C s) d t | � j t | j | j � � f S( Nu %s<%s>( R8 R9 R4 R R ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� O s c C s@ t j � | _ d | _ g | _ t � | _ t j � | _ d S( Ni ( R! R" t _lockt _created_connectionst _available_connectionst sett _in_use_connectionsR� R� R� ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR$ U s c C s� | j t j � k r� t � d } t } x/ t � | k rY | j j t � } | r+ Pq+ q+ W| si t � n z& | j t j � k r� | j � n Wd | j j � Xn d S( Ni ( R� R� R� R RA R# t acquireR R$ t release( R- t timeout_att acquired( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt _checkpidf s # c O s� | j � | j �H y | j j � } Wn t k rF | j � } n X| j j | � Wd QXyp | j � y | j � r� t d � � n Wn@ t k r� | j � | j � | j � r� t d � � q� n XWn! t k r� | j | � � n X| S( u Get a connection from the poolNu Connection has datau Connection not ready( R. R% R' R t IndexErrort make_connectionR) t addR� Rn R R� R� R+ ( R- t command_namet keyst optionsR| ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt get_connection� s* c C sF | j } t d | j d d � d | j d d � d | j d t � � S( u, Return an encoder based on encoding settingsR* u encodingu utf-8R+ u encoding_errorsu strictR, u decode_responses( R R) RG RA ( R- R� ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt get_encoder� s c C s@ | j | j k r! t d � � n | j d 7_ | j | j � S( u Create a new connectionu Too many connectionsi ( R& R R R R ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR0 � s c C s� | j � | j �l y | j j | � Wn t k r; n X| j | � r^ | j j | � n | j d 8_ | j � d SWd QXd S( u( Releases the connection back to the pooli N( R. R% R) t removet KeyErrort owns_connectionR' R� R& R� ( R- R| ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR+ � s c C s | j | j k S( N( R� ( R- R| ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR9 � s c C s` | j � | j �G | r2 t | j | j � } n | j } x | D] } | j � qB WWd 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% R R' R) R� ( R- t inuse_connectionst connectionsR| ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR� � s N( R9 R? R@ t classmethodR] RA R R� R. R� R$ R. R5 R6 R0 R+ R9 RZ R� ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR � s z 6 ! t BlockingConnectionPoolc B sP e Z d Z d d e e d � Z d � Z d � Z d � Z d � 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) i2 i c K s8 | | _ | | _ t t | � j d | d | | � d S( NR R ( t queue_classR^ R� R= R. ( R- R R^ R R> R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR. s c C sg | j | j � | _ x3 t rJ y | j j d � Wq t k rF Pq Xq Wg | _ t j � | _ d S( N( R> R t poolRZ t put_nowaitR] R t _connectionsR� R� R� ( R- ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR$ % s c C s& | j | j � } | j j | � | S( u Make a fresh connection.( R R RA R� ( R- R| ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR0 = s c O s | j � d } y" | j j d t d | j � } Wn t k rQ t d � � n X| d k rm | j � } n yp | j � y | j � r� t d � � n Wn@ t k r� | j � | j � | j � r� t d � � 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. t blockR^ u No connection available.u Connection has datau Connection not readyN( R. R] R? RG RZ R^ R R R0 R� Rn R� R� R+ ( R- R2 R3 R4 R| ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR5 C s, " c C sc | j � | j | � s7 | j � | j j d � d Sy | j j | � Wn t k 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+ w s c C s, | j � x | j D] } | j � q Wd 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 ( R9 R? R@ R� R R. R$ R0 R5 R+ R� ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyR= � s 4 (a t __future__R t distutils.versionR t itertoolsR R Rb RP R� RU R! R t redis._compatR R R R R R R R R R R R R R R R R R R t redis.exceptionsR R R R R R R R R R R! R" R# R$ t redis.utilsR% R� RZ R� t ImportErrorRA t EWOULDBLOCKR` R� t SSLWantReadErrort SSLWantWriteErrort SSLErrorR� R� R3 R_ R� t __version__t hiredis_versionR� t HIREDIS_SUPPORTS_BYTE_BUFFERR� t msgR R� R� R� Rs R� R[ t objectRX R) RB RL Rx R� R� R� R� R R R R3 R6 R R R= ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/redis/connection.pyt <module> s� |^ (#xOz � D63 � G