o rPf @s"UddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZddlmZddlmZmZmZmZmZmZddlmZmZmZdd lmZmZmZmZdd l m!Z!dd l"m#Z#m$Z$dd l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-dd l.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6e2rddl7Z7dZ8dZ9dZ:dZ;dZeeeeefe?d<e2reZ@neZ@GdddZAGdddZBGdddZCGdddeCZDGdddeDZEGdd d eCZFd!ZGd"d#ZHeIeJeJeHeHeKeIeIeHeJd$ ZLd%d&ZMGd'd(d(ZNGd)d*d*eNZOdS)+N)abstractmethod)chain)EmptyFull LifoQueue)time)AnyCallableListOptionalTypeUnion)parse_qsunquoteurlparse)Encoder_HiredisParser _RESP2Parser _RESP3Parser) NoBackoff)CredentialProvider"UsernamePasswordCredentialProvider)AuthenticationError$AuthenticationWrongNumberOfArgsErrorChildDeadlockedErrorConnectionError DataError RedisError ResponseError TimeoutError)Retry)CRYPTOGRAPHY_AVAILABLEHIREDIS_AVAILABLEHIREDIS_PACK_AVAILABLE SSL_AVAILABLEget_lib_version str_if_bytes*$s  DefaultParserc@seZdZdefddZdS)HiredisRespSerializerargscGsg}t|dtrt|d|dd}nd|dvr.t|d|dd}z |t|W|StyNt \}}}t | |w2Pack a series of arguments into the Redis protocolrrN ) isinstancestrtupleencodesplitappendhiredis pack_command TypeErrorsysexc_inforwith_traceback)selfr.output_value tracebackrCQ/var/www/html/humari/django-venv/lib/python3.10/site-packages/redis/connection.pypack:s"  zHiredisRespSerializer.packN)__name__ __module__ __qualname__r rErCrCrCrDr-9sr-c@seZdZdddZddZdS)PythonRespSerializerreturnNcCs||_||_dSN)_buffer_cutoffr5)r> buffer_cutoffr5rCrCrD__init__Ls zPythonRespSerializer.__init__c Gsg}t|dtrt|d|dd}nd|dvr.t|d|dd}tttt|t f}|j }t |j|D]>}t|}t||ksZ||ksZt|t rtt|t t|t f}||||t }qEt|t t|t |t f}qE|||Sr/)r2r3r4r5r6 SYM_EMPTYjoinSYM_STARlenSYM_CRLFrLmap memoryview SYM_DOLLARr7)r>r.r?buffrMarg arg_lengthrCrCrDrEPs<"      zPythonRespSerializer.packrJN)rFrGrHrNrErCrCrCrDrIKs  rIc*@seZdZdZdddddedddeddddeddddd dfd ed ee d ee d ee de de de de dededee dee dee dee de e dfdeegdfdeedeedeegdff&ddZdd Zed!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zed/d0Zed1d2Zed3d4Zd5d6Zd7d8Zd9d:Zd;d<Z d=d>Z!dMd@dAZ"dBdCZ#dNdDdEZ$ dOd?ddFdGdHZ%dIdJZ&dKdLZ'dS)PAbstractConnectionz0Manages communication to and from a Redis serverrNFutf-8strictizredis-pyr+dbpasswordsocket_timeoutsocket_connect_timeoutretry_on_timeoutencodingencoding_errorsdecode_responsessocket_read_sizehealth_check_interval client_namelib_name lib_versionusernameretryredis_connect_funccredential_providerprotocolcommand_packercCs|s|r |dur tdt|_||_| |_||_||_||_||_ ||_ ||_ |dur/|}||_ ||_ |tur;g}|rB|t||_|sI|rb|durUttd|_nt||_|j|nttd|_| |_d|_||_t||| |_d|_| |_|| g|_ d|_!z-zt"|}Wnt#yt$}Yn t%yt&dwW|dks|dkrt&d ||_'n|dks|dkrt&d ||_'w|(||_)dS) a2 Initialize a new Connection. To specify a retry policy for specific errors, first set `retry_on_error` to a list of the error/s to retry on, then set `retry` to a valid `Retry` object. To retry on TimeoutError, `retry_on_timeout` can also be set to `True`. 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'rripzprotocol must be an integerr+zprotocol must be either 2 or 3)*rosgetpidpidr^rhrirjrnr_rkr`rarbSENTINELr7r retry_on_errorr!rrlcopydeepcopyupdate_supported_errorsrgnext_health_checkrmrencoder_sock_socket_read_size set_parser_connect_callbacksrLintr:DEFAULT_RESP_VERSION ValueErrorrro_construct_command_packer_command_packer)r>r^r_r`rarbrvrcrdre parser_classrfrgrhrirjrkrlrmrnrorpprCrCrDrNsh       zAbstractConnection.__init__cCs,ddd|D}|jjd|dS)N,cSsg|] \}}|d|qS)=rC).0kvrCrCrD sz/AbstractConnection.__repr__..<>)rP repr_pieces __class__rF)r> repr_argsrCrCrD__repr__szAbstractConnection.__repr__cCdSrKrCr>rCrCrDrzAbstractConnection.repr_piecescCs$z|WdStyYdSwrK) disconnect ExceptionrrCrCrD__del__s  zAbstractConnection.__del__cCs&|dur|Str tSt|j|jjSrK)r$r-rIrLr{r5)r>packerrCrCrDrs z,AbstractConnection._construct_command_packercCs(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 WeakMethodrr7)r>callbackwmrCrCrDregister_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)rremoverrr)r>rrCrCrDderegister_connect_callbacks  z.AbstractConnection.deregister_connect_callbackcCs||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 )rfN)r}_parser)r>rrCrCrDr~szAbstractConnection.set_parserc sjrdSzjfddfdd}Wntjy"tdty4}zt|d}~ww|_zj durC n Wn t yU wddj D_ j D] }|}|rm|qbdS)z5Connects to the Redis server if not already connectedNcsSrK)_connectrCrrCrDsz,AbstractConnection.connect..cs |SrKr)errorrrCrDrs zTimeout connecting to servercSsg|]}|r|qSrCrC)rrefrCrCrDr,sz.AbstractConnection.connect..)r|rlcall_with_retrysockettimeoutr OSErrorr_error_messagerm on_connectrrr)r>sockerrrCrrDconnects:     zAbstractConnection.connectcCrrKrCrrCrCrDr2rzAbstractConnection._connectcCrrKrCrrCrCrD _host_error6rzAbstractConnection._host_errorcCrrKrC)r> exceptionrCrCrDr:rz!AbstractConnection._error_messagecCst|j||j}d}|js|js|jr"|jpt|j|j}|}|r\|jdvr\t|jt r?| t |j |j_ |j|t |dkrKd|dg}|jd|jdg|R|}nq|r|jdg|Rdd iz|}Wnty|jd|d d d |}Ynwt|d krtd n:|jdvrt|jt r| t |j |j_ |j||d|j|}|d|jkr|d|jkrtd|jr|dd|jt|d krtdz|jr|ddd|j|Wn tyYnwz|jr|ddd|j|Wn tyYnw|jr6|d|jt|d kr8tddSdS)z=Initialize the connection, authenticate and select a databaseN)r+2rdefaultrHELLOAUTH check_healthFrOKzInvalid Username or PasswordsprotoprotozInvalid RESP versionCLIENTSETNAMEzError setting client nameSETINFOzLIB-NAMEzLIB-VERSELECTzInvalid Database)rrrnrkr_rget_credentialsror2rr~rEXCEPTION_CLASSESrR send_command read_responserr'rgetrrhrirrjr^)r>parser auth_args cred_providerresponse auth_responserCrCrDr>s                   zAbstractConnection.on_connectc Gs||j|j}d|_|durdSt|jkr,z|tjWn t t fy+Ynwz| WdSt y=YdSw)z!Disconnects from the Redis serverN) r on_disconnectr|rrrsrtshutdownr SHUT_RDWRrr:close)r>r. conn_sockrCrCrDrs  zAbstractConnection.disconnectcCs*|jdddt|dkrtddS)z Send PING, expect PONG in returnPINGFrPONGz#Bad response from PING health checkN)rr'rrrrCrCrD _send_pingszAbstractConnection._send_pingcC |dS)z Function to call when PING failsNr)r>rrCrCrD _ping_failed zAbstractConnection._ping_failedcCs0|jrt|jkr|j|j|jdSdSdS)z3Check the health of the connection with a PING/PONGN)rgrrzrlrrrrrCrCrDrszAbstractConnection.check_healthTc Cs|js||r |zt|tr|g}|D]}|j|qWdStjy3|t dt yg}z)|t |j dkrNd|j d}}n |j d}|j d}t d|d|dd}~wtyr|w) z2Send an already packed command to the Redis serverzTimeout writing to socketrUNKNOWNrError z while writing to socket. .N)r|rrr2r3sendallrrrr rrRr.r BaseException)r>commandritemrerrnoerrmsgrCrCrDsend_packed_commands2    z&AbstractConnection.send_packed_commandcOs"|j|jj||ddddS)z+Pack and send a command to the Redis serverrTrN)rrrEr)r>r.kwargsrCrCrDrs   zAbstractConnection.send_commandc Cs`|j}|s ||}z|j|WSty/}z|td|d|jd}~ww)z8Poll the socket to see if there's data that can be read.Error while reading from z: N) r|rrrcan_readrrrr.)r>rr host_errorrrCrCrDrszAbstractConnection.can_read)disconnect_on_error push_requestc Cs|}z|jdvrts|jj||d}n|jj|d}Wn>tjy2|r+|td|t yN}z|r?|t d|d|j d}~wt y[|rZ|w|j rft|j |_t|trpz|~w|S)z0Read the response from a previously sent command)3rq)disable_decodingr)rzTimeout reading from rz : N)rror#rrrrrr rrr.rrgrrzr2r)r>rrrrrrrCrCrDrs>   z AbstractConnection.read_responsecGs |jj|S)r0)rrE)r>r.rCrCrDr9rzAbstractConnection.pack_commandc Csg}g}d}|j}|D]B}|jj|D]9}t|}||ks&||ks&t|tr4|r0|t|d}g}||ks=t|trC||q||||7}qq |rX|t||S)z.Pack multiple commands into the Redis protocolr) rLrrErRr2rUr7rOrP) r>commandsr?pieces buffer_lengthrMcmdchunkchunklenrCrCrD pack_commands!s.   z AbstractConnection.pack_commandsT)r)F)(rFrGrH__doc__rur,r&rr r3floatboolr rr rrNrrrrrrrr~rrrrrrrrrrrrrr9rrCrCrCrDr[~s      Y   #   Z   . r[csLeZdZdZ     dfdd Zd d Zd d Zd dZddZZ S) Connectionz4Manages TCP communication to and from a Redis server localhostFNrc s<||_t||_||_|pi|_||_tjdi|dSNrC)hostrportsocket_keepalivesocket_keepalive_options socket_typesuperrN)r>rrrrrrrrCrDrNCs   zConnection.__init__cCs6d|jfd|jfd|jfg}|jr|d|jf|S)Nrrr^rh)rrr^rhr7r>rrCrCrDrSszConnection.repr_piecesc Csd}t|j|j|jtjD]k}|\}}}}}d}zDt|||}|tjtjd|j rH|tj tj d|j D] \} } |tj| | q;||j||||j|WStyy} z| }|duro|WYd} ~ qd} ~ ww|dur|td)zCreate a TCP socket connectionNrz)socket.getaddrinfo returned an empty list)r getaddrinforrr SOCK_STREAM setsockopt IPPROTO_TCP TCP_NODELAYr SOL_SOCKET SO_KEEPALIVEritems settimeoutrarr`rr) r>errresfamilysocktyper canonnamesocket_addressrrrr@rCrCrDrYs4    zConnection._connectcCs|jd|jS)N:)rrrrCrCrDrszConnection._host_errorcCs|}t|jdkr*z d|d|jddWSty)d|jdYSwzd|jdd|d |jddWStyNd|jdYSw) NrzError connecting to z. rrzConnection Error: rz connecting to . )rrRr.AttributeErrorr>rrrCrCrDrs&  zConnection._error_message)rrFNr rFrGrHrrNrrrr __classcell__rCrCrrDr@s)rcsJeZdZdZ              d fdd ZfddZZS) 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) NrequiredFc ststd||_||_|durtj}nt|tr1tjtjtj d}||vr-td|||}||_ ||_ ||_ ||_ ||_||_| |_| |_| |_| |_| |_||_tjdi|dS)aConstructor Args: ssl_keyfile: Path to an ssl private key. Defaults to None. ssl_certfile: Path to an ssl certificate. Defaults to None. ssl_cert_reqs: The string value for the SSLContext.verify_mode (none, optional, required). Defaults to "required". ssl_ca_certs: The path to a file of concatenated CA certificates in PEM format. Defaults to None. ssl_ca_data: Either an ASCII string of one or more PEM-encoded certificates or a bytes-like object of DER-encoded certificates. ssl_check_hostname: If set, match the hostname during the SSL handshake. Defaults to False. ssl_ca_path: The path to a directory containing several CA certificates in PEM format. Defaults to None. ssl_password: Password for unlocking an encrypted private key. Defaults to None. ssl_validate_ocsp: If set, perform a full ocsp validation (i.e not a stapled verification) ssl_validate_ocsp_stapled: If set, perform a validation on a stapled ocsp response ssl_ocsp_context: A fully initialized OpenSSL.SSL.Context object to be used in verifying the ssl_ocsp_expected_cert ssl_ocsp_expected_cert: A PEM armoured string containing the expected certificate to be returned from the ocsp verification service. ssl_min_version: The lowest supported SSL version. It affects the supported SSL versions of the SSLContext. None leaves the default provided by ssl module. ssl_ciphers: A string listing the ciphers that are allowed to be used. Defaults to None, which means that the default ciphers are used. See https://docs.python.org/3/library/ssl.html#ssl.SSLContext.set_ciphers for more information. Raises: RedisError z$Python wasn't built with SSL supportN)noneoptionalrz+Invalid SSL Certificate Requirements Flag: rC)r%rkeyfilecertfilessl CERT_NONEr2r3 CERT_OPTIONAL CERT_REQUIRED cert_reqsca_certsca_dataca_pathcheck_hostnamecertificate_passwordssl_validate_ocspssl_validate_ocsp_stapledssl_ocsp_contextssl_ocsp_expected_certssl_min_version ssl_ciphersrrN)r> ssl_keyfile ssl_certfile ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostname ssl_ca_path ssl_passwordr"r#r$r%r&r'r CERT_REQSrrCrDrNs:( zSSLConnection.__init__c st}t}|j|_|j|_|js|jr"|j |j|j|j d|j dus1|j dus1|j dur<|j|j |j |j d|jdurE|j|_|jrN||j|j||jd}|jdurctdurctd|jrm|jrmtd|jrd dl}d d lm}|jdur|j|jj}| |j|!|jn|j}|"||j#|j$|t%%}|&|'|j|j(f|)|*|S|jdurtrd d lm+}|||j|j(|j } | ,r|St-d |S)z Wrap the socket with SSL support)rrr_N)cafilecapathcadata)server_hostnameTFzcryptography is not installed.zKEither an OCSP staple or pure OCSP connection must be validated - not both.rr)ocsp_staple_verifier) OCSPVerifierzocsp validation error).rrrcreate_default_contextr r verify_moderrload_cert_chainr!rrrload_verify_locationsr&minimum_versionr' set_ciphers wrap_socketrr"r"rr#OpenSSLocspr5r$SSLContext SSLv23_METHODuse_certificate_fileuse_privatekey_fileset_ocsp_client_callbackr%rr request_ocsprr do_handshakerr6is_validr) r>rcontextsslsockr>r5 staple_ctxconr6orrCrDrsf             zSSLConnection._connect)NNrNNFNNFFNNNN)rFrGrHrrNrrrCrCrrDrs$HrcsBeZdZdZdfdd ZddZdd Zd d Zd d ZZ S)UnixDomainSocketConnectionz4Manages UDS communication to and from a Redis serverNc s"||_||_tjdi|dSr)pathr`rrN)r>rPr`rrrCrDrN4sz#UnixDomainSocketConnection.__init__cCs.d|jfd|jfg}|jr|d|jf|S)NrPr^rh)rPr^rhr7rrCrCrDr9sz&UnixDomainSocketConnection.repr_piecescCs8ttjtj}||j||j||j|S)z&Create a Unix domain socket connection)rAF_UNIXrrrarrPr`)r>rrCrCrDr?s    z#UnixDomainSocketConnection._connectcCs|jSrK)rPrrCrCrDrGsz&UnixDomainSocketConnection._host_errorcCsR|}t|jdkrd|d|jddSd|jdd|d|jddS)Nrz!Error connecting to unix socket: r rrrz connecting to unix socket: )rrRr.rrCrCrDrJsz)UnixDomainSocketConnection._error_message)rONrrCrCrrDrN1srN)0FFALSENNOcCs6|dus|dkr dSt|tr|tvrdSt|S)NrOF)r2r3upper FALSE_STRINGSr)rArCrCrDto_bool\s rY) r^r`rarrbrvmax_connectionsrgr-rc Cs|ds|ds|dstdt|}i}t|jD]7\}}|rWt|dkrWt|d}t |}|rSz||||<Wq t tfyRtd|dw|||<q |j rbt|j |d<|j rlt|j |d <|j d kr|jr{t|j|d <t|d <|S|jrt|j|d <|jrt|j|d<|jrd|vrztt|jdd|d<Wn ttfyYnw|j dkrt|d <|S)Nzredis://z rediss://zunix://zRRedis URL must specify one of the following schemes (redis://, rediss://, unix://)rzInvalid value for `z` in connection URL.rkr_unixrPconnection_classrrr^/rOrediss) startswithrrrqueryrrRrURL_QUERY_ARGUMENT_PARSERSrr:rkr_schemerPrNhostnamerrreplacerr)urlrnamerArrCrCrD parse_urlrsZ    rgc@seZdZdZeddZedfdeefddZ de e ffd d Z d&d d Z d&d dZ de ddfddZdefddZd'ddZd(ddZdddefddZd)deddfddZd&d d!Zd*d$d%ZdS)+ConnectionPoola Create a connection pool. ``If max_connections`` is set, then this object raises :py:class:`~redis.exceptions.ConnectionError` when the pool's limit is reached. By default, TCP connections are created unless ``connection_class`` is specified. Use class:`.UnixDomainSocketConnection` for unix sockets. Any additional keyword arguments are passed to the constructor of ``connection_class``. cKs4t|}d|vr|d|d<|||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. r\NrC)rgupdate)clsrer url_optionsrCrCrDfrom_urls )  zConnectionPool.from_urlNrZcKsJ|pd}t|tr |dkrtd||_||_||_t|_| dS)Nlrz,"max_connections" must be a positive integer) r2rrr\connection_kwargsrZ threadingLock _fork_lockreset)r>r\rZrmrCrCrDrNs zConnectionPool.__init__rJcCs(t|jdt|jdi|jdS)NrrrC)typerFreprr\rmrrCrCrDrs zConnectionPool.__repr__cCs,t|_d|_g|_t|_t|_ dS)Nr) rnro_lock_created_connections_available_connectionsset_in_use_connectionsrrrsrtrrCrCrDrq s  zConnectionPool.resetcCsl|jtkr4|jjdd}|stz|jtkr&|W|jdSW|jdS|jwdS)N)r)rtrrrsrpacquirerrqrelease)r>acquiredrCrCrD _checkpids# zConnectionPool._checkpid command_namerc Os||j#z|j}Wn ty|}Ynw|j|Wdn1s-wYz.|z | r@t dWW|St t fy`| || r\t dYW|Swt ym||w)zGet a connection from the poolNConnection has dataConnection not ready)r}rtrvpop IndexErrormake_connectionrxaddrrrrrrr{r>r~keysoptions connectionrCrCrDget_connectionIs8     zConnectionPool.get_connectioncCs,|j}t|dd|dd|dddS)z,Return an encoder based on encoding settingsrcr\rdr]reF)rcrdre)rmrr)r>rrCrCrD get_encoderjs    zConnectionPool.get_encodercCs4|j|jkr td|jd7_|jdi|jS)zCreate a new connectionzToo many connectionsrNrC)rurZrr\rmrrCrCrDrss zConnectionPool.make_connectionrc Cs||j;z|j|Wn tyYnw||r&|j|n|jd8_|  WddSWddS1sEwYdS)z(Releases the connection back to the poolrN) r}rtrxrKeyErrorowns_connectionrvr7rurr>rrCrCrDr{zs   "zConnectionPool.releasecCs |j|jkSrK)rtrrCrCrDrs zConnectionPool.owns_connectionTinuse_connectionscCs`||j|rt|j|j}n|j}|D]}|qWddS1s)wYdS)z 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}rtrrvrxr)r>r connectionsrrCrCrDrs "zConnectionPool.disconnectcCr)z-Close the pool, disconnecting all connectionsNrrrCrCrDrrzConnectionPool.closerlr!cCs8|jd|i|jD]}||_q |jD]}||_qdS)Nrl)rmrirvrlrx)r>rlconnrCrCrD set_retrys   zConnectionPool.set_retryrZ)rJr)rrrJNr)rlr!rJN)rFrGrHr classmethodrlrr rrNr3rrqr}rrrrr{rrrrrrCrCrCrDrhs( 2   /!  rhcsReZdZdZddeeffdd ZddZdd Zd d Z d d Z ddZ Z S)BlockingConnectionPoola 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.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.ConnectionError` (as the default :py:class:`~redis.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) 2c s(||_||_tjd||d|dS)N)r\rZrC) queue_classrrrN)r>rZrr\rrmrrCrDrNs zBlockingConnectionPool.__init__cCsJ||j|_ z|jdWn tyYnwqg|_t|_dSrK) rrZpool put_nowaitr _connectionsrrrsrtrrCrCrDrqs  zBlockingConnectionPool.resetcCs"|jdi|j}|j||S)zMake a fresh connection.NrC)r\rmrr7rrCrCrDrs z&BlockingConnectionPool.make_connectionc Os|d}z |jjd|jd}Wn tytdw|dur%|}z.|z |r3tdWW|Stt fyS| ||rOtdYW|Swt y`| |w)a7 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. NT)blockrzNo connection available.rr) r}rrrrrrrrrrrr{rrCrCrDrs8     z%BlockingConnectionPool.get_connectioncCsR|||s||jddSz |j|WdSty(YdSw)z)Releases the connection back to the pool.N)r}rrrrrrrCrCrDr{6s   zBlockingConnectionPool.releasecCs ||jD]}|qdS)z(Disconnects all connections in the pool.N)r}rrrrCrCrDrKs  z!BlockingConnectionPool.disconnect) rFrGrHrrrrNrqrrr{rrrCrCrrDrs#4r)Prwrrrrr;rnrabcr itertoolsrqueuerrrrtypingrr r r r r urllib.parserrr_parsersrrrrbackoffr credentialsrr exceptionsrrrrrrrr rlr!utilsr"r#r$r%r&r'r8rQrVrSrOrobjectru__annotations__r,r-rIr[rrrNrXrYrrlistrargrhrrCrCrCrDsv      (  3E[( 9