o ;h @s<UddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZmZmZmZmZmZmZmZmZmZmZmZmZddlmZmZmZm Z ddl!m"Z"e"rrddl#Z#dd l#m$Z$m%Z%ndZ#dZ%dZ$dd l&m'Z'dd l(m)Z)m*Z*dd l!m+Z+m,Z,ej-d krddlm.Z/nddl/m.Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7m8Z8ddl9m:Z:m;Z;mZ>m?Z?m@Z@ddlAmBZBddlCmDZDmEZEmFZFddlGmHZHmIZImJZJmKZKmLZLdZMdZNdZOdZPdZQGdddejRZSeSjTZUeeeKeLeJfeVd<eDreJZWneKZWGdd d eZXGd!d"d"eZYeeXeYfZZGd#d$d$Z[Gd%d&d&e[Z\Gd'd(d(e\Z]Gd)d*d*Z^Gd+d,d,e[Z_d-Z`d.eeafd/d0Zbe ecededebebececebedd1 Zeeefed2egffeVd3<Gd4d5d5ed6d7Zhd8efd.ehfd9d:Zied;dd<d<ZkGd?d@d@ekZldS)AN)abstractmethod)chain)MappingProxyType) AnyCallableIterableListMappingOptionalProtocolSetTupleType TypedDictTypeVarUnion) ParseResultparse_qsunquoteurlparse) SSL_AVAILABLE) SSLContext TLSVersion)TokenInterface)!AsyncAfterConnectionReleasedEventEventDispatcher)deprecated_argsformat_error_message) r)timeout)Retry) NoBackoff)DEFAULT_RESP_VERSION)CredentialProvider"UsernamePasswordCredentialProvider)AuthenticationError$AuthenticationWrongNumberOfArgsErrorConnectionError DataError RedisError ResponseError TimeoutError) EncodableT)HIREDIS_AVAILABLEget_lib_version str_if_bytes) BaseParserEncoder_AsyncHiredisParser_AsyncRESP2Parser_AsyncRESP3Parser*$s  c@seZdZeZdS) _SentinelN)__name__ __module__ __qualname__objectsentinelrArAK/var/www/html/venv/lib/python3.10/site-packages/redis/asyncio/connection.pyr;Qs r; DefaultParserc@eZdZdddZdS)ConnectCallbackProtocol connectionAbstractConnectioncCdSNrAselfrFrArArB__call__`sz ConnectCallbackProtocol.__call__NrFrGr<r=r>rLrArArArBrE_rEc@rD)AsyncConnectCallbackProtocolrFrGcdSrIrArJrArArBrLdsz%AsyncConnectCallbackProtocol.__call__NrMrNrArArArBrPcrOrPc.@seZdZdZdZdddddedddedddd edddedd dd d e e e fd e e de e de e dede eefde de dedeede de de e de e de e de e de ede edeede ed e e d!e ef,d"d#Zefd$efd%d&Zd'd(Zd)d*Zed+d,Zed-d.Z d/d0Z!d1d2Z"deed3dfd4d5Z#d6d7Z$drd9efd:d;Z%edd?Z'd@e(d3e fdAdBZ)dCdDZ*dsdEdFZ+drd9ed3dfdGdHZ,dtdIed3dfdJdKZ-dLdMZ.dNdOZ/dPdQZ0dRe1e2d3dfdSdTZ3 8drdRe e2e e1e2fd9ed3dfdUdVZ4dWedXed3dfdYdZZ5d[d\Z6  dud8dd]d^ed_e e d`edae efdbdcZ7dWe8d3e9e2fdddeZ:dfe1e1e8d3e9e2fdgdhZ;didjZfdndoZ?dpdqZ@dS)vrGz0Manages communication to and from a Redis server)dbusername client_namelib_name lib_versioncredential_providerpasswordsocket_timeoutsocket_connect_timeoutredis_connect_funcretry_on_timeoutretry_on_errorhealth_check_intervalnext_health_checkZlast_active_atencoder ssl_contextprotocol_reader_writer_parser_connect_callbacks_buffer_cutoff_lock_socket_read_size__dict__rNFutf-8strictizredis-pyr)rRrXrYrZr\r]encodingencoding_errorsdecode_responses parser_classsocket_read_sizer^rTrUrVrSretryr[ encoder_classrWrbevent_dispatcherrRrXrYrZr\r]rmrnrorprqr^rTrUrVrSrrr[rsrWrbrtcCs|s|r |dur td|durt|_n||_||_| |_||_||_||_||_||_ ||_ |dur6|}||_ ||_ |t urBg}|rU|t|tj|tj||_|s\|rs|sfttd|_nt||_|j|nttd|_| |_d|_|||| |_||_d|_d|_| |_ |!| g|_"d|_#d|_$z.zt%|}Wnt&yt'}Yn t(yt)dwW|dks|dkrt)d ||_*dS|dks|dkrt)d ||_*w) Nz'username' and 'password' cannot be passed along with 'credential_provider'. Please provide only one of the following arguments: 1. 'password' and (optional) 'username' 2. 'credential_provider'ripzprotocol must be an integerrrzprotocol must be either 2 or 3)+r*r_event_dispatcherrRrTrUrVrWrXrSrYrZr\SENTINELappendr-socketr!asyncior]r"r#rrcopydeepcopyZupdate_supported_errorsr^r_r`r[rcrdri set_parserrfrg_re_auth_tokenint TypeErrorr$ ValueErrorr)rb)rKrRrXrYrZr\r]rmrnrorprqr^rTrUrVrSrrr[rsrWrbrtprArArB__init__sr          zAbstractConnection.__init__ _warningscCsRt|ddr'|jd|t|dz t|WdSty&YdSwdS)Nrdzunclosed Connection )source)getattrwarnResourceWarningr{get_running_loop_close RuntimeError)rKrrArArB__del__s   zAbstractConnection.__del__cCs$|jr|jd|_|_dSdS)zR Internal method to silently close the connection without waiting N)rdclosercrKrArArBrs zAbstractConnection._closecCs8ddd|D}d|jjd|jjd|dS)N,css"|] \}}|d|VqdS)=NrA).0kvrArArB s z.AbstractConnection.__repr__..<.()>)join repr_pieces __class__r=r<)rKZ repr_argsrArArB__repr__s zAbstractConnection.__repr__cCrHrIrArrArArBrzAbstractConnection.repr_piecescCs|jduo |jduSrI)rcrdrrArArB is_connectedszAbstractConnection.is_connectedcCs(t|}||jvr|j|dSdS)a^ Register a callback to be called when the connection is established either initially or reconnected. This allows listeners to issue commands that are ephemeral to the connection, for example pub/sub subscription or key tracking. The callback must be a _method_ and will be kept as a weak reference. N)weakref WeakMethodrfry)rKcallbackZwmrArArBregister_connect_callbacks  z,AbstractConnection.register_connect_callbackcCs.z |jt|WdStyYdSw)z De-register a previously registered callback. It will no-longer receive notifications on connection events. Calling this is not required when the listener goes away, since the callbacks are kept as weak methods. N)rfremoverrr)rKrrArArBderegister_connect_callbacks  z.AbstractConnection.deregister_connect_callbackreturncCs||jd|_dS)z Creates a new instance of parser_class with socket size: _socket_read_size and assigns it to the parser for the connection :param parser_class: The required parser class )rqN)rire)rKrprArArBr~szAbstractConnection.set_parserc|jddIdHdS)z5Connects to the Redis server if not already connectedT check_healthN)connect_check_healthrrArArBconnect&zAbstractConnection.connectTrc sTjrdSzjfddfddIdHWn9tjy#tjtjfy1tdtyC}zt |d}~wt yS}zt ||d}~wwz"j sbj |dIdHntj rp IdHn WntyIdHwddjD_jD]}|}|}|rt|r|IdHqdS)NcSrI)_connectrArrArB/z9AbstractConnection.connect_check_health..crrI disconnecterrorrrArBr/rzTimeout connecting to serverrcSsg|]}|r|qSrArA)rrefrArArB Msz;AbstractConnection.connect_check_health..)rrrcall_with_retryr{ZCancelledErrorrzr!r-OSErrorr)_error_message Exceptionr[on_connect_check_healthiscoroutinefunctionr+rrfinspect isawaitable)rKreexcrrtaskrArrBr*sJ     z'AbstractConnection.connect_check_healthcrQrIrArrArArBrTszAbstractConnection._connectcCrHrIrArrArArB _host_errorXrzAbstractConnection._host_error exceptioncCst||SrI)rr)rKrrArArBr\z!AbstractConnection._error_messagecC|jSrI)rbrrArArB get_protocol_zAbstractConnection.get_protocolcr)z=Initialize the connection, authenticate and select a databaseTrN)rrrArArB on_connectbrzAbstractConnection.on_connectc s|j||j}d}|js|js|jr&|jpt|j|j}|IdH}|r|jdvrt|jt rC| t |j |j_ |j|t |dkrOd|dg}|jd|jdg|RddiIdH|IdH}|d t|jkr|d t|jkrtd nq|r|jdg|RddiIdHz |IdH}Wnty|jd|d dd IdH|IdH}Ynwt|dkrtdn.|jdvrt|jt r| t |j |j_ |j||jd|j|d IdH|IdH}|jr|jdd|j|d IdHt|IdHdkrtd|jr%|jddd|j|d IdH|jr7|jddd|j|d IdH|jrG|jd|j|d IdHdd|j|jfDD]}z |IdHWqRtyiYqRw|jr~t|IdHdkrtddSdS)N)r2rudefaultrZHELLOAUTHrFsprotoprotozInvalid RESP versionrvrOKzInvalid Username or PasswordZCLIENTZSETNAMEzError setting client nameZSETINFOzLIB-NAMEzLIB-VERZSELECTcss|]}|r|VqdSrIrA)rsentrArArBrz=AbstractConnection.on_connect_check_health..zInvalid Database)rerrWrSrXr&Zget_credentials_asyncrb isinstancer5r~r6ZEXCEPTION_CLASSESlen send_command read_responsegetrr)r(r1r'rTrUrVrRr,)rKrparserZ auth_argsZ cred_providerresponseZ auth_response_rArArBrfs                   z*AbstractConnection.on_connect_check_healthnowaitc szdt|j4IdHM|j|js! WdIdHWdSz#z|j|s2|jIdHWn ty<YnwWd|_ d|_nd|_ d|_wWdIdHWdS1IdHs^wYWdSt j yvt d|jdw)z!Disconnects from the Redis serverNz#Timed out closing connection after ) async_timeoutrZreZ on_disconnectrrdrZ wait_closedrrcr{r-)rKrrArArBrs8    2 zAbstractConnection.disconnectcs8|jdddIdHt|IdHdkrtddS)z Send PING, expect PONG in returnZPINGFrNZPONGz#Bad response from PING health check)rr1rr)rrArArB _send_pings zAbstractConnection._send_pingc|IdHdS)z Function to call when PING failsNrrKrrArArB _ping_failedzAbstractConnection._ping_failedcs>|jrt|jkr|j|j|jIdHdSdSdS)z3Check the health of the connection with a PING/PONGN) r^r{rtimer_rrrrrrrArArBrszAbstractConnection.check_healthcommandcs"|j||jIdHdSrI)rd writelinesdrain)rKrrArArB_send_packed_commands z'AbstractConnection._send_packed_commandc sX|js |jddIdH|r|IdHz5t|tr |}t|tr(|g}|jr;t | ||jIdHWdS|j ||j IdHWdStjya|jddIdHtddty}z/|jddIdHt|jdkrd|jd}}n |jd}|jd}td |d |d |d}~wty|jddIdHw) NFrTrzTimeout writing to socketruUNKNOWNrzError z while writing to socket. r)rrrrstrencodebytesrYr{wait_forrrdrrr-rrrargsr) BaseException)rKrrrZerr_noerrmsgrArArBsend_packed_commandsF        z&AbstractConnection.send_packed_commandrkwargscs(|j|j||dddIdHdS)z+Pack and send a command to the Redis serverrTrN)r pack_commandr)rKrrrArArBr(szAbstractConnection.send_commandc s^z |jIdHWSty.}z|jddIdH|}td|d|jd}~ww)z8Poll the socket to see if there's data that can be read.NTrError while reading from z: )recan_read_destructiverrrr)r)rKr host_errorrArArBr.sz'AbstractConnection.can_read_destructive)disconnect_on_error push_requestdisable_decodingr!rrc s|dur|n|j}|}z}|durB|jdvrBt|4IdH|jj||dIdH}WdIdHn 1IdHs}t |}t ||ksd||ksdt|tr~t|tt|t f}||||t }qOt|tt|t |t f}qO|||S)z2Pack a series of arguments into the Redis protocolrruN )rfloatrtuplersplit SYM_EMPTYrSYM_STARrSYM_CRLFrgmapr` memoryview SYM_DOLLARry)rKroutputZbuff buffer_cutoffargZ arg_lengthrArArBrqs>"      zAbstractConnection.pack_commandcommandsc Csg}g}d}|j}|D]A}|j|D]9}t|}||ks%||ks%t|tr3|r/|t|d}g}||ks__doc__ __slots__rxrCr0r3rrrr rboollistr;rr2r"ConnectCallbackTr%rrwarningsrrrrrrpropertyrrrr~rrrrrrrrrrrrrrrrrrrrr.rrr r r rrrrArArArBrGjs         Y    *  l )  :. rGcseZdZdZddddddded eeefd ed ee eeee ffd ef fd dZ ddZ de fddZ ddZdefddZZS) Connectionz4Manages TCP communication to and from a Redis server localhostiFNr)hostportsocket_keepalivesocket_keepalive_options socket_typer r!r"r#r$c s<||_t||_||_|pi|_||_tjdi|dSNrA)r rr!r"r#r$superr)rKr r!r"r#r$rrrArBrs   zConnection.__init__cCs6d|jfd|jfd|jfg}|jr|d|jf|S)Nr r!rRrT)r r!rRrTryrKrrArArBrszConnection.repr_piecesrcCs|j|jdS)Nr r!r)rrArArB_connection_argumentsrz Connection._connection_argumentsc st|j4IdHtjdi|IdH\}}WdIdHn 1IdHs*wY||_||_|jd}|ry| t j t j dz$|j re| t jt jd|jD]\}}| t j||qXWdSWdSttfyx|wdS)zCreate a TCP socket connectionNrzrurA)rrZr{Zopen_connectionr*rcrd transportZget_extra_info setsockoptrz IPPROTO_TCP TCP_NODELAYr" SOL_SOCKET SO_KEEPALIVEr#itemsSOL_TCPrrr)rKreaderwritersockrrrArArBrs.( zConnection._connectcCs|jd|jS)N:r)rrArArBrszConnection._host_error)r<r=r>rrrrrr r rrrr*rr __classcell__rArAr'rBrs, rcseZdZdZ        d deedeedeeejfdeed eed e d ee d eeffd d Z de ffdd Z eddZeddZeddZeddZeddZeddZeddZZS)! SSLConnectionzManages SSL connections to and from the Redis server(s). This class extends the Connection class, adding SSL functionality, and making use of ssl.SSLContext (https://docs.python.org/3/library/ssl.html#ssl.SSLContext) NrequiredT ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostnamessl_min_version ssl_ciphersc s<tstdt||||||||d|_tjdi| dS)N$Python wasn't built with SSL support)keyfilecertfile cert_reqsca_certsca_datacheck_hostname min_versionciphersrA)rr+RedisSSLContextrar&r) rKr:r;r<r=r>r?r@rArr'rArBrs  zSSLConnection.__init__rcst}|j|d<|S)Nssl)r&r*rarrKrr'rArBr*-s z#SSLConnection._connection_argumentscC|jjSrI)rarCrrArArBrC2zSSLConnection.keyfilecCrNrI)rarDrrArArBrD6rOzSSLConnection.certfilecCrNrI)rarErrArArBrE:rOzSSLConnection.cert_reqscCrNrI)rarFrrArArBrF>rOzSSLConnection.ca_certscCrNrI)rarGrrArArBrGBrOzSSLConnection.ca_datacCrNrI)rarHrrArArBrHFrOzSSLConnection.check_hostnamecCrNrI)rarIrrArArBrIJrOzSSLConnection.min_version)NNr9NNTNN)r<r=r>rr rrrL VerifyModerrrr r*rrCrDrErFrGrHrIr7rArAr'rBr8 sT        r8c@seZdZdZ        ddeedeedeeeejfdeedeed e d ee d eefd d Z de fddZ dS)rK) rCrDrErFrGcontextrHrIrJNFrCrDrErFrGrHrIrJc Cststd||_||_|durtj}nt|tr1tjtjtj d} || vr-td|| |}||_ ||_ ||_ |j tjkrB|nd|_ ||_||_d|_dS)NrB)noneoptionalr9z+Invalid SSL Certificate Requirements Flag: F)rr+rCrDrL CERT_NONErr CERT_OPTIONAL CERT_REQUIREDrErFrGrHrIrJrQ) rKrCrDrErFrGrHrIrJZ CERT_REQSrArArBr\s0   zRedisSSLContext.__init__rcCs|jsDt}|j|_|j|_|jr|jr|j|j|jd|j s$|j r-|j |j |j d|j dur6|j |_ |jdurA||j||_|jS)N)rDrC)cafilecadata)rQrLcreate_default_contextrHrE verify_moderDrCload_cert_chainrFrGload_verify_locationsrIminimum_versionrJ set_ciphers)rKrQrArArBrs     zRedisSSLContext.get)NNNNNFNN)r<r=r>rr rrrLrPrrrrrrArArArBrKOs8 'rKcsdeZdZdZdddeffddZdeeeeee fffdd Z d d Z defd d Z Z S)UnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverpathrbc s||_tjdi|dSr%)rbr&r)rKrbrr'rArBrsz#UnixDomainSocketConnection.__init__rcCs.d|jfd|jfg}|jr|d|jf|S)NrbrRrT)rbrRrTryr(rArArBrsz&UnixDomainSocketConnection.repr_piecesc svt|j4IdHtj|jdIdH\}}WdIdHn 1IdHs'wY||_||_|IdHdS)Nra)rrZr{Zopen_unix_connectionrbrcrdr)rKr3r4rArArBrs(z#UnixDomainSocketConnection._connectcCrrIrarrArArBrrz&UnixDomainSocketConnection._host_error)r<r=r>rrrrr rrrrrr7rArAr'rBr_s "r_)0FFALSENNOrcCs6|dus|dkr dSt|tr|tvrdSt|S)Nr`F)rrupper FALSE_STRINGSr)valuerArArBto_bools rk) rRrYrZr"r\max_connectionsr^r?r!.URL_QUERY_ARGUMENT_PARSERSc@sJeZdZUeed<eed<eeed<eed<eed<eed<eed<dS) ConnectKwargsrSrXconnection_classr r!rRrbN)r<r=r>r__annotations__rrGrrArArArBrns   rnF)totalurlc Cs|t|}i}t|jD]7\}}|rDt|dkrDt|d}t|}|r@z||||<Wq tt fy?t d|dw|||<q |j rOt|j |d<|j rYt|j |d<|j dkrn|j rht|j |d<t|d<|S|j d vr|jr}t|j|d <|jrt|j|d <|j rd |vrztt|j d d|d <Wn tt fyYnw|j dkrt|d<|Sd}t d|d)NrzInvalid value for 'z' in connection URL.rSrXunixrbro)Zredisredissr r!rR/r`rtzredis://, rediss://, unix://z5Redis URL must specify one of the following schemes ())rrqueryr1rrrmrrrrSrXschemerbr_hostnamer!rreplaceAttributeErrorr8)rrparsedrnameZ value_listrjrZ valid_schemesrArArB parse_urlsR      r~_CPConnectionPool)boundc@seZdZdZedeededefddZe dfdee d e e fd d Z d d ZddZdefddZedgdddd3ddZddZddZddZde fdd Zde fd!d"Zd4d$efd%d&Zd5d'd(Zd6d+d,Zd-efd.d/Zd0efd1d2ZdS)7ra Create a connection pool. ``If max_connections`` is set, then this object raises :py:class:`~redis.ConnectionError` when the pool's limit is reached. By default, TCP connections are created unless ``connection_class`` is specified. Use :py:class:`~redis.UnixDomainSocketConnection` for unix sockets. Any additional keyword arguments are passed to the constructor of ``connection_class``. clsrrrcKs t|}|||di|S)a 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@]/path/to/socket.sock?db=0[&password=password] Three URL schemes are supported: - `redis://` creates a TCP socket connection. See more at: - `rediss://` creates a SSL wrapped TCP socket connection. See more at: - ``unix://``: creates a Unix Domain Socket connection. The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters. There are several ways to specify a database number. The first value found will be used: 1. A ``db`` querystring option, e.g. redis://localhost?db=0 2. If using the redis:// or rediss:// schemes, the path argument of the url, e.g. redis://localhost/0 3. A ``db`` keyword argument to this function. If none of these options are specified, the default db=0 is used. All querystring options are cast to their appropriate Python types. Boolean arguments can be specified with string values "True"/"False" or "Yes"/"No". Values that cannot be properly cast cause a ``ValueError`` to be raised. Once parsed, the querystring arguments and keyword arguments are passed to the ``ConnectionPool``'s class initializer. In the case of conflicting arguments, querystring arguments always win. NrA)r~update)rrrrZ url_optionsrArArBfrom_urls+ zConnectionPool.from_urlNrorlcKs|pd}t|tr |dkrtd||_||_||_g|_t|_|j dt |_ t |_|j dd|_|jdurAt|_dSdS)Nlrz,"max_connections" must be a positive integerrsrt)rrrroconnection_kwargsrl_available_connectionsset_in_use_connectionsrr3rsr{Lockrhrwr)rKrorlrrArArBrDs   zConnectionPool.__init__c Cs.d|jjd|jjd|jdi|jdS)NrrrrrA)rr=r<rorrrArArBrZszConnectionPool.__repr__cCsg|_t|_dSrI)rrWeakSetrrrArArBreset`szConnectionPool.resetcCs|jp t|j|jkS)z;Return True if a connection can be retrieved from the pool.)rrrrlrrArArBcan_get_connectiondsz!ConnectionPool.can_get_connection*)Use get_connection() without args instead5.3.0Z args_to_warnreasonversionc s|j4IdH, |}z ||IdHWnty(||IdHwWdIdH|S1IdHs:wY|SrI)rhget_available_connectionensure_connectionrrelease)rK command_namekeysoptionsrFrArArBget_connectionks   zConnectionPool.get_connectioncCsTz|j}Wnty!t|j|jkrtdd|}Ynw|j||S)zCGet a connection from the pool, without making sure it is connectedzToo many connectionsN) rpop IndexErrorrrrlr)make_connectionaddrJrArArBr|s    z'ConnectionPool.get_available_connectioncCs.|j}|j|dd|dd|dddS)z,Return an encoder based on encoding settingsrmrkrnrlroF)rmrnro)rrsrrMrArArB get_encoders    zConnectionPool.get_encodercCs|jdi|jS)z=Create a new connection. Can be overridden by child classes.NrA)rorrrArArBrszConnectionPool.make_connectionrFc s~|IdHz|IdHrtddWdStttfy>|IdH|IdH|IdHr;tddYdSw)z8Ensure that the connection object is connected and validNzConnection has datazConnection not ready)rrr)r-rrrJrArArBrs  z ConnectionPool.ensure_connectioncs4|j||j||jt|IdHdS)z(Releases the connection back to the poolN)rrrryrwZdispatch_asyncrrJrArArBrs   zConnectionPool.releaseTinuse_connectionscs\|r t|j|j}n|j}tjdd|DddiIdH}tdd|Dd}|r,|dS)z Disconnects connections in the pool If ``inuse_connections`` is True, disconnect connections that are current in use, potentially by other tasks. Otherwise only disconnect connections that are idle in the pool. css|]}|VqdSrIr)rrFrArArBrrz,ConnectionPool.disconnect..Zreturn_exceptionsTNcss|] }t|tr|VqdSrI)rr)rrrArArBrs)rrrr{Zgathernext)rKr connectionsresprrArArBrs  zConnectionPool.disconnectcr)z-Close the pool, disconnecting all connectionsNrrrArArBacloserzConnectionPool.acloserrr"cCs(|jD]}||_q|jD]}||_q dSrI)rrrr)rKrrconnrArArB set_retrys  zConnectionPool.set_retryr c sj4IdHBjD]'jfddfddIdHjfddfddIdHq jD]q7WdIdHdS1IdHsPwYdS)NcsddSr)rrrrA)rr rArBrsz1ConnectionPool.re_auth_callback..c |SrI_mockrrrArBr crrI)rrA)rrArBrrcrrIrrrrArBrr)rhrrrrrrrrA)rrKr rBre_auth_callbacks      .zConnectionPool.re_auth_callbackrcsdS)z Dummy functions, needs to be passed as error callback to retry object. :param error: :return: NrArrArArBrszConnectionPool._mockrIrr)rrr"rN) r<r=r>r classmethodrrrrrrGr rrrrrrrrrrrrrrrrrrr+rrArArArBrs< 0       c s|eZdZdZddeejfdedeede e de ej ffdd Z e d gd d d dfdd Zde ffdd ZZS)BlockingConnectionPoola  A blocking connection pool:: >>> from redis.asyncio import Redis, BlockingConnectionPool >>> client = Redis.from_pool(BlockingConnectionPool()) It performs the same function as the default :py:class:`~redis.asyncio.ConnectionPool` implementation, in that, it maintains a pool of reusable connections that can be shared by multiple async redis clients. 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.ConnectionError` (as the default :py:class:`~redis.asyncio.ConnectionPool` implementation does), it blocks the current `Task` 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) 2rlr!ro queue_classc s,tjd||d|t|_||_dS)N)rorlrA)r&rr{ Condition _conditionr!)rKrlr!rorrr'rArBrs  zBlockingConnectionPool.__init__rrrrNc szM|j4IdH9t|j4IdH|j|jIdHt}WdIdHn 1IdHs3wYWdIdHn 1IdHsHwYWntjy`}zt d|d}~wwz | |IdH|WSt y|| |IdHw)z@Gets a connection from the pool, blocking until one is availableNzNo connection available.) rrr!rrr&rr{r-r)rrr)rKrrrrFerrr'rArBrs( *(  z%BlockingConnectionPool.get_connectionrFc s^|j4IdHt|IdH|jWdIdHdS1IdHs(wYdS)z)Releases the connection back to the pool.N)rr&rnotifyrJr'rArBr/s  .zBlockingConnectionPool.releaserI)r<r=r>rrr{ LifoQueuerr rrGQueuerrrrr7rArAr'rBrs,#r)mr{r|enumrrzsysrrabcr itertoolsrtypesrtypingrrrrr r r r r rrrr urllib.parserrrrutilsrrLrrZ auth.tokenreventrrrr version_infor!rZredis.asyncio.retryr"Z redis.backoffr#Zredis.connectionr$Zredis.credentialsr%r&Zredis.exceptionsr'r(r)r*r+r,r-Z redis.typingr.Z redis.utilsr/r0r1_parsersr2r3r4r5r6rrrZSYM_LFrEnumr;r@rxrprCrErPrrGrr8rKr_rirrkrrrmrr?rnr~rrrrArArArBs    <       $  m9CE 4`