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__objectsentinelrArAx/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/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_checklast_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_classrWrcevent_dispatcherrRrXrYrZr\r]rnrorprqrrr^rTrUrVrSrsr[rtrWrcrucCs|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#rscopydeepcopyupdate_supported_errorsr^r_rar[rdrerj set_parserrgrh_re_auth_tokenint TypeErrorr$ ValueErrorr)rc)rKrRrXrYrZr\r]rnrorprqrrr^rTrUrVrSrsr[rtrWrcruprArArB__init__sr          zAbstractConnection.__init__ _warningscCsRt|ddr'|jd|t|dz t|WdSty&YdSwdS)Nrezunclosed 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)recloserdrKrArArBrs zAbstractConnection._closecCs8ddd|D}d|jjd|jjd|dS)N,css"|] \}}|d|VqdS)=NrA).0kvrArArB s z.AbstractConnection.__repr__..<.()>)join repr_pieces __class__r=r<)rK repr_argsrArArB__repr__s zAbstractConnection.__repr__cCrHrIrArrArArBrzAbstractConnection.repr_piecescCs|jduo |jduSrI)rdrerrArArB 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 WeakMethodrgrz)rKcallbackwmrArArBregister_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)rgremoverrr)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 )rrN)rjrf)rKrqrArArBrszAbstractConnection.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..)rrscall_with_retryr|CancelledErrorr{r!r-OSErrorr)_error_message Exceptionr[on_connect_check_healthiscoroutinefunctionr+rrginspect isawaitable)rKreexcrrtaskrArrBr*sJ     z'AbstractConnection.connect_check_healthcrQrIrArrArArBrTszAbstractConnection._connectcCrHrIrArrArArB _host_errorXrzAbstractConnection._host_error exceptioncCst||SrI)rr)rKrrArArBr\z!AbstractConnection._error_messagecC|jSrI)rcrrArArB 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)r2rvdefaultrHELLOAUTHrFsprotoprotozInvalid RESP versionrwrOKzInvalid Username or PasswordCLIENTSETNAMEzError setting client nameSETINFOzLIB-NAMEzLIB-VERSELECTcss|]}|r|VqdSrIrA)rsentrArArBrz=AbstractConnection.on_connect_check_health..zInvalid Database)rfrrWrSrXr&get_credentials_asyncrc isinstancer5rr6EXCEPTION_CLASSESlen send_command read_responsegetrr)r(r1r'rTrUrVrRr,)rKrparser auth_args cred_providerresponse 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_timeoutrZrf on_disconnectrrer wait_closedrrdr|r-)rKrrArArBrs8    2 zAbstractConnection.disconnectcs8|jdddIdHt|IdHdkrtddS)z Send PING, expect PONG in returnPINGFrNPONGz#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_rsrrrrrArArBrszAbstractConnection.check_healthcommandcs"|j||jIdHdSrI)re 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 socketrvUNKNOWNrzError z while writing to socket. r)rrrrstrencodebytesrYr|wait_forrrerrr-rrrargsr) BaseException)rKrrrerr_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: )rfcan_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 protocolrrvN )rfloatrtuplersplit SYM_EMPTYrSYM_STARrSYM_CRLFrhmapra memoryview SYM_DOLLARrz)rKroutputbuff buffer_cutoffarg 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__ryrCr0r3rrrr rboollistr;rr2r"ConnectCallbackTr%rrwarningsrrrrrrpropertyrrrrrrrrrrrrrrrrrrrrrrrrr.rrr"r$r%rr(r-rArArArBrGjs         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_typer9r:r;r<r=c s<||_t||_||_|pi|_||_tjdi|dSNrA)r9rr:r;r<r=superr)rKr9r:r;r<r=rrrArBrs   zConnection.__init__cCs6d|jfd|jfd|jfg}|jr|d|jf|S)Nr9r:rRrT)r9r:rRrTrzrKrrArArBrszConnection.repr_piecesrcCs|j|jdS)Nr9r:rBrrArArB_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 connectionNr{rvrA)rrZr|open_connectionrCrdre transportget_extra_info setsockoptr{ IPPROTO_TCP TCP_NODELAYr; SOL_SOCKET SO_KEEPALIVEr<itemsSOL_TCPrrr)rKreaderwritersockrrrArArBrs.( zConnection._connectcCs|jd|jS)N:rBrrArArBrszConnection._host_error)r<r=r>r0rrrr2r r rrrrCrr __classcell__rArAr@rBr7s, r7cseZdZdZ        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+RedisSSLContextrbr?r) rKrUrVrWrXrYrZr[r\rr@rArBrs  zSSLConnection.__init__rcst}|j|d<|S)Nssl)r?rCrbrrKrr@rArBrC-s z#SSLConnection._connection_argumentscC|jjSrI)rbr^rrArArBr^2zSSLConnection.keyfilecCrirI)rbr_rrArArBr_6rjzSSLConnection.certfilecCrirI)rbr`rrArArBr`:rjzSSLConnection.cert_reqscCrirI)rbrarrArArBra>rjzSSLConnection.ca_certscCrirI)rbrbrrArArBrbBrjzSSLConnection.ca_datacCrirI)rbrcrrArArBrcFrjzSSLConnection.check_hostnamecCrirI)rbrdrrArArBrdJrjzSSLConnection.min_version)NNrTNNTNN)r<r=r>r0r rrrg VerifyModer2rrr rCr6r^r_r`rarbrcrdrRrArAr@rBrS sT        rSc@seZdZdZ        ddeedeedeeeejfdeedeed e d ee d eefd d Z de fddZ dS)rf) r^r_r`rarbcontextrcrdreNFr^r_r`rarbrcrdrec Cststd||_||_|durtj}nt|tr1tjtjtj d} || vr-td|| |}||_ ||_ ||_ |j tjkrB|nd|_ ||_||_d|_dS)Nr])noneoptionalrTz+Invalid SSL Certificate Requirements Flag: F)rr+r^r_rg CERT_NONErr CERT_OPTIONAL CERT_REQUIREDr`rarbrcrdrerl) rKr^r_r`rarbrcrdre 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)r_r^)cafilecadata)rlrgcreate_default_contextrcr` verify_moder_r^load_cert_chainrarbload_verify_locationsrdminimum_versionre set_ciphers)rKrlrArArBrs     zRedisSSLContext.get)NNNNNFNN)r<r=r>r1r rrrgrkr2rrrrrArArArBrfOs8 'rfcsdeZdZdZdddeffddZdeeeeee fffdd Z d d Z defd d Z Z S)UnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverpathr~c s||_tjdi|dSr>)r~r?r)rKr~rr@rArBrsz#UnixDomainSocketConnection.__init__rcCs.d|jfd|jfg}|jr|d|jf|S)Nr~rRrT)r~rRrTrzrArArArBrsz&UnixDomainSocketConnection.repr_piecesc svt|j4IdHtj|jdIdH\}}WdIdHn 1IdHs'wY||_||_|IdHdS)Nr})rrZr|open_unix_connectionr~rdrer)rKrNrOrArArBrs(z#UnixDomainSocketConnection._connectcCrrIr}rrArArBrrz&UnixDomainSocketConnection._host_error)r<r=r>r0rrrr rrrrrrRrArAr@rBr{s "r{)0FFALSENNOrcCs6|dus|dkr dSt|tr|tvrdSt|S)Nr|F)rrupper FALSE_STRINGSr2)valuerArArBto_bools r) rRrYrZr;r\max_connectionsr^rZr!.URL_QUERY_ARGUMENT_PARSERSc@sJeZdZUeed<eed<eeed<eed<eed<eed<eed<dS) ConnectKwargsrSrXconnection_classr9r:rRr~N)r<r=r>r__annotations__rrGrrArArArBrs   rF)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.rSrXunixr~r)redisredissr9r:rR/r|rzredis://, rediss://, unix://z5Redis URL must specify one of the following schemes ())rrqueryrLrrrrrrrSrXschemer~r{hostnamer:rreplaceAttributeErrorrS)rparsedrname value_listrr 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``. clsrrcKs 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)rupdate)rrr url_optionsrArArBfrom_urls+ zConnectionPool.from_urlNrrcKs|pd}t|tr |dkrtd||_||_||_g|_t|_|j dt |_ t |_|j dd|_|jdurAt|_dSdS)Nlrz,"max_connections" must be a positive integerrtru)rrrrconnection_kwargsr_available_connectionsset_in_use_connectionsrr3rtr|Lockrirxr)rKrrrrArArBrDs   zConnectionPool.__init__c Cs.d|jjd|jjd|jdi|jdS)NrrrrrA)rr=r<rrrrArArBrZszConnectionPool.__repr__cCsg|_t|_dSrI)rrWeakSetrrrArArBreset`szConnectionPool.resetcCs|jp t|j|jkS)z;Return True if a connection can be retrieved from the pool.)rrrrrrArArBcan_get_connectiondsz!ConnectionPool.can_get_connection*)Use get_connection() without args instead5.3.0 args_to_warnreasonversionc s|j4IdH, |}z ||IdHWnty(||IdHwWdIdH|S1IdHs:wY|SrI)riget_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 IndexErrorrrrr)make_connectionaddrJrArArBr|s    z'ConnectionPool.get_available_connectioncCs.|j}|j|dd|dd|dddS)z,Return an encoder based on encoding settingsrnrlrormrpF)rnrorp)rrtrrhrArArB get_encoders    zConnectionPool.get_encodercCs|jdi|jS)z=Create a new connection. Can be overridden by child classes.NrA)rrrrArArBrszConnectionPool.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)rrrrzrxdispatch_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..return_exceptionsTNcss|] }t|tr|VqdSrI)rr)rrrArArBrs)rrrr|gathernext)rKr connectionsresprrArArBrs  zConnectionPool.disconnectcr)z-Close the pool, disconnecting all connectionsNrrrArArBacloserzConnectionPool.aclosersr"cCs(|jD]}||_q|jD]}||_q dSrI)rrsr)rKrsconnrArArB set_retrys  zConnectionPool.set_retryr&c sj4IdHBjD]'jfddfddIdHjfddfddIdHq jD]q7WdIdHdS1IdHsPwYdS)NcsddSr))rr+r,rA)rr&rArBrsz1ConnectionPool.re_auth_callback..c |SrI_mockrrrArBr crrI)rrA)rrArBrrcrrIrrrrArBrr)rirrsrrr(r'rA)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._mockrIr.r/)rsr"rN) r<r=r>r0 classmethodrrrrr7rGr rrrrr2rrrrrrrrrrrrrr+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) 2rr!r queue_classc s,tjd||d|t|_||_dS)N)rrrA)r?rr| Condition _conditionr!)rKrr!rrrr@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>r0r7r| LifoQueuerr rrGQueuerrrrrRrArAr@rBrs,#r)mr|r}enumrr{sysr5rabcr itertoolsrtypesrtypingrrrrr r r r r rrrr urllib.parserrrrutilsrrgrr auth.tokenreventrrrr version_infor!rredis.asyncio.retryr" redis.backoffr#redis.connectionr$redis.credentialsr%r&redis.exceptionsr'r(r)r*r+r,r- redis.typingr. redis.utilsr/r0r1_parsersr2r3r4r5r6rrrSYM_LFrEnumr;r@ryrrCrErPr4rGr7rSrfr{rr2rrrrrr?rrrrrrArArArBs    <       $  m9CE 4`