h  ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z m ZddlmZddlmZmZmZddlmZddlmZmZmZmZddlmZddlmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2dd l3m4Z4dd l5m6Z7dd l8m9Z9m:Z:dd l;mm?Z?ddl@mAZAddlBmCZCddlDmEZE ddlFmGZGdZH ddlLmLZLmMZMmNZNmOZOdZPdZQdZRdZSejdk(rG ddlTZUdZV eUjeUjd5ZYeVeYd d!ZZeVeYd"d#Z[dddd$Z]nd%Z^d&Z]ed'ed(d)efgfgZ_ejjd*rejdd+d,kr1d-jejDcgc]}|r|c}ZdnejZded.ejfd/edfd0ejfd)ejfge_d1<nejd2k(rXed.ejfd/ejfd0ejfd)ejdfge_d1<n|ejdk(red.ejfd/d-jejejffd0ejfd)d3jejd4d5fge_d1<nejjd6r0ejd7\ZdZkZled.edfd/edfd0elfd)ekfge_d1<nejejejejZoed.ejfd/d-jeodd+Dcgc]}|s| c}fd0ejfd)eod+fge_d1<ejjd8rjd-jejd9jeeqejd:d9jeeqejzfe_d;<nejjd6ryd-jejd9jeeqejddNd?ZtGd@dAeuZvdBZwdCZxGdDdEeuZyGdFdGeuZzdHZ{dIZ|GdJdKe2Z}GdLdMZ~y#eI$r eJedrejrdZHndZHYwxYw#eI$rdZPYwxYw#eI$rddlUZUYwxYw#1swYxYw#e\$rd!ZZd#Z[YwxYwcc}wcc}w)ON)SSLErrorHAS_SNI IPADDR_SAFE)DEFAULT_CODEC_OPTIONS)imap itervalues_unicode)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) AutoReconnectCertificateErrorConnectionFailureConfigurationErrorInvalidOperationDocumentTooLargeNetworkTimeoutNotMasterErrorOperationFailure PyMongoError)IsMaster)time)ConnectionCheckOutFailedReasonConnectionClosedReason)commandreceive_message)ReadPreference) SERVER_TYPE) SocketChecker)match_hostname) ip_addresscX tt|y#ttf$rYywxYwNTF)r-r ValueError UnicodeErroraddresss O/var/www/html/ranktracker/api/venv/lib/python3.12/site-packages/pymongo/pool.py is_ip_addressr5Fs.  x( )L)  s )) inet_ptonc tj|y#tj$rB tjtj|Yy#tj$rYYywxYwwxYwr/)socket inet_atonerrorr6AF_INET6r2s r4r5r5Os_ !  )<< !!$$V__g>||! !  !s&A-$AA)%A-(A))A-cn tj|y#tj$r d|vrYyYywxYw)NT:F)r8r9r:r2s r4r5r5^s:   )<< '>  s 44fcntlF_GETFDF_SETFD FD_CLOEXECcTt|t}t|t|tzy)z8Set the close-on-exec flag on the given file descriptor.Nr>)fdflagss r4_set_non_inheritable_non_atomicrFqsb'" b'5:-.cy)z6Dummy function for platforms that don't provide fcntl.N)dummys r4rFrFys rGx win32cz tj||\}}t|S#ttf$r|cYSwxYwN)winreg QueryValueExintOSErrorr0)keynamedefaultvalue_s r4_queryrZsB **35HE1u: $ N s #&::z2SYSTEM\CurrentControlSet\Services\Tcpip\Parameters KeepAliveTimeimKeepAliveIntervalctttdz}tttdz}|tks |tkr$|j t jd||fyy)Nr])min_WINDOWS_TCP_IDLE_MS_MAX_TCP_KEEPIDLE_WINDOWS_TCP_INTERVAL_MS_MAX_TCP_KEEPINTVLioctlr8SIO_KEEPALIVE_VALS)sockidle_ms interval_mss r4_set_keepalive_timesrjs_*,=,DE2,t35 * *66 JJv007K0 27rGctt|rYtt|} |jtj|}||kDr"|j tj||yyy#tj $rYywxYwrP)hasattrr8getattr getsockopt IPPROTO_TCP setsockoptr:)rg tcp_option max_valuesockoptrWs r4_set_tcp_optionrtsu 6: &fj1G //&*<*rGdriver)rVPyMongoversionlinux) typerV architectureosdarwin-r_rjavaPyPy.z (Python %s)platformz(%s)fooidnac|\}}| d|||fz}n|d|}|r||z}t|tjr t|t|trdt |vr t|t |)z9Convert a socket.error to ConnectionFailure and raise it.z %s:%d: %sz: z timed out) isinstancer8timeoutr _SSLErrorstrr)r3r: msg_prefixhostportmsgs r4_raise_connection_failurer sJD$ T4//&3%(S!! E9 %+U*C S!!C  rGc4eZdZdZeeeddeddddddddfdZe dZ e dZ e dZ e dZ e d Ze d Ze d Ze d Ze d Ze dZe dZe dZe dZe dZe dZe dZy) 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_settingsNTcp||_||_||_||_||_||_||_||_| |_| |_ | |_ | |_ | |_ ||_ tjt |_| rd| i|j"d<| r| j$r+t ddd| j$|j"dd<| j&r+t ddd| j&|j"dd<| j(r&t dd| j(|j"d<yyy)NrV applicationr{|r}r)_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__metadatarVr}r)self max_pool_size min_pool_sizemax_idle_time_secondsconnect_timeoutsocket_timeoutwait_queue_timeoutwait_queue_multiple ssl_contextssl_match_hostnamesocket_keepaliveevent_listenersappnamer{compression_settingss r4__init__zPoolOptions.__init__+s+ -,'<$!0 .$6!%8"($6!"2!0  &:#-- 2 .4g->DOOM * {{h'/5>)&1~~h' 2FNN8D))4j)6??/< + rGc&i}|jtk7r|j|d<|jtk7r|j|d<|jt k7r|jdz|d<|j tk7r|j dz|d<|S)zqThe non-default options this pool was created with. Added for CMAP's :class:`PoolCreatedEvent`. maxPoolSize minPoolSizer] maxIdleTimeMSwaitQueueTimeoutMS)rrrrrrrr)roptss r4non_default_optionszPoolOptions.non_default_optionsYs    = 0"&"6"6D    = 0"&"6"6D   ' '+< <$($@$@4$GD !  $ $(: :)-)B)BT)ID% & rGc|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. )rrs r4rzPoolOptions.max_pool_sizejs###rGc|jS)zThe minimum required number of concurrent connections that the pool will maintain to each connected server. Default is 0. )rrs r4rzPoolOptions.min_pool_sizeys ###rGc|jS)zThe maximum number of seconds that a connection can remain idle in the pool before being removed and replaced. Defaults to `None` (no limit). )rrs r4rz!PoolOptions.max_idle_time_secondss +++rGc|jS)zGHow long a connection can take to be opened before timing out. )rrs r4rzPoolOptions.connect_timeout%%%rGc|jS)zKHow long a send or receive on a socket can take before timing out. )rrs r4rzPoolOptions.socket_timeouts$$$rGc|jS)zhHow long a thread will wait for a socket from the pool if the pool has no free sockets. )rrs r4rzPoolOptions.wait_queue_timeouts (((rGc|jS)ztMultiplied by max_pool_size to give the number of threads allowed to wait for a socket at one time. )rrs r4rzPoolOptions.wait_queue_multiples )))rGc|jS)z(An SSLContext instance or None. )rrs r4rzPoolOptions.ssl_contexts!!!rGc|jS)zCCall ssl.match_hostname if cert_reqs is not ssl.CERT_NONE. )rrs r4rzPoolOptions.ssl_match_hostnames(((rGc|jS)zZWhether to send periodic messages to determine if a connection is closed. )rrs r4rzPoolOptions.socket_keepalives &&&rGc|jS)z;An instance of pymongo.monitoring._EventListeners. )rrs r4rzPoolOptions.event_listenersrrGc|jS)zMThe application name, for sending with ismaster in server handshake. )rrs r4rzPoolOptions.appnames~~rGc|jS)zIDriver name and version, for sending with ismaster in handshake. )rrs r4r{zPoolOptions.drivers}}rGc|jSrP)rrs r4rz PoolOptions.compression_settingss***rGc6|jjS)zLA dict of metadata about the application, driver, os, and platform. )rrrs r4metadatazPoolOptions.metadatas##%%rG)__name__ __module__ __qualname__ __slots__rrrrrpropertyrrrrrrrrrrrrrr{rrrIrGr4rr!sv+I&3,'8$ $9K%)t$(4!%tD&*,<\  $ $$$ ,,&& %% )) ** "" )) '' &&   ++&&rGrcr|r5|jD]"}|jdk(s|js |cSy)zDReturn one credential that needs mechanism negotiation, if any. DEFAULTN)values mechanismusernameall_credentialscredss r4_negotiate_credsrs;$++- E)+   rGc|rAt|dk(r3tt|}tjj |Sy)zAReturn the _AuthContext to use for speculative auth, if any. r_N)lennextrr _AuthContextfrom_credentialsrs r4_speculative_contextrs<3/14Z01  11%88 rGc(eZdZdZdZedZy)_CancellationContextcd|_yNF _cancelledrs r4rz_CancellationContext.__init__s rGcd|_y)zCancel this context.TNrrs r4cancelz_CancellationContext.cancels rGc|jS)zWas cancel called?rrs r4 cancelledz_CancellationContext.cancelledsrGN)rrrrrrrrIrGr4rrs  rGrceZdZdZdZddZdZdZdeje dddddddddddddfd Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZy) 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 c||_||_||_t|_d|_t |_d|_d|_ t|_ t|_ t|_t |_d|_d|_d|_|j*j,|_|j0|_|j*j2|_d|_t7|_i|_i|_|j>|_d|_ d|_!|jDstG|_!|j*|_d|_$yr)%rgr3idsetauthsetclosed_timelast_checkin_timeperformed_handshake is_writablermax_wire_versionr max_bson_sizermax_message_sizermax_write_batch_sizesupports_sessions is_mongosop_msg_enabledrr listenersenabled_for_cmaprcompression_contextr+socket_checkernegotiated_mechanismsauth_ctx generationreadycancel_context handshaker more_to_come)rrgpoolr3rs r4rzSocketInfo.__init__s   u  !&#(   0* 0$8!!&#22 $ 5 5$(II$B$B!#' +o&(" // "~~"6"8D II !rGNc*|jddd|SrP) _ismaster)rrs r4ismasterzSocketInfo.ismaster!s~~dD$@@rGctdg}|j }d}|rFd|_|jj|d<|jr||jj |d<nb|`||d<t |dz|d<d}|jjr2|jj|jj|z|jd k\r|||d <t|}|r|jd z|jz|d <t|} | r| j|d <|j!d|d|} t#| |} | j$|_| j|_ | j&|_| j(|_| j*|_| j,du|_| j0t2j4k(|_|r8|jr,|jj9| j } | |_| jd k\|_|r| j>|j@|<| r:| jC| | jEr| |jF| jH<| S)N)r%r_FTclient compressiontopologyVersionr]maxAwaitTimeMSz $clusterTimersaslSupportedMechsspeculativeAuthenticateadmin)publish_eventsexhaust_allowed) awaitable)%r rrrr compressorsrSrrg settimeoutrrsourcerrspeculate_commandr'r#rrrrlogical_session_timeout_minutesr server_typer*Mongosrget_compression_contextrrsasl_supported_mechsrparse_responsespeculate_succeededr credentials) r cluster_timetopology_versionheartbeat_frequencyrcmdperforming_handshaker1rrdocr%ctxs r4r$zSocketInfo._ismaster$s[?#$#'#;#;; '+D $ II..CM((%)%>%>%J%JM"  )%5C! "$'(;D(@$AC !Iyy(( $$II--0CCE  A %,*B".C !1 (- s(:U^^(KC$ %'8 -5-G-G-IC) *ll7C+46C95#// ( 9 9%33 ( 9 9$,$A$A!  4 4D @ !--1C1CC D$=$=++CC$$&C'*D $&771< 080M0MD & &u -   # #H -++-6> h223rGc|jd}|j|_|j}|d}tj||j |S)Nr)r(r!unpack_responser _check_command_responser)rreply unpacked_docs response_docs r4 _next_replyzSocketInfo._next_reply\sT$$T*!..--/ $Q' '' d6K6KLrGFTc|j|| t| | } t|ts t |}| r?|j dkr0| j s$td| j|j fz| | js | td|j dk\r| r| js| j|d<n|j dkr | td| r| j||||j|| ||r |jnd}| xr | j }|jr|j!| t#|||||j$||| ||||j&|||j(| | | |j*|j|||S#t,$rt.$r}|j1|Yd}~yd}~wwxYw) 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.r writeConcernz5Must be connected to MongoDB 3.4+ to use a collation.)parse_write_concern_error collationcompression_ctx use_op_msgunacknowledged user_fieldsr0)validate_sessionrrrr r ok_for_legacyrlevel acknowledgedis_server_defaultdocument _apply_tosend_cluster_timerr_raise_if_not_writabler'rr3rrr! BaseExceptionr)rdbnamespecslave_okread_preference codec_optionscheckallowable_errors check_keys read_concern write_concernrOrPsessionr'retryable_writer/rTr0rrSr:s r4r'zSocketInfo.commanddsL fg.1'=I$ .t9D T22Q6$22$1%%t'<'<=>? ?%)C)C!$EG G  ! !Q &!33#0#9#9D  " "Q &9+@$GI I    dO_ E tWf5&4DNN$ &I}/I/I+I     ' ' 7 24x>>?M"FE3C<<Y--|5N%.+/+C+C&*&9&9*8'2+: < <    2  * *5 1 1 2sAFG,GGc|j)||jkDrtd||jfz |jj|y#t$r}|j |Yd}~yd}~wwxYw)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.)rrrgsendallr^r)rmessage max_doc_sizer:s r4 send_messagezSocketInfo.send_messages{    * 4#5#55"?t11234 4  2 II  g & 2  * *5 1 1 2sA A7A22A7c t|||jS#t$r}|j|Yd}~yd}~wwxYw)zzReceive a raw BSON message or raise ConnectionFailure. If any exception is raised, the socket is closed. N)r(rr^r)r request_idr:s r4r(zSocketInfo.receive_messages=  2"4T5J5JK K 2  * *5 1 1 2s =8=cB|r|jstdddddyy)z]Raise NotMasterError on unacknowledged write if this socket is not writable. z not masterri{')okerrmsgcodeN)rr )rrSs r4r]z!SocketInfo._raise_if_not_writables4 $"2"2 <0@A A#3>rGc|j| |j|||r?|j|}tj|j |j Sy)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)r]ror(r _check_gle_responsecommand_responser)rrqrrnwith_last_errorrHs r4 legacy_writezSocketInfo.legacy_writesf ##$78 #|, ((4E..u/E/E/G/3/D/DF F rGc|j|d|j|}|j}tj||j |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)ror(rxr rGr)rrqrrHresults r4 write_commandzSocketInfo.write_commandsO #q!$$Z0'') ''0E0EF rGc|s |jrtt|}|jj}||z D]=}t j |j ||jj|?||z D]}|j||jsEd|_ |jr1|jj|j|jyyy)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)r r rrr logoutr4discard authenticaterrrpublish_connection_readyr3r)rrcachedr r=s r4 check_authzSocketInfo.check_auths dllO45Fll'')G '/ 2  K..5 $$[1 2 &/ / !!+. / zzDJ$$77 dggN%rGctj|||jj||jj |d|j j |dy)zLog in to the server and store these credentials in `authset`. Can raise ConnectionFailure or OperationFailure. :Parameters: - `credentials`: A MongoCredential. N)r rr addrpopr)rr=s r4rzSocketInfo.authenticate"sP +t, % ""&&{D9 +t,rGc|r>|j|ur td|j|jk7r tdyy)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 )rr'ris r4rUzSocketInfo.validate_session0sU f,&"##4<</&#$$0 rGc|jry|j|r?|jr2|jj |j |j |yyy)z$Close this connection with a reason.N)r  _close_socketrrpublish_connection_closedr3r)rreasons r4 close_socketzSocketInfo.close_socket@sK ;;   d++ NN 4 4 dggv /,6rGc|jryd|_|jr|jj |jj y#t $rYywxYw)zClose this connection.NT)r rrrgclose Exceptionrs r4rzSocketInfo._close_socketIsS ;;        & & (  IIOO    sA A#"A#cL|jj|jS)z?Return True if we know socket has been closed, False otherwise.)r socket_closedrgrs r4rzSocketInfo.socket_closedWs""00;;rGcN|jdk\r|r|j||yyy)z$Add cluster time for MongoDB >= 3.6.r+N)r_send_cluster_time)rr'rir's r4r\zSocketInfo.send_cluster_time[s*  A %&  % %gw 7+1 %rGc"t|_yrPr r rs r4update_last_checkin_timez#SocketInfo.update_last_checkin_time`s !&rGc||_yrP)r)rrs r4update_is_writablezSocketInfo.update_is_writablecs &rGc0t|jz S)z9Seconds since this socket was last checked into its pool.rrs r4idle_time_secondszSocketInfo.idle_time_secondsfsw////rGc|jtjt|tt t frt|j|yrP) rr&ERRORrIOErrorrTrrr3)rr:s r4rz$SocketInfo._raise_connection_failurejs; 0667 egw : ; %dllE : rGc4|j|jk(SrPrzrothers r4__eq__zSocketInfo.__eq__syyEJJ&&rGc||k( SrPrIrs r4__ne__zSocketInfo.__ne__s5=  rGc,t|jSrP)hashrgrs r4__hash__zSocketInfo.__hash__sDIIrGctdt|jd|jxrdxsddt|S)Nz SocketInfo()z CLOSEDz at )reprrgr rrs r4__repr__zSocketInfo.__repr__s2 O KK %I + + tH  rGrP) rrr__doc__rr%r$rKr)PRIMARYrr'ror(r]rzr}rrrUrrrr\rrrrrrrrrIrGr4rrs#"JA6p.3 . 6 634!%%!"*/ %# %W2r2"2AF("O8 -$ / <8 )'0*'! rGrc |\}}|jdrkttds tdtjtj}t |j  |j||Stj}tjr|dk7rtj}d}tj|||tjD]}|\}} } } } tj|| ttddz| }t |j  |j!tj"tj$d|j'|j(|j!tj*tj,|j.|j.r t1||j| |cS||tjd #tj$r|jwxYw#tj$rtj|| | }Y8wxYw#tj$r} | }|jYd} ~ d} ~ wwxYw) 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_CLOEXECrr_zgetaddrinfo failed)endswithrlr8rrrFfilenoconnectr:rAF_INEThas_ipv6 AF_UNSPEC getaddrinfo SOCK_STREAMrmrpro TCP_NODELAYr3r SOL_SOCKET SO_KEEPALIVErrj)r3optionsrrrgfamilyerrresafsocktypeprotorJsaes r4_create_connectionrs JD$ }}Wvy)#%56 6}}V^^,' 6  LL K^^F 4;.!! C!!$ff6H6HI),&HeUB 6==Hwv~qAA5JD ( 6  OOF..0B0BA F OOG33 4 OOF--v/B/B#44 6''$T* LL K-6  ll/00]||  JJL  (|| 6==Xu5D 6|| C JJLL s7/G7+)H.B,I7%H*I  I J#I;;Jc`t||}|j}||d} tr%t|rtr|j ||}n|j |}|jr5t|dds(|jr t|j!||j#|j$|S#t $r|jtttf$r'}|jt||dYd}~d}~wwxYw#t $r|jwxYw)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)rr _HAVE_SNIr5 _IPADDR_SAFE wrap_socketrrrrTrr verify_modermrr, getpeercertr3r)r3rrgrrexcs r4_configured_socketrs gw /D%%Kqz N-"5"..tT.J"..t4  # # %5u=** t//1DA  OOG**+ K+   JJL ), N JJL &gs4L M M  N$   s#xYw#|jj#wxYw)zRemoves stale sockets then adds new ones if pool is too small and has not been reset. The `reference_generation` argument specifies the `generation` at the point in time this operation was requested on the pool. NrF)rrrrrrrr&IDLErrrracquirerrrrelease appendleft)rreference_generationrrs r4remove_stale_socketszPool.remove_stale_socketshs 99 * * 6 H||||B'99;dii>]>]] $ 0 0 2I**+A+F+FG||||B'99;dii>]>]] H   %(;(;; //0   0 ))11%8 1 LL9 YY7*>>!../E/K/KL 7&&..0LL++I6 7&&..0)  H H  77&&..0sHB:H 3;HH1:0H%*H1 H%(H1 HH"%H.*H11I NcF|j5|j}|xjdz c_ddd|jj}|jr|j |j  t|j |j}t#|||j }|j$r"|j'||j(|_ |j+||S#1swYxYw#t$rn}|jr+|j|j tjt|tttfrt!|j |d}~wwxYw#t$r!|j-tjwxYw)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. r_N)rrrrrpublish_connection_createdr3rrrr&rrrrTrrrr r%rrr)rrconn_idrrgr:rs r4rz Pool.connects^YY )--G  # #q ( # )II--   0 0w G %dllDII>DtT4<<A >>    /(44D     1 ? ) ) $$33LL'+A+G+GI%'7I!>?)$,,>  "   " "#9#?#? @  s0"C06 C<E60C9< E3A)E..E36*F c#lK|jj}|jr|j|j|j |}|jr&|j |j|j ||s|j|yy#|j|xYww)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. N) rrr$publish_connection_check_out_startedr3 _get_socketpublish_connection_checked_outr return_socket)rrcheckoutrrs r4 get_socketzPool.get_sockets.II--   : :4<< H$$_5   4 4 ill , .O ""9-     y ) sBB4BB4B11B4c|jtjk7r|j|jrU|j r>|j jj|jtjtd|jjd|j js|j!d}d} |j"5|xj$dz c_d}ddd|G |j"5|j&j)}ddd|j+|rd} |G|j1||S#1swYexYw#1swY?xYw#t,$r|j/|}YJwxYw#t2$r|r|j5t6j8|jj;|r7|j"5|xj$dzc_dddn #1swYnxYw|j r>|j jj|jtj<wxYw)z8Get or create a SocketInfo. Can raise ConnectionFailure.z?Attempted to check out a connection from closed connection poolTNFr_)rrrrr rrr#publish_connection_check_out_failedr3r%rrrrr_raise_wait_queue_timeoutrrrpopleft _perished IndexErrorrrrrr&rr CONN_ERROR)rrr incrementeds r4rzPool._get_sockets  88ryy{ " JJL ;;$$ ))MMLL"@"L"LN"  %%--dii224  * * ,    ###q(#"  ##);$(LL$8$8$: ; ~~i0$( #   1 = # # ;;!> $ _ =I> &&'='C'CD  " " * * ,YY-''1,'---$$ ))MMLL"@"K"KM  s F$E < F E8E,.E86F F E)%F,E51E88FFFFAI!*H  I! H AI!cH|jj}|jr&|j|j|j |j tjk7r|jn|jr |jtjn|js|j5|j|jk7r |jtj nF|j#|j%|j&|j(j+|ddd|j,j/|j5|xj0dzc_dddy#1swYNxYw#1swYyxYw)zReturn the socket to the pool, or if it's closed discard it. :Parameters: - `sock_info`: The socket to check into the pool. Nr_)rrrpublish_connection_checked_inr3rrrrrr rr&rrrrrrrrrrrr)rrrs r4rzPool.return_sockets1 II--   3 3DLL),, O 88ryy{ " JJL{{&&'='I'IJ%%YY;!++t>!../E/K/KL!::<!44T5E5EF // :; &&( YY %   1 $  % %;; % %s?BF -F FF!c|j}|jj9||jjkDr |jtj y|j Nd|j k(s||j kDr0|jr |jtjy|j|jk7r |jtjyy)aReturn True and close the connection if it is "perished". 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, or if the socket's generation is outdated. 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. TrF) rrrrr&rrrrrr)rrrs r4r zPool._perished4s&779 II + + 7!DII$C$CC  " "#9#>#> ?  ( ( 4T111!D$@$@@&&(&&'='C'CD   4?? 2  " "#9#?#? @rGc |jj}|jr*|j|jt j td|jjd|jj)NzMTimed out while checking out a connection from connection pool with max_size z and wait_queue_timeout ) rrrrr3r%TIMEOUTrrr)rrs r4r zPool._raise_wait_queue_timeoutVsiII--   9 9 <DD F '')E)E GH HrGcH|jD]}|jdyrP)rr)rrs r4__del__z Pool.__del__`s% )I  " "4 ( )rG)TrP)F)rrrrrrrrrr contextlibcontextmanagerrrrr r rrIrGr4rrs`.=`E4<! !1F'R'.'.R7r%: DH)rGrrP)rrrrr8sysrrpymongo.ssl_supportrrrrrrbsonrbson.py3compatrrr bson.sonr pymongor r r rpymongo.client_sessionrpymongo.commonrrrrrrrrrpymongo.errorsrrrrrrrr r!r"pymongo.ismasterr#pymongo.monotonicr$r pymongo.monitoringr%r&pymongo.networkr'r(pymongo.read_preferencesr)pymongo.server_typer*pymongo.socket_checkerr+pymongo.ssl_match_hostnamer, ipaddressr-r5 ImportErrorrlrr?r@rArBrFrbrdry_winregrQrZOpenKeyHKEY_LOCAL_MACHINErUrarcrTrjrtr startswith version_infojoinlinux_distribution_namesystemmachinermac_ver win32_verjava_ver_ver_arch system_aliasr}_aliasedpython_implementationrpypy_version_infoencoderobjectrrrrrrrrr)parts0r4rAsO  !! '55;;B000 * * *&+8.3+05)$R  99/<<7  ( V^^))EG NJM#)##H '-c3F'M $  N2 ?  s')[)ABCD  <<7# f$5(557A4;?AB ! "#  )))+, $H$$&' IdO \\X "# "# )))+, $H$$&q)* IdO \\W "# ?8??,.>h.>.>.@ABC )))+, CHH/X//1!A678 IdO \\V$***,R0E4    DIdO%x$$+8++-/?x/?/?/ACH "# HRaLADD4ABC )))+, HQK IdO"8!!#..v6HH ' ' ' ) $sC112 3 $sC,<,<"=> > @AIj \\V$HH ' ' ' ) $sC,,- . #((OHOO-/?x/?/?/ABC C EFIj  HH ' ' ' ) $sC,,- . 01Ij f!.n&&n&b 6 Z Z z B1J-` | W)W)E!v{# ! %!R     N N ( '#' (RA\Bsr6 VW%W-W- W W- W=*X2X!V>=V>W  W  WW W*%W-- W:9W: