o &!^ @shddlZddlZddlZddlZddlZddlZddlZddlZzddlZddlm Z e eddZ Wne yFdZ Gdddej Z YnwzddlmZWne y`Gdd d eZYnwdd lmZdd lmZmZmZmZdd lmZdd lmZmZmZmZddlm Z ddl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4ddl5m6Z6ddl7m8Z9ddl:m;Z;mZ>m?Z?m@Z@ddlAmBZBddlCmDZDddlEmFZFmZz ddlGmHZHddZIWne yeJedr ejKr ddZInddZIYnwzddlLmLZLmMZMmNZNmOZOdd ZPWne y3d!d ZPYnwd"ZQd#ZRd$ZSejd%krzddlTZUWne yTddlUZUYnwz:eUVeUjWd&(ZXeUYeXd'\ZZZ[eUYeXd(\Z\Z[e]eZesvee]e\es~eWdn 1swYWne^efyd)d*Z_Ynwd+d*Z_nd,d-Z`d.d*Z_ed/ed0d1efgfgZaejbd2rejcdd3d4krd5dd6d7eeDZfnegZfed8egfd9effd:ehfd1eifgead;<nejdd?fgead;<nTejbd@rjeldA\ZfZmZned8effd9effd:enfd1emfgead;<n1eoegeiepZqed8egfd9d5ddBd7eqdd3Dfd:ehfd1eqd3fgead;<erbdCrd5derdDdeesejtdEdDdeesejcfeadF<n8ejbd@rd5derdDdeesejcdGd5degeiffeadF<nd5derdDdeesejcfeadF<dHudIdYdJdKZvGdLdMdMewZxGdNdOdOewZydPdQZzejcdd3dRkZ{dSdTZ|GdUdVdVe4Z}GdWdXdXZ~dS)ZN)SSLErrorHAS_SNIFc@ eZdZdS)rN__name__ __module__ __qualname__r r >/var/www/html/env/lib/python3.10/site-packages/pymongo/pool.pyrr)CertificateErrorc@r)_SSLCertificateErrorNrr r r r r $r r )DEFAULT_CODEC_OPTIONS)imap itervalues_unicode integer_types)SON)authhelpers thread_util __version__)_validate_session_write_concern) MAX_BSON_SIZEMAX_IDLE_TIME_SECMAX_MESSAGE_SIZE MAX_POOL_SIZEMAX_WIRE_VERSIONMAX_WRITE_BATCH_SIZE MIN_POOL_SIZE ORDERED_TYPESWAIT_QUEUE_TIMEOUT) AutoReconnectConnectionFailureConfigurationErrorInvalidOperationDocumentTooLargeNetworkTimeoutNotMasterErrorOperationFailure PyMongoError)IsMaster)time)ConnectionCheckOutFailedReasonConnectionClosedReason)commandreceive_message SocketChecker)ReadPreference) SERVER_TYPE)match_hostnamer ) ip_addressc Cs,z tt|WdSttfyYdSwNTF)r5r ValueError UnicodeErroraddressr r r is_ip_addressOs  r; inet_ptonc CsRzt|WdStjy(z ttj|WYdStjy'YYdSwwr6)socket inet_atonerrorr<AF_INET6r9r r r r;Xs cCs6zt|WdStjyd|vrYdSYdSw)NT:F)r=r>r?r9r r r r;gs  fcntlF_GETFDF_SETFD FD_CLOEXECcCst|t}t|t|tBdS)z8Set the close-on-exec flag on the given file descriptor.NrB)fdflagsr r r _set_non_inheritable_non_atomiczs rIcCsdS)z6Dummy function for platforms that don't provide fcntl.Nr dummyr r r rIsi, win32z2SYSTEM\CurrentControlSet\Services\Tcpip\Parameters KeepAliveTimeKeepAliveIntervalcCsdSNr rJr r r _set_keepalive_timessrRcCsHtttd}tttd}|tks|tkr"|tjd||fdSdS)N)min_DEFAULT_TCP_IDLE_MS_MAX_TCP_KEEPIDLE_DEFAULT_TCP_INTERVAL_MS_MAX_TCP_KEEPINTVLioctlr=SIO_KEEPALIVE_VALS)sockidle_ms interval_msr r r rRscCsbtt|r/tt|}z|tj|}||kr!|tj||WdSWdStjy.YdSwdSrQ)hasattrr=getattr getsockopt IPPROTO_TCP setsockoptr?)r\ tcp_option max_valuesockoptdefaultr r r _set_tcp_options  rhcCs(t|dtt|dtt|dtdS)N TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNT)rhrWrY_MAX_TCP_KEEPCNTr\r r r rRs  driver)namePyMongoversionlinux) cCg|]}|r|qSr r .0partr r r s r{typero architectureosdarwin-rTrtjavacCrwr r rxr r r r{sPyPy.z (Python %s)platformz(%s)fooidnacCsr|\}}|durd|||f}nd||f}|r||}t|tjr&t|t|tr5dt|vr5t|t|)z9Convert a socket.error to ConnectionFailure and raise it.Nz %s:%d: %sz%s: %sz timed out) isinstancer=timeoutr'rstrr")r:r? msg_prefixhostportmsgr r r _raise_connection_failures  rc@seZdZdZeeeddeddddddddfddZe ddZ e dd Z e d d Z e d d Z e ddZe ddZe ddZe ddZe ddZe ddZe ddZe ddZe ddZe d d!Ze d"d#Ze d$d%ZdS)& PoolOptions)__max_pool_size__min_pool_size__max_idle_time_seconds__connect_timeout__socket_timeout__wait_queue_timeout__wait_queue_multiple __ssl_context__ssl_match_hostname__socket_keepalive__event_listeners __appname__driver __metadata__compression_settingsNTcCs||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ tt|_| r9d| i|jd<| rr| jrNdtdd| jf|jdd<| jradtdd| jf|jdd<| jrtdtd| jf|jd<dSdSdS)Nro applicationz%s|%srnrqr)_PoolOptions__max_pool_size_PoolOptions__min_pool_size#_PoolOptions__max_idle_time_seconds_PoolOptions__connect_timeout_PoolOptions__socket_timeout _PoolOptions__wait_queue_timeout!_PoolOptions__wait_queue_multiple_PoolOptions__ssl_context _PoolOptions__ssl_match_hostname_PoolOptions__socket_keepalive_PoolOptions__event_listeners_PoolOptions__appname_PoolOptions__driver"_PoolOptions__compression_settingscopydeepcopy _METADATA_PoolOptions__metadatarorqr)self max_pool_size min_pool_sizemax_idle_time_secondsconnect_timeoutsocket_timeoutwait_queue_timeoutwait_queue_multiple ssl_contextssl_match_hostnamesocket_keepaliveevent_listenersappnamerncompression_settingsr r r __init__/s@    zPoolOptions.__init__cCs`i}|jtkr |j|d<|jtkr|j|d<|jtkr"|jd|d<|jtkr.|jd|d<|S)zqThe non-default options this pool was created with. Added for CMAP's :class:`PoolCreatedEvent`. maxPoolSize minPoolSizerS maxIdleTimeMSwaitQueueTimeoutMS)rrrrrrrr!)roptsr r r non_default_options]s      zPoolOptions.non_default_optionscC|jS)aQThe maximum allowable number of concurrent connections to each connected server. Requests to a server will block if there are `maxPoolSize` outstanding connections to the requested server. Defaults to 100. Cannot be 0. When a server's pool has reached `max_pool_size`, operations for that server block waiting for a socket to be returned to the pool. If ``waitQueueTimeoutMS`` is set, a blocked operation will raise :exc:`~pymongo.errors.ConnectionFailure` after a timeout. By default ``waitQueueTimeoutMS`` is not set. )rrr r r rns zPoolOptions.max_pool_sizecCr)zThe minimum required number of concurrent connections that the pool will maintain to each connected server. Default is 0. )rrr r r r}zPoolOptions.min_pool_sizecCr)zThe maximum number of seconds that a connection can remain idle in the pool before being removed and replaced. Defaults to `None` (no limit). )rrr r r rsz!PoolOptions.max_idle_time_secondscCr)zGHow long a connection can take to be opened before timing out. )rrr r r rzPoolOptions.connect_timeoutcCr)zKHow long a send or receive on a socket can take before timing out. )rrr r r rrzPoolOptions.socket_timeoutcCr)zhHow long a thread will wait for a socket from the pool if the pool has no free sockets. )rrr r r rrzPoolOptions.wait_queue_timeoutcCr)ztMultiplied by max_pool_size to give the number of threads allowed to wait for a socket at one time. )rrr r r rrzPoolOptions.wait_queue_multiplecCr)z(An SSLContext instance or None. )rrr r r rrzPoolOptions.ssl_contextcCr)zCCall ssl.match_hostname if cert_reqs is not ssl.CERT_NONE. )rrr r r rrzPoolOptions.ssl_match_hostnamecCr)zZWhether to send periodic messages to determine if a connection is closed. )rrr r r rrzPoolOptions.socket_keepalivecCr)z;An instance of pymongo.monitoring._EventListeners. )rrr r r rrzPoolOptions.event_listenerscCr)zMThe application name, for sending with ismaster in server handshake. )rrr r r rrzPoolOptions.appnamecCr)zIDriver name and version, for sending with ismaster in handshake. )rrr r r rnrzPoolOptions.drivercCrrQ)rrr r r rsz PoolOptions.compression_settingscCs |jS)zLA dict of metadata about the application, driver, os, and platform. )rrrr r r metadatas zPoolOptions.metadata)rrr __slots__rrrr!rpropertyrrrrrrrrrrrrrrnrrr r r r r%sV .               rc@seZdZdZddZddZdejeddddddddddddfd d Z d d Z d dZ ddZ ddZ ddZddZddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.ZdS)/ SocketInfozStore a socket with some metadata. :Parameters: - `sock`: a raw socket object - `pool`: a Pool instance - `address`: the server's (host, port) - `id`: the id of this socket in it's pool cCs||_||_||_t|_d|_t|_d|_d|_ t |_ t |_ t|_t|_d|_d|_d|_|jj|_|j|_|jj|_d|_|j|_d|_dS)NF)r\r:idsetauthsetclosed_timelast_checkin_timeperformed_handshake is_writablermax_wire_versionr max_bson_sizermax_message_sizermax_write_batch_sizesupports_sessions is_mongosop_msg_enabledrr listenersenabled_for_cmaprcompression_contextpool_idready)rr\poolr:rr r r rs*   zSocketInfo.__init__cCstdg}|js||d<|jr|jj|d<|jdkr"|dur"||d<t|jd|dd}|j|_|j|_|j|_|j |_ |j |_ |j du|_ |j tjk|_|js]|jr]|j|j}||_d |_|jdk|_|S) N)ismasterrTclient compressionz $clusterTimeadminF)publish_eventsT)rrr compressorsrr+r/rrrrlogical_session_timeout_minutesr server_typer3Mongosrget_compression_contextrr)rr cluster_timecmdrctxr r r rs0    zSocketInfo.ismasterFTNcCst||| t| | } t|tst|}| r(|jdkr(| js(td| j|jf| dus7| j s7| dus7td|jdkrG| rG| j sG| j |d<n |jdkrT| durTtd| r]| |||| || ||ri|jnd}| op| j }|jry||z!t|j||||j||| ||||j|||j| | | |j|j||dWStyty}z ||WYd}~dSd}~ww) aFExecute a command or raise an error. :Parameters: - `dbname`: name of the database on which to run the command - `spec`: a command document as a dict, SON, or mapping object - `slave_ok`: whether to set the SlaveOkay wire protocol bit - `read_preference`: a read preference - `codec_options`: a CodecOptions instance - `check`: raise OperationFailure if there are errors - `allowable_errors`: errors to ignore if `check` is True - `check_keys`: if True, check `spec` for invalid keys - `read_concern`: The read concern for this command. - `write_concern`: The write concern for this command. - `parse_write_concern_error`: Whether to parse the ``writeConcernError`` field in the command response. - `collation`: The collation for this command. - `session`: optional ClientSession instance. - `client`: optional MongoClient for gossipping $clusterTime. - `retryable_write`: True if this command is a retryable write. - `publish_events`: Should we publish events for this command? - `user_fields` (optional): Response fields that should be decoded using the TypeDecoders from codec_options, passed to bson._decode_all_selective. zDread concern level of %s is not valid with a max wire version of %d.Nz3Collation is unsupported for unacknowledged writes.ru writeConcernz5Must be connected to MongoDB 3.4+ to use a collation.)parse_write_concern_error collationcompression_ctx use_op_msgunacknowledged user_fields)validate_sessionrrr rr ok_for_legacyr$level acknowledgedis_server_defaultdocument _apply_tosend_cluster_timerr_raise_if_not_writabler/r\rr:rrr) BaseExceptionr)rdbnamespecslave_okread_preference codec_optionscheckallowable_errors check_keys read_concern write_concernrrsessionrretryable_writerrrrr?r r r r/sj %         zSocketInfo.commandc Csj|jdur||jkrtd||jfz |j|WdSty4}z ||WYd}~dSd}~ww)z}Send a raw BSON message or raise ConnectionFailure. If a network exception is raised, the socket is closed. NzfBSON document too large (%d bytes) - the connected server supports BSON document sizes up to %d bytes.)rr&r\sendallrr)rmessage max_doc_sizer?r r r send_messagels  zSocketInfo.send_messagec CsDz t|j||jWSty!}z ||WYd}~dSd}~ww)zzReceive a raw BSON message or raise ConnectionFailure. If any exception is raised, the socket is closed. N)r0r\rrr)r request_idr?r r r r0}szSocketInfo.receive_messagecCs$|r|jstddddddSdS)z]Raise NotMasterError on unacknowledged write if this socket is not writable. z not masterri{')okerrmsgcodeN)rr()rrr r r rs z!SocketInfo._raise_if_not_writablecCs8|| ||||r||}t|SdS)aSend OP_INSERT, etc., optionally returning response as a dict. Can raise ConnectionFailure or OperationFailure. :Parameters: - `request_id`: an int. - `msg`: bytes, an OP_INSERT, OP_UPDATE, or OP_DELETE message, perhaps with a getlasterror command appended. - `max_doc_size`: size in bytes of the largest document in `msg`. - `with_last_error`: True if a getlasterror command is appended. N)rrr0r_check_gle_responsecommand_response)rrrrwith_last_errorreplyr r r legacy_writes  zSocketInfo.legacy_writecCs,||d||}|}t||S)zSend "insert" etc. command, returning response as a dict. Can raise ConnectionFailure or OperationFailure. :Parameters: - `request_id`: an int. - `msg`: bytes, the command message. r)rr0rr_check_command_response)rrrrresultr r r write_commands  zSocketInfo.write_commandcCs|s|jr7tt|}|j}||D]}t|j||j|q||D]}t|||j |q(|j sKd|_ |j rM|j |j|jdSdSdS)a Update this socket's authentication. Log in or out to bring this socket's credentials up to date with those provided. Can raise ConnectionFailure or OperationFailure. :Parameters: - `all_credentials`: dict, maps auth source to MongoCredential. TN)rrrrrlogoutsourcediscard authenticateaddrrrpublish_connection_readyr:r)rall_credentialscachedr credentialsr r r check_auths     zSocketInfo.check_authcCst|||j|dS)zLog in to the server and store these credentials in `authset`. Can raise ConnectionFailure or OperationFailure. :Parameters: - `credentials`: A MongoCredential. N)rr$rr%)rr)r r r r$s zSocketInfo.authenticatecCs2|r|j|ur td|j|jkrtddSdS)zValidate this session before use with client. Raises error if this session is logged in as a different user or the client is not the one that created the session. z9Can only use session with the MongoClient that started itzBCannot use session after authenticating with different credentialsN)_clientr%_authsetr)rrrr r r rs  zSocketInfo.validate_sessioncCs\|jrdSd|_z|jWn tyYnw|r*|jr,|j|j|j|dSdSdS)z$Close this connection with a reason.NT) rr\close Exceptionrrpublish_connection_closedr:r)rreasonr r r close_sockets   zSocketInfo.close_socketcCs&|jdkr|r|||dSdSdS)z$Add cluster time for MongoDB >= 3.6.rN)r_send_cluster_time)rr/rrr r r rszSocketInfo.send_cluster_timecCs t|_dSrQrrrr r r update_last_checkin_time z#SocketInfo.update_last_checkin_timecCs ||_dSrQ)r)rrr r r update_is_writable zSocketInfo.update_is_writablecCs t|jS)z9Seconds since this socket was last checked into its pool.r3rr r r idle_time_secondss zSocketInfo.idle_time_secondscCs*|tjt|tjrt|j|dSrQ)r1r.ERRORrr=r?rr:)rr?r r r r s  z$SocketInfo._raise_connection_failurecCs |j|jkSrQrmrotherr r r __eq__r5zSocketInfo.__eq__cCs ||k SrQr r:r r r __ne__"r7zSocketInfo.__ne__cCs t|jSrQ)hashr\rr r r __hash__%r7zSocketInfo.__hash__cCs"dt|j|jr dp dt|fS)NzSocketInfo(%s)%s at %sz CLOSED)reprr\rrrr r r __repr__(s  zSocketInfo.__repr__)rrr__doc__rrr2PRIMARYrr/rr0rrr r*r$rr1rr4r6r8rr<r=r?rBr r r r rsH W    rc Cs|\}}|dr4ttdstdttj}t|z|||WStjy3| wtj }tj rA|dkrAtj }d}t |||tjD]s}|\}} } } } zt|| ttddB| }Wntjyut|| | }Ynwt|z*|tjtjd||j|tjtj|j|jrt||| |WStjy} z | }| WYd} ~ qLd} ~ ww|dur|td ) zGiven (host, port) and PoolOptions, connect and return a socket object. Can raise socket.error. This is a modified version of create_connection from CPython >= 2.7. z.sockAF_UNIXz-UNIX-sockets are not supported on this system localhostN SOCK_CLOEXECrrTzgetaddrinfo failed)endswithr_r=r#rErIfilenoconnectr?r-AF_INEThas_ipv6 AF_UNSPEC getaddrinfo SOCK_STREAMr`rcrb TCP_NODELAY settimeoutr SOL_SOCKET SO_KEEPALIVErrR)r:optionsrrr\familyerrresafsocktypeprotorKsaer r r _create_connection0sZ           r])rtc Cst||}|j}|durr|d}ztr!t|rtr!|j||d}n||}Wn'ty3|tyN}z|t ||dWYd}~nd}~ww|j rrt |ddsr|j rrz t ||dWn tyq|w||j|S)zGiven (host, port) and PoolOptions, return a configured socket. Can raise socket.error, ConnectionFailure, or CertificateError. Sets socket's SSL and timeout options. Nr)server_hostnamezSSL handshake failed: check_hostnameF)hostname)r]r _HAVE_SNIr; _PY37PLUS wrap_socketr r-IOErrorr verify_moder`rr4 getpeercertr rQr)r:rTr\rrexcr r r _configured_socketxs<      ric@seZdZdZdS)_PoolClosedErrorzZInternal error raised when a thread tries to get a connection from a closed pool. N)rrrrCr r r r rjsrjc@seZdZdddZddZddZdd Zd d Zd d ZddZ e j dddZ ddZ dddZddZddZddZdS) PoolTcCsd|_t|_t|_d|_d|_d|_ d|_ d|_ t |_||_||_||_|jo7|jjduo7|jjj|_|jjdusE|jjdurHd}n|jj|jj}t|jj||_t|_|jrm|jj|j|jjdSdS)z :Parameters: - `address`: a (hostname, port) tuple - `options`: a PoolOptions instance - `handshake`: whether to call ismaster for each new SocketInfo rTrFN)_check_interval_seconds collectionsdequesockets threadingLocklockactive_socketsnext_connection_idrrrr~getpidpidr:r handshakerrrrrcreate_semaphore_socket_semaphorer1socket_checkerpublish_pool_createdr)rr:rTrw max_waitersr r r rs>       z Pool.__init__cCs|j1|jr WddS|jd7_t|_|jt}|_d|_ |r-d|_Wdn1s7wY|j j }|rZ|D]}| t jqD|jrX||jdSdS|jrc||j|D]}| t jqedS)NrTrT)rrrrr~rurvrormrnrsrrr1r. POOL_CLOSEDrpublish_pool_closedr:publish_pool_clearedSTALE)rr-ror sock_infor r r _resets0   z Pool._resetcCsJ||_|j|jD]}||jq WddS1swYdS)zXUpdates the is_writable attribute on all sockets currently in the Pool. N)rrrror6)rrr=r r r r6s  "zPool.update_is_writablecC|jdddS)NFr-rrr r r resetz Pool.resetcCr)NTrrrr r r r- rz Pool.closecCsn|jjdur@|j/|jr1|jd|jjkr1|j}|tj|jr1|jd|jjksWdn1s;wY |jt |j|j |jj krZ WddSWdn1sdwY|j dsqdSz>|}|j(|j|kr|tj WdW|j dS|j|Wdn1swYW|j n|j wqA)zRemoves stale sockets then adds new ones if pool is too small and has not been reset. The `reference_pool_id` argument specifies the `pool_id` at the point in time this operation was requested on the pool. NrTF)rrrrror8popr1r.IDLElenrsrryacquirerJrrrelease appendleft)rreference_pool_idrr r r remove_stale_sockets sD      zPool.remove_stale_socketsc Cs|j|j}|jd7_Wdn1swY|jj}|jr+||j|d}z t|j|j}Wn-tj yc}z |durG| |jrS| |j|t j t|j|WYd}~nd}~wwt|||j|}|jr{||jjd|j|_|S)zConnect to Mongo and return a new SocketInfo. Can raise ConnectionFailure or CertificateError. Note that the pool does not keep a reference to the socket -- you must call return_socket() when you're done with it. rTN)rrrtrrrpublish_connection_createdr:rir=r?r-r/r.r9rrrwrrr)rconn_idrr\r?rr r r rJ/s2  z Pool.connectFccs|jj}|jr||j|}d}z||d}|jr'||j|j|VWn|j ||d|jrE|sE|jj |jt j |sO| |dSdS)a,Get a socket from the pool. Use with a "with" statement. Returns a :class:`SocketInfo` object wrapping a connected :class:`socket.socket`. This method should always be used in a with-statement:: with pool.get_socket(credentials, checkout) as socket_info: socket_info.send_message(msg) data = socket_info.receive_message(op_code, request_id) The socket is logged in or out as needed to match ``all_credentials`` using the correct authentication mechanism for the server's wire protocol version. Can raise ConnectionFailure or OperationFailure. :Parameters: - `all_credentials`: dict, maps auth source to MongoCredential. - `checkout` (optional): keep socket checked out. FT)publish_checkinN) rrr$publish_connection_check_out_startedr:_get_socket_no_authr*publish_connection_checked_outr return_socket#publish_connection_check_out_failedr- CONN_ERROR)rr'checkoutrr checked_authr r r get_socketSs0    zPool.get_socketc Cst|jtkr ||jr|jr|jj|j t j t d|j d|jjs,||j|jd7_Wdn1sAwYz?d}|durz|j |j}Wdn1sawYWn tyt|}Ynw||r|d}|dusMW|SW|Sty|j |j|jd8_Wdn1swY|jr|jj|j t jw)z8Get or create a SocketInfo. Can raise ConnectionFailure.z?Attempted to check out a connection from closed connection poolTrTN)rvr~rurrrrrrr:r-r}rjryrr_raise_wait_queue_timeoutrrrsropopleft IndexErrorrJ _perishedr.rrrrr r r rsZ      zPool._get_socket_no_authcCs|jj}|jr|r||j|j|jtkr| n=|j r'| t j n3|j|jkr4| t jn&|j sZ|||j|j|j|Wdn1sUwY|j|j|jd8_WddS1suwYdS)zReturn the socket to the pool, or if it's closed discard it. :Parameters: - `sock_info`: The socket to check into the pool. - `publish_checkin`: If False, a ConnectionCheckedInEvent will not be published. NrT)rrrpublish_connection_checked_inr:rrvr~rurrr1r.r}rrr4r6rrrrorryrrs)rrrrr r r rs&     "zPool.return_socketcCsp|}|jjdur||jjkr|tjdS|jdur6d|jks'||jkr6|j|j r6|tj dSdS)a;This side-effecty function checks if this socket has been idle for for longer than the max idle time, or if the socket has been closed by some external network error. Checking sockets lets us avoid seeing *some* :class:`~pymongo.errors.AutoReconnect` exceptions on server hiccups, etc. We only check if the socket was closed by an external error if it has been > 1 second since the socket was checked into the pool, to keep performance reasonable - we can't avoid AutoReconnects completely anyway. NTrF) r8rrr1r.rrlrz socket_closedr\r9)rrr8r r r rs       zPool._perishedcCs6|jj}|jr||jtjtd|jj|jj f)NziTimed out while checking out a connection from connection pool with max_size %r and wait_queue_timeout %r) rrrrr:r-TIMEOUTr#rr)rrr r r rs zPool._raise_wait_queue_timeoutcCs|jD]}|dqdSrQ)ror1rr r r __del__s  z Pool.__del__N)T)F)rrrrrr6rr-rrJ contextlibcontextmanagerrrrrrrr r r r rks 1 #$ / 0 rkrQ)rrr~rr=sysrprmsslrr`rb ImportErrorr?r r r7bsonrbson.py3compatrrrrbson.sonrpymongorrrrpymongo.client_sessionrpymongo.commonrrrrrrrr r!pymongo.errorsr"r#r$r%r&r'r(r)r*pymongo.ismasterr+pymongo.monotonicr,rpymongo.monitoringr-r.pymongo.networkr/r0r1pymongo.read_preferencesr2pymongo.server_typer3pymongo.ssl_match_hostnamer4 ipaddressr5r;r_rLrCrDrErFrIrWrYrl_winregwinregOpenKeyHKEY_LOCAL_MACHINEkey QueryValueExrV_rXrOSErrorrRrhr startswith version_infojoinlinux_distribution_namesystemmachinermac_ver win32_verjava_ver_ver_arch system_aliasrq_aliasedpython_implementationrpypy_version_infoencoderobjectrrr]rcrirjrkr r r r s>      ,,      #                                 2\E0