Ii+ SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKJrJrJrJrJrJrJrJrJr SSKJr SSKJrJr SSKJrJrJ r J!r!J"r" SSK#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r.J/r/ SSK0J1r1J2r2 SS K3J4r4J5r5 SS K6J7r7J8r8J9r9J:r: SS K;JJ?r? SS K@JArA SSKBJCrC SSKDJErE SSKFJGrG SSKHJIrI SSKJJKrKJLrL SSKMJNrN SSKOJPrP SSKQJRrRJSrS \(aTSSKJTrT SSKUJVrV SSKWJXrXJYrYJZrZ SSK[J\r\J]r] SSK^J_r_ SSK`Jara SSKBJbrb SSKcJdrd SSKMJere SSKfJgrgJhrh SS KiJjrjJkrkJlrl SS!KmJnrn SS"KoJprpJqrqJrrrJoro SES#jrsS%ruS&rvS'rwS(rx\ RS):XaGSSKzr{S*r|\{R"\{RS+5r\|"\S,S-5r\|"\S.S/5rSSS5 S0rO SFS1jrSGS2jrSHSIS3jjrSJS4jrSKS5jrSLS6jr"S7S85r"S9S:5rSMS;jrSNS<jr"S=S>\-5r"S?S@5r"SASB5r"SCSD5rg!\ta SES$jrsNf=f!\ta SSK{r{Nf=f!,(df  N=f!\a S-rS/rNf=f)O) annotationsN) TYPE_CHECKINGAny GeneratorMappingMutableMappingNoReturnOptionalSequenceUnion)DEFAULT_CODEC_OPTIONS)_csothelpers_shared) MAX_BSON_SIZEMAX_MESSAGE_SIZEMAX_WIRE_VERSIONMAX_WRITE_BATCH_SIZE ORDERED_TYPES) AutoReconnectConfigurationErrorConnectionFailureDocumentTooLargeExecutionTimeoutInvalidOperationNetworkTimeoutNotPrimaryErrorOperationFailure PyMongoErrorWaitQueueTimeoutError_CertificateError)Hello HelloCompat) _create_lock_Lock)_CONNECTION_LOGGER_ConnectionStatusMessage _debug_log _verbose_connection_error_reason)ConnectionCheckOutFailedReasonConnectionClosedReason)sendall) PoolOptions)ReadPreference)_add_to_command) SERVER_TYPE) SocketChecker)HAS_SNISSLError)_validate_session_write_concern)_handle_reauth)commandreceive_message) CodecOptions)ObjectId) SnappyContext ZlibContext ZstdContext)_OpMsg_OpReply)_sslConn) ReadConcern) _ServerMode) _AuthContext) ClientSession) MongoClient_MongoClientErrorHandler) ClusterTime_Address _CollationIn) WriteConcern)F_GETFDF_SETFD FD_CLOEXECfcntlcT[U[5n[U[U[-5 g)z8Set the close-on-exec flag on the given file descriptor.N)rLrIrJrK)fdflagss >/venv/lib/python3.13/site-packages/pymongo/synchronous/pool.py_set_non_inheritable_non_atomicrQlsb'" b'5:-.cg)z6Dummy function for platforms that don't provide fcntl.N)rNs rPrQrQusrRTx win32cz[R"X5up4[U5$![[4a Us$f=fN)winreg QueryValueExintOSError ValueError)keynamedefaultvalue_s rP_queryres> **35HEu: $ N s "%::z2SYSTEM\CurrentControlSet\Services\Tcpip\Parameters KeepAliveTimeimKeepAliveIntervalc[[[S-5n[[[S-5nU[:d U[:a#UR [ RSX45 gg)Nrh)min_WINDOWS_TCP_IDLE_MS_MAX_TCP_KEEPIDLE_WINDOWS_TCP_INTERVAL_MS_MAX_TCP_KEEPINTVLioctlsocketSIO_KEEPALIVE_VALS)sockidle_ms interval_mss rP_set_keepalive_timesrvsX*,=,DE24F4MN ) )[;S-S JJv001g2K L.TrRc[[U5(aX[[U5nUR[RU5nXB:a!UR [RX25 ggg![ a gf=frZ)hasattrrqgetattr getsockopt IPPROTO_TCP setsockoptr^)rs tcp_option max_valuesockoptrbs rP_set_tcp_optionrsp 6: & &fj1G //&*<*rRc:UupEUbSXEU4-nOUSU3nU(aX&-nSU;aU[U5- n[U[R5(a [ U5Ue[U[ 5(aS[ U5;a [ U5Ue[U5Ue)z9Convert a socket.error to ConnectionFailure and raise it.z %s:%d: %s: zconfigured timeouts timed out)format_timeout_details isinstancerqtimeoutrr2strr)addresserror msg_prefixtimeout_detailshostportmsgs rP_raise_connection_failurersJD T//b C' %o66%((S!u, E8 $ $E )B S!u,C e+rRcfU(aU[R"5- OSnURU5$rZ)time monotonicwait) conditiondeadliners rP _cond_waitrs&-5h))4G >>' ""rRc0n[R"5nURnURnU(aUS-US'U(aU(dUS-US'U(aUS-US'U$)Nrh timeoutMSsocketTimeoutMSconnectTimeoutMS)r get_timeoutsocket_timeoutconnect_timeout)optionsdetailsrrrs rP_get_timeout_detailsrsiG!G++N--O&~ g%3d%:!"&5&<"# NrRcrSnU(a-US- nSHnX ;dM USUSXS3- nM USSnUS- nU$) Nz (configured timeouts:)rrr rzms,)rT)rresultrs rPrrs^ F**KG!AgYb)9(:#>>L#  MrRc<\rSrSrSSjrSSjr\SSj5rSrg) _CancellationContextcSUlgNF _cancelledselfs rP__init___CancellationContext.__init__s rRcSUlg)zCancel this context.TNrrs rPcancel_CancellationContext.cancels rRcUR$)zWas cancel called?rrs rP cancelled_CancellationContext.cancelledsrRrNreturnNonerbool) __name__ __module__ __qualname____firstlineno__rrpropertyr__static_attributes__rTrRrPrrs  rRrc*\rSrSrSrS&SjrS'SjrS(SjrS)SjrS)Sjr S)Sjr S*S jr S+S jr S,S jr S*S jr\\R"\S SSSSSSSSS SS4S-Sjj5rS.SjrS/SjrS0SjrS1SjrS2SjrS3S4SjjrS5SjrS6SjrS)SjrS7SjrS8SjrS9SjrS)Sjr S:Sjr!S;Sjr"SS#jr&S?S$jr'S%r(g)@ ConnectionzStore a connection with some metadata. :param conn: a raw connection object :param pool: a Pool instance :param address: the server's (host, port) :param id: the id of this socket in it's pool c[R"U5UlXlX0lX@lSUl[R"5Ul SUl SUl [Ul [Ul[ Ul[$UlSUlSUlSUlSUlUR0R2UlUR6UlUR8UlUR0R:UlSUl[A5Ul!SUl"SUl#SUl$URJUl&URLRO5Ul(SUl)[U5Ul+UR0UlSUl,SUl-SUl.SUl/SUl0SUl1UR0RdUl3SUl4URjUl5[R"5Ul6g)NFg)7weakrefrefpool_refconnridclosedrrlast_checkin_timeperformed_handshake is_writablermax_wire_versionr max_bson_sizermax_message_sizermax_write_batch_sizesupports_sessionshello_ok is_mongosop_msg_enabledopts_event_listeners listenersenabled_for_cmapenabled_for_logging_compression_settingscompression_settingscompression_contextr0socket_checkeroidc_token_gen_idnegotiated_mechsauth_ctxgenpool_gen get_overall generationreadyrcancel_context more_to_come service_idserver_connection_id pinned_txn pinned_cursoractiver last_timeout connect_rtt _client_id creation_time)rrpoolrrs rPrConnection.__init__ s D)    !%!1#( !& 0* 0$8!!&# #33 $ 5 5#'#;#; $(II$C$C!Y] -:_045904  --335 4H4JII "'.237! "  II44//!^^-rRcfXR:XagXlURRU5 g)z?Cache last timeout to avoid duplicate calls to conn.settimeout.N)rr settimeout)rrs rPset_conn_timeoutConnection.set_conn_timeout<s) '' ' # W%rRc[R"5nUc7UR(d%URURR 5 g[R "5nUc URnX4- nUS:aI[UR5n[U5nSUSSUSSU3n[USSUSS.UR5eUb[US-5US 'URU5 U$) Nrz5operation would exceed time limit, remaining timeout:z.5fz <= network round trip time:r2okerrmsgcoderh maxTimeMS) r remainingrrrrget_rttrrrrrr]) rclientcmdrrtt max_time_msr formattedrs rP apply_timeoutConnection.apply_timeoutCs//# ?$$%%dii&>&>?mmo ;""Cm ?2499=O.?ILWUXMYuvyz}u~~AJ@KLF"FB7%%   ?";#56C  g&rRc8SUlUR(aegNT)rrrs rPpin_txnConnection.pin_txnbs%%%%%rRc8SUlUR(aegr)rrrs rP pin_cursorConnection.pin_cursorfs!??""?rRcUR5nU(aURU5 gUR[R5 grZ)rcheckin close_connr*STALE)rrs rPunpinConnection.unpinjs/}}  LL  OO288 9rRcURR(d,UR(dURR(aSUl[ R S0$[ RSSS0$)NTrjhelloOk)r server_apir load_balancedrr"CMD LEGACY_CMDrs rP hello_cmdConnection.hello_cmdqsO 99  4==DII4K4K"&D OOQ' '**Ay$? ?rRc(URSSS5$rZ)_hellors rPhelloConnection.hellozs{{4t,,rRcUR5nUR(+nSnU(akSUlURRUS'UR(aURR US'URR (aSUS'ObUb_X$S'Uce[US-5US'SnURR(a(URURRU-5 U(dUbXS 'URRnU(aURS :Xa0UR(aURS -UR-US 'S SKJn UR R#XpR$5n U (aU R'5n U bXS'OSn U(a[(R*"5n UR-SUSUS9n U(a[(R*"5W - Ul[1XS9n U R2UlU R4UlU R6UlU R8UlU R:UlU R<SL=(a U R>Ul U R<UlU RBUl!U RD[FRH[FRJ[FRL[FRN[FRP4;Ul)U RD[FRT:HUl+U RD[FRX:HUl-U(a<UR(a+URR]U R 5nXl/SUl0U RbUl2U(aU RfUl4U (a,U RkU 5 U Rm5(aXl7URR (aWU Rp(d [sS5eU RpUl8URtRwURp5Ul<U $)NFTr compression loadBalancedtopologyVersionrhmaxAwaitTimeMSz $clusterTimeDEFAULT.saslSupportedMechsrauthspeculativeAuthenticateadmin)publish_eventsexhaust_allowed) awaitablez`Driver attempted to initialize in load balancing mode, but the server does not support this mode)=r"rrmetadatar compressorsrr]rr _credentials mechanismusernamesourcepymongo.synchronousr1rAfrom_credentialsrspeculate_commandrrr5rr!rrrrrlogical_session_timeout_minutes is_readablerr server_typer/ RSPrimary RSSecondary RSArbiterRSOtherRSGhostis_repl Standalone is_standaloneMongosrget_compression_contextrr connection_idrsasl_supported_mechsrparse_responsespeculate_succeededrrrrgetr)r cluster_timetopology_versionheartbeat_frequencyr performing_handshaker6credsr1rspeculative_authenticatestartdocr&ctxs rPr%Connection._hello}s nn#'#;#;; '+D $ II..CM((%)%>%>%J%JM"yy&&&*N#  )%5! "&2 22$'(;d(B$CC !Iyy((%%dii&?&?BU&UV# (@".  && )+,1LL3,>,O() 0((99%NH+3+E+E+G(+75M12H NN$Ell7CylY #~~/%7D c/ ,, % 6 6"00 % 6 6$)$>$>!  1 1 = S%BSBS ?D>c>c, ((  ! !  # #  ! !       -   #..+2H2HH**k.@.@@ D$=$=++CCEDUDUVC'* $"$)$7$7! $)$>$>D !   # #E *++-- ( 99 " "##(A$..DO"mm//@DO rRcURS5nURUlUR5nUSn[R"X0R 5 U$Nr)r6runpack_responser_check_command_responser)rreply unpacked_docs response_docs rP _next_replyConnection._next_replysR$$T*!..--/ $Q' ..|=R=RSrRTNFcURX5 [X5n [U[5(d [ U5nUbUR (dU b [ S5eURU5 U (aU RX-X05 URX+U 5 U(a UROSn[U=(a UR (+5nUR(aURU5 [UUUURUUU U UUUR UUR"UU U UR$URUUUUS9$![&[(4a e[*anUR-U5 SnAgSnAff=f)aExecute a command or raise an error. :param dbname: name of the database on which to run the command :param spec: a command document as a dict, SON, or mapping object :param read_preference: a read preference :param codec_options: a CodecOptions instance :param check: raise OperationFailure if there are errors :param allowable_errors: errors to ignore if `check` is True :param read_concern: The read concern for this command. :param write_concern: The write concern for this command. :param parse_write_concern_error: Whether to parse the ``writeConcernError`` field in the command response. :param collation: The collation for this command. :param session: optional ClientSession instance. :param client: optional MongoClient for gossipping $clusterTime. :param retryable_write: True if this command is a retryable write. :param publish_events: Should we publish events for this command? :param user_fields: Response fields that should be decoded using the TypeDecoders from codec_options, passed to bson._decode_all_selective. Nz3Collation is unsupported for unacknowledged writes.)parse_write_concern_error collationcompression_ctx use_op_msgunacknowledged user_fieldsr5 write_concern)validate_sessionr3rrdict acknowledgedradd_server_api _apply_tosend_cluster_timerrr_raise_if_not_writabler5rrrrrr BaseExceptionr)rdbnamespecread_preference codec_optionscheckallowable_errors read_concernrlrfrgsessionrretryable_writer4rkr5rrjrs rPr5Connection.commandsbR f.1'I$ ..:D%)C)CyGX$%Z[ [ D!    d_ K tf5&4DNN$ mNM4N4N0NO     ' ' 7 2  ""*C# $ 8 8..-' /+- 0!/2   2  * *5 1 1 2s6AEE; E66E;cURb(X R:a[SX R4-5e[URU5 g![anUR U5 SnAgSnAff=f)zmSend 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.)rrr+rrtr)rmessage max_doc_sizers rP send_messageConnection.send_message8ss    )l=O=O.O"?BNPbPbAcd   2 DIIw ' 2  * *5 1 1 2sA A3A..A3c[XUR5$![anURU5 SnAgSnAff=f)zjReceive a raw BSON message or raise ConnectionFailure. If any exception is raised, the socket is closed. N)r6rrtr)r request_idrs rPr6Connection.receive_messageHs;  2"4T5J5JK K 2  * *5 1 1 2s =8=cVU(a"UR(d[SSSSS.5egg)zNRaise NotPrimaryError on unacknowledged write if this socket is not writable. z not primaryri{'rN)rr)rrjs rPrs!Connection._raise_if_not_writableRs+ $"2"2!-]\a1bc c#3>rRcHURS5 URX5 g)zSend unack OP_MSG. Can raise ConnectionFailure or InvalidDocument. :param msg: bytes, an OP_MSG message. :param max_doc_size: size in bytes of the largest document in `msg`. TN)rsr)rrrs rP unack_writeConnection.unack_writeZs  ##D) #,rRcURUS5 URU5nURU5n[R"XPR 5 U$)zSend "insert" etc. command, returning response as a dict. Can raise ConnectionFailure or OperationFailure. :param request_id: an int. :param msg: bytes, the command message. r)rr6command_responserr_r)rrrrxr`rs rP write_commandConnection.write_commandesO #q!$$Z0'' 6 ..v7L7LM rRc U(aUR(aSUlSUlUR(Gd9URRnU(aSSKJn URX US9 SUl[R"5UR- nUR(a@URceURRURURU5 UR (az["R$"[&R(5(aP[+["UR,[.R0URSURSURUS9 gggg) zXAuthenticate to the server if needed. Can raise ConnectionFailure or OperationFailure. NFrr0)reauthenticateTrjclientIdr serverHost serverPortdriverConnectionId durationMS)rrrrr9r=r1 authenticaterrrrrpublish_connection_readyrrrr% isEnabledForloggingDEBUGr'rr& CONN_READY)rrrVr1durations rPrConnection.authenticatews  '' $ DJzzzII**E4!!%n!MDJ~~'$*<*<,K,KGMM,Z,Z&!__4??#||A#||A'+ww'-['rRcHU(aURULa [S5egg)zsValidate this session before use with client. Raises error if the client is not the one that created the session. z9Can only use session with the MongoClient that started itN)_clientr)rrr|s rPrmConnection.validate_sessions) f,&'bcc- rRc $UR(agUR5 U(aUR(a@URceURR UR UR U5 UR(a[R"[R5(aZ[[UR[RUR SUR SUR [!U5US9 gggg)z$Close this connection with a reason.Nrrjrrrrrreasonr)r _close_connrrpublish_connection_closedrrrr%rrrr'rr& CONN_CLOSEDr()rrs rPrConnection.close_conns ;;   $$~~11188twwPVW'',>,K,KGMM,Z,Z&!__4@@#||A#||A'+ww;FC  -[' rRcUR(agSUlURR5 URR 5 g![ a gf=f)zClose this connection.NT)rrrrclose Exceptionrs rPrConnection._close_connsJ ;;   ""$  IIOO    sA AAcLURRUR5$)z?Return True if we know socket has been closed, False otherwise.)r socket_closedrrs rP conn_closedConnection.conn_closeds""00;;rRc6U(aURX5 gg)zAdd $clusterTime.N)_send_cluster_time)rr5r|rs rPrrConnection.send_cluster_times   % %g 7 rRczURR(a [XRR5 gg)zAdd server_api parameters.N)rrr.)rr5s rPrpConnection.add_server_apis& 99   GYY%9%9 : rRc8[R"5UlgrZrrrrs rPupdate_last_checkin_time#Connection.update_last_checkin_times!%!1rRcXlgrZ)r)rrs rPupdate_is_writableConnection.update_is_writables&rRcF[R"5UR- $)z9Seconds since this socket was last checked into its pool.rrs rPidle_time_secondsConnection.idle_time_secondss~~$"8"888rRcUR(aSnO[RnURU5 [ U[ [ [45(a*[UR5n[URXS9 ge)Nr) rr*ERRORrrIOErrorr^r2rrrr)rrrrs rPr$Connection._raise_connection_failuresZ ::F+11F  egw9 : :*4995G %dllE S rRc4URUR:H$rZ)rrothers rP__eq__Connection.__eq__syyEJJ&&rRc X:X+$rZrTrs rP__ne__Connection.__ne__s   rRc,[UR5$rZ)hashrrs rP__hash__Connection.__hash__sDIIrRcSR[UR5UR=(a S=(d S[ U55$)NzConnection({}){} at {}z CLOSEDr)formatreprrrrrs rP__repr__Connection.__repr__s8'.. O KK %I + tH  rR)+rrrrrrrrrrrrrrrrrrHrJrrrrr@rrrrrrrrrrrrrrrrrrr)rUnion[socket.socket, _sslConn]rPoolrztuple[str, int]rr])rOptional[float]rr)rrCr z"Optional[MutableMapping[str, Any]]rrr)rdict[str, Any])rr!)rRzOptional[ClusterTime]rSz Optional[Any]rT Optional[int]rzHello[dict[str, Any]])"rurrvMutableMapping[str, Any]rwr@rxr7ryrrzz#Optional[Sequence[Union[str, int]]]r{zOptional[ReadConcern]rlzOptional[WriteConcern]rfrrgzOptional[_CollationIn]r|Optional[ClientSession]rOptional[MongoClient]r}rr4rrkzOptional[Mapping[str, Any]]r5rrr)rbytesrr]rr)rrrzUnion[_OpReply, _OpMsg])rjrrr)rrrr]rr)rr]rrrxr7rr)F)rrrr)rrr|rrr)r Optional[str]rrr)r5rr|rrrrr)r5rrr)rrrr)rfloat)rrtrr )rrrrrr])rr))rrrr__doc__rrr rrrr"r&r%rcr4r-PRIMARYr r5rr6rsrrrrmrrrrrrprrrrrrrrrrTrRrPrrsi1.21.:>1.IX1.^a1.f&!(J >&#:@-W+W(W+ W  Wr (6'='=&;@D.204*/,0+/(, %#37 %#W2W2'W2% W2 $ W2  W2>W2,W2.W2$(W2*W2)W2&W2W2W2 1!W2"#W2$ %W2W2r2 2d -$):F $ D d+ d6M d  d* <8)8)8& 8  8; 2'98'! rRrc "Uup#URS5(aq[[S5(d [S5e[R"[R5n[ UR 55 URU5 U$[Rn[R(aUS:wa[RnSn[R"X#U[R5GHnUuppn [R"X[[SS5-U 5n[ UR 55 UR![R"[R$S5 [&R("5n U c UR*n OU S::a[R,"S 5eUR/U 5 UR![R0[R2S 5 [5U5 URU 5 Us $ UbUe[S 5e![a UR5 ef=f![a [R"XU 5nGN?f=f![anUnUR5 SnAGMSnAff=f) 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_CLOEXECrrjrTzgetaddrinfo failed)endswithrxrqrrrQfilenoconnectr^rAF_INEThas_ipv6 AF_UNSPEC getaddrinfo SOCK_STREAMryr|r{ TCP_NODELAYrrrrr SOL_SOCKET SO_KEEPALIVErv)rrrrrsfamilyerrresafsocktypeprotodummysares rP_create_connectionrsJD }}Wvy))#$ST T}}V^^,' 6  LL K^^F 4;.!! C!!$ff6H6HI),&eB 6==PQ0R%RTYZD ( 6  OOF..0B0BA Foo'G!11Ann[11 OOG $ OOF--v/B/BD I  & LL K3J<  *++c  JJL  & 6==u5D 6& C JJLL s79H:)H>=C I&H;>!I#"I#& J0J  Jc Z[X5nURnUcURUR5 U$USn[(a[ (aUR X$S9nO[US5(aURX$S9nO[R"5nURS[R"UR X$S95nOs[ (aUR U5nOV[US5(aURU5nO3[R"5nURSUR U5nUR((aFUR*(d5UR,(d$[.R0"WR35US9 WRUR5 U$![a UR5 e[ ["4a0nUR5 [%U5n['XSUS9 SnANSnAff=f![a WR5 ef=f)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_hostname a_wrap_socketzSSL handshake failed: r)hostname)r _ssl_contextrrr1_IS_SYNC wrap_socketrxrasyncioget_running_looprun_in_executor functoolspartialr rr^r2rr verify_modecheck_hostnametls_allow_invalid_hostnamessslmatch_hostname getpeercert) rrrs ssl_contextrssl_sockloopexcrs rP_configured_socketrWs g /D&&K ../ 1:D#c 7x&2242N;88*888TH"335D#33!))+*A*A4^ H x&2248;88*88>H"335D#33D+:Q:QSWXH **33    x335 E  ../ O1    X c 'w/!'0HZab c!  NN   sB%F1$ F1AF1 F1'"F1 2F11#H1*H &HH H*c\rSrSrSrSrg)_PoolClosedErrorizRInternal error raised when a thread tries to get a connection from a closed pool. rTN)rrrrrrrTrRrPrrsrRrcF\rSrSrS SjrS SjrS SjrS SjrS SjrSr g)_PoolGenerationicP[R"[5UlSUlgr]) collections defaultdictr] _generations _generationrs rPr_PoolGeneration.__init__s1<1H1H1MrRc>Uc UR$URU$)z,Get the generation for the given service_id.rrrrs rPrQ_PoolGeneration.gets%  ## #  ,,rRcUR$)z"Get the Pool's overall generation.)rrs rPr_PoolGeneration.get_overallsrRcU=RS- slUc+URHnURU==S- ss'M gURU==S- ss'g)z2Increment the generation for the given service_id.rjNr r!s rPinc_PoolGeneration.incsW A  "// !!*-2-0   j )Q . )rRc(XRU5:g$)z?Return if the given generation for a given service_id is stale.)rQrrrs rPstale_PoolGeneration.staleshhz***rRr Nr)rOptional[ObjectId]rr]r)rr,rrrr]rr,rr) rrrrrrQrr&r*rrTrRrPrrs -  /+rRrc \rSrSrSrSrSrSrg) PoolStateirjrTN)rrrrPAUSEDREADYCLOSEDrrTrRrPr/r/s F E FrRr/cR\rSrSrSSSjjrSSjr\SSj5rSSSjjrSSjr SSSjjr SS jr SS jr SS jr S S jrS!S"S jjr\R"S!S#Sjj5rS$SjrS!S%SjjrS&SjrS'SjrS(SjrSSjrSrg))riNcUR(a[RUlO[RUlSUl[ R"5Ul[5Ul [5n[U5Ul SUlSUlSUl[#5Ul[&R("5UlXlX lX0lUR0=(a? UR.R2SL=(a UR.R2R4UlUR0Ul:"U5UlSUlUR.R@Ul UR@(d[CS5Ul [8R:"U5Ul"UR.RFUl$SUl%X@l&UR4(a]UR.R2ceUR.R2ROUR,UR.RP5 UR6(a[RRT"[VRX5(a[[[[R4URL[\R^UR,SUR,SS.UR.RPD6 SUl0[5Ul1SUl2SUl3g)z :param address: a (hostname, port) tuple :param options: a PoolOptions instance :param handshake: whether to call hello for each new Connection rjrNinfrrrr)4 pause_enabledr/r2stater3_check_interval_secondsrdequeconnssetactive_contextsr#r$lockactive_socketsnext_connection_idrrrosgetpidpidrr handshakerrr threading Condition size_condrequests max_pool_sizer_max_connecting_condmax_connecting_max_connecting_pendingrpublish_pool_creatednon_default_optionsr%rrrr'r& POOL_CREATEDoperation_count_Pool__pinned_socketsncursorsntxns)rrrrF client_id_locks rPr Pool.__init__s8  "))DJ"DJ()$)4(9(9(; :=%%L "#+/ #$99;  " NN < **$6 < **;;  $(>> #,,U3 !YY44!!!&uD %.$7$7$>!#yy77 #  99--9 99 II & & ; ; dii;;   # #(:(G(G (V(V " 0==<<?<<?   ))//  %&25  rRc bUR UR[R:wa[RUlUR(aHUR R ceUR R RUR5 UR(al[R"[R5(aC[[UR[ R"URSURSS9 SSS5 g!,(df  g=f)Nrrjr8)r@r:r/r3rrrpublish_pool_readyrrr%rrrr'rr& POOL_READYrs rPr Pool.readys YYzzY__,&__ ((9955AAAII..AA$,,O++0B0O0OPWP]P]0^0^*!% 8 C C#'<<?#'<<? YYs D D  D.c<UR[R:H$rZ)r:r/r4rs rPr Pool.closed.szzY----rRc URnUR UR(a SSS5 gURR(aCU(a<URR (d!UR[ RsoPlURRU5 [R"5nURU:waX`l SUl SUlUc'UR[ R""5soplOy[ R""5n[ R""5n URH7n U R$U:XaUR'U 5 M&U R'U 5 M9 UnXlU(a[ R(UlUR*R-5 URR-5 U(a#UR.Hn U R15 M SSS5 URR2n U(aWH"n U R5[6R85 M$ UR:(a U ceU R=UR>5 UR@(an[BRD"[FRH5(aD[K[BURL[NR8UR>SUR>SS9 gggU[ R:waUR:(a U ceU RQUR>UUS9 UR@(am[BRD"[FRH5(aD[K[BURL[NRRUR>SUR>SUS9 WH"n U R5[6RT5 M$ g!,(df  GN=f)Nrrjr8)rinterrupt_connections)rrrr serviceId)+r:rIrrr9rr/r2rr&rCrDrErArSr=rr<rappendr4rL notify_allr?rrrr* POOL_CLOSEDrpublish_pool_closedrrr%rrrr'rr&publish_pool_cleared POOL_CLEAREDr) rrpauserra old_statenewpidsocketsdiscardkeeprcontextrs rP_reset Pool._reset2sJJ ^^{{^yy&&59P9P(, I4D4D% : HHLL $YY[Fxx6!!&'#'($!&*jj+2C2C2E#-8->->-@*5*;*;*= JJD*4t, D) ' "! &--  % % 0 0 2 NN % % '$#33GNN$ 4?DII..   6 B BC $$ ,,,--dll;'',>,K,KGMM,Z,Z&!__4@@#||A#||A -['I,,,(($00022 #-.C3 ++0B0O0OPWP]P]0^0^*!% 8 E E#'<<?#'<<?",   6 < <= M^sO.GO.. O=cXlUR URHnURUR5 M SSS5 g!,(df  g=f)zHUpdates the is_writable attribute on all sockets currently in the Pool. N)rr@r=r)rr_sockets rPrPool.update_is_writables=' YY::**4+;+;<&YYs /A  Ac$URSXS9 g)NF)rrrarp)rrras rPreset Pool.resets %J drRc$URSSS9 g)NF)rrirvrs rPreset_without_pausePool.reset_without_pauses %u -rRc"URSS9 g)NT)rrvrs rPr Pool.closes $ rRc8URRX5$rZ)rr*r)s rPstale_generationPool.stale_generationsxx~~c..rRc UR UR[R:wa SSS5 gSSS5 URR bUR UR (aUR SR5URR :aUR R5nUR[R5 UR (a7UR SR5URR :aMSSS5 UR [UR 5UR-URR:a SSS5 gUR URR:a SSS5 gU=R S- slSSS5 SnUR" UR$UR&:aSSS5 U(aDUR" U=R$S-slUR"R)5 SSS5 UR U=R S-slURR)5 SSS5 gU=R$S- slSnSSS5 UR+5nUR UR,R/5U:waUR[R05 SSS5 U(aDUR" U=R$S-slUR"R)5 SSS5 UR U=R S-slURR)5 SSS5 gUR R3U5 UR4R7UR85 SSS5 U(aDUR" U=R$S-slUR"R)5 SSS5 UR U=R S-slURR)5 SSS5 GMK!,(df  GNN=f!,(df  GNm=f!,(df  GN=f!,(df  GNv=f!,(df  g=f!,(df  GN5=f!,(df  GN=f!,(df  g=f!,(df  GN/=f!,(df  N=f!,(df  N=f!U(aVUR" U=R$S-slUR"R)5 SSS5 O!,(df  O=fUR U=R S-slURR)5 SSS5 f!,(df  f=f=f)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. NrTrjF)r@r:r/r3rmax_idle_time_secondsr=rpoprr*IDLErIlenrA min_pool_sizerJrLrOrNnotifyrrrr appendleftr?rmr)rreference_generationr incrementeds rPremove_stale_socketsPool.remove_stale_socketssYYzzY__,Y, 99 * * 6JJ 288:TYY=\=\\::>>+DOO$:$?$?@ JJ 288:TYY=\=\\tzz?T%8%88DII(D(DE 22 * 1188:3^^MMQ&MNN))+$^JJ))$/((001D1DE22 * 1188:3^^MMQ&MNN))+$CY  832$^//.&32$^Y32$^ 22 * 1188:322^^MMQ&MNN))+$^^s Q>"CR? R  R" R14 S S S&!U) S8; T  TU T,/ T=W40V  W4 V W4*0W# W4# W1 -W4c UR URnU=RS- slSSS5 URRnUR(a!UceUR UR W5 UR(am[R"[R5(aD[[UR[RUR SUR SWS9 [!UR UR5n[;X@UR W5nUR UR<R?UR@5 SSS5 URB(a!URE5 URFUl#U(aURIUSS9 URK5 U$!,(df  GN=f!["Ga5nUR(a0UceUR%UR W[&R(5 UR(a[R"[R5(ak[[UR[R*UR SUR SW[-[&R(5[&R(S9 [/U[0[2[445(a)[7UR5n[9UR XVS9 eSnAff=f!,(df  GN=f!["a! URM[&R(5 ef=f) zConnect to Mongo and return a new Connection. Can raise ConnectionFailure. Note that the pool does not keep a reference to the socket -- you must call checkin() when you're done with it. rjNrrrrrrrrF)completed_handshake)'r@rBrrrpublish_connection_createdrrr%rrrr'rr& CONN_CREATEDrrtrr*rrr(rrr^r2rrrr?addrrFr&rcontribute_socketrr)rhandlerconn_idrrsrrrs rPr Pool.connectsuYY--G  # #q ( #II..  ( ((  0 0w G  # #(:(G(G (V(V "0==<<?<<?#*   %dllDII>D0$dllG< YY  $ $T%8%8 9 ~~ #'#3#3 ))$E)J      uY( $$ ,,,33LL'+A+G+G'',>,K,KGMM,Z,Z&!__4@@#||A#||A'.;>.tyy9)$,,W + 0Y  OO288 9  s="G > G&L 0AL2 G L(D0LL L/2+Mc #,# URRn[R"5nUR(a UceUR UR 5 UR(al[R"[R5(aC[[UR[RUR SUR SS9 UR!X1S9n[R"5U- nUR(a,UceUR#UR UR$U5 UR(ax[R"[R5(aO[[UR[R&UR SUR SUR$US9 UR( UR*R-UR.5 SSS5 Uv UR2(aFUR( UR@R-U5 U=RBS- sl!SSS5 gUR4(aFUR( UR@R-U5 U=RDS- sl"SSS5 gUR<(aUR?U5 gg!,(df  N=f![0az UR2=(d UR4nU(a)[6R8"5upxn UR;Xx5 U(d"UR<(aUR?U5 ef=f!,(df  g=f!,(df  g=f7f)aGet a connection from the pool. Use with a "with" statement. Returns a :class:`Connection` object wrapping a connected :class:`socket.socket`. This method should always be used in a with-statement:: with pool.get_conn() as connection: connection.send_message(msg) data = connection.receive_message(op_code, request_id) Can raise ConnectionFailure or OperationFailure. :param handler: A _MongoClientErrorHandler. Nrrjr8rr)#rrrrr$publish_connection_check_out_startedrrr%rrrr'rr&CHECKOUT_STARTED _get_connpublish_connection_checked_outrCHECKOUT_SUCCEEDEDr@r?rrrtrrsysexc_infohandlerrrTrVrU) rrrcheckout_started_timerrpinnedexc_typeexc_valrds rPcheckout Pool.checkoutsy&II.. $ 0  ( ((  : :4<< H  # #(:(G(G (V(V "0AA<<?<<?  ~~3~E>>#&;;  ( ((  4 4T\\477H U  # #(:(G(G (V(V "0CC<<?<<?#'77#  $$(()<)<=J ??%%))$/ a   %%))$/ " [[ LL 3  __:(:(:F(+||~$1x1dkk T"  sgGN K+&K< K+N%1M2&N<1N--N K($K++BM//N2 N<N N Nc UR[R:wGaKU(Ga[R"5U- nUR (aXUR RceUR RRUR[RU5 UR(a}[R"[R 5(aT[#[UR$[&R(URSURSS[RUS9 [+UR 5n[-UR[/S5US9 gg)Nrrj>+.CC((9955AAAII..RR &D&O&OQY++0B0O0OPWP]P]0^0^*!% 8 H H#'<<?#'<<?]<GG#+ +4995G % m,DEW^ + )rRc UR[R"5:waUR5 UR(Ga[ R "5U- nUR(aXURRceURRRUR[RU5 UR(a}[R "["R$5(aT['[UR([*R,URSURSS[RUS9 [/S5eUR0 U=R2S- slSSS5 [4R6"5(a[4R8"5nOJURR:(a-[ R "5URR:-nOSnUR< UR?USS9 UR@URB:d[EUR<U5(dEUR@URB:aUR<RG5 URIU5 UR?USS9 UR@URB:dMU=R@S- sl SSS5 SnS nS nUR0 U=RJS- sl%SnSSS5 UGcURL UR?US S9 URN(dURPURR:d[EURLU5(dXURN(dURPURR:aURLRG5 SnURIU5 UR?US S9 URN(dURPURR:dMURNRU5nSSS5 U(aURYU5(aSnGMAOTUR[US 9nURL U=RPS-sl(URLRG5 SSS5 UcGMSUl3U$!,(df  GNA=f!,(df  GN=f!,(df  GN=f![Va U=RPS- sl(Nf=f!,(df  N=f!,(df  N=f!URL U=RPS-sl(URLRG5 SSS5 f!,(df  f=f=f![\Ga U(aUR_[`Rb5 UR< U=R@S-sl U(aU=RJS-sl%UR<RG5 SSS5 O!,(df  O=fU(Gd[ R "5U- nUR(aXURRceURRRUR[RdU5 UR(a}[R "["R$5(aT['[UR([*R,URSURSS [RdUS9 ef=f) z8Get or create a Connection. Can raise ConnectionFailure.NrrjzConnection pool was closedrz?Attempted to check out a connection from closed connection poolT)rFrr)4rErCrDrzrrrrrrrrr)rerr%rrrr'rr&rrr@rSrr get_deadlinewait_queue_timeoutrIrrJrKrr_raise_wait_queue_timeoutrArLr=rOrNpopleft IndexError _perishedrrtrr*rrr)rrrrrrr emitted_events rPrPool._get_connsN 88ryy{ "  $ $ & ;;;~~'*??H$$yy11=== **NNLL"@"L"Lh'',>,K,KGMM,Z,Z&!__4DD#||A#||A78DD' #Q YY  A %      ))+H YY ) )~~'$))*F*FFHH ^^  $ $%:t $ L}}t'9'99!$..(;;}}t'9'99--/223HI(()>4(P}}t'9'99 MMQ M  > ##q(#" ,..,,-Bu,U#zzT]]T=Q=Q-Q)$*C*CXNN $zzT]]T=Q=Q-Q $ 9 9 @ @ B,0M ::;PQ001FSX0Y $zzT]]T=Q=Q-Q+#zz113/ ~~d++# ,?#||G|<!66 MMQ.M 55<<>77,x  yY^"(&+ * +/.076T66 MMQ.M 55<<>766  6 < <= " ''1,'%%'   !>>+.CC((9955AAAII..RR &D&O&OQY++0B0O0OPWP]P]0^0^*!% 8 H H#'<<?#'<<?]<GG#+  9 s,R<B5SS+ V7S V'C*TS2.+VT9) V50T(% V< S  S S/*V2TTTT T%!V( T62V9 V0U?6 V? V VV=]A X% ]% X3 /D ]c URnURnSUlSUlSUlURR U5 UR R nUR URR UR5 SSS5 UR(a+UceURURUR5 UR(aw[R "["R$5(aN['[UR([*R,URSURSURS9 UR.[0R2"5:waUR55 GOUR6(a!UR9[:R<5 GOUR6(aUR(a:UceUR?URUR[:R@5 UR(a[R "["R$5(au['[UR([*RBURSURSUR[E[:R@5[:R@S9 OUR URGURHURJ5(a UR9[:RL5 OiURO5 URQ[SURT55 URVRYU5 URZR]5 SSS5 UR^ U(aU=R`S-sl0OU(aU=RbS-sl1U=RdS-sl2U=RfS-sl3U=RhS-sl4UR^R]5 SSS5 g!,(df  GN=f!,(df  N=f!,(df  g=f)zvReturn the connection to the pool, or if it's closed discard it. :param conn: The connection to check into the pool. FNrrjrr)5rrrrTrmrrr@r?rrpublish_connection_checked_inrrrr%rrrr'rr& CHECKEDINrErCrDrzrrr*rerrrr(rrrrrrrrr=rrLrrIrVrUrJrArS)rrtxncursorrs rPr Pool.checkins oo## " %%d+II.. YY  ( ()<)< =  ( ((  3 3DLL$'' J  # #(:(G(G (V(V "0::<<?<<?#'77   88ryy{ "  $ $ &{{ 6 B BC(($00077 dgg/E/K/K++0B0O0OPWP]P]0^0^*!% 8 D D#'<<?#'<<?+/77?@V@\@\]4:: YY,,T__dooNN(>(D(DE557//T5E5E0FG --d31188:^^ a  " MMQ M   1 $   A % NN ! ! #^eYLY^s&+&QB5Q%BQ$ Q Q!$ Q2cUR5nURRb9X RR:a UR[R 5 gUR bTUR S:XdX R :a5UR5(a UR[R5 gURURUR5(a UR[R5 gg)aYReturn 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*rr;rrrrrr)rrrs rPrPool._perishedEs!224 II + + 7!II$C$CC OO277 8  ' ' 3  ( (A -1BEaEa1a!! 6 < <=  $// B B OO288 9rRc URRn[R"5U- nUR(a0UceUR UR [RU5 UR(a}[R"[R5(aT[[UR[ R"UR SUR SS[RUS9 [$R&"5=(d URR(nURR*(alUR,UR.- UR0- n[3SR5URR6UR.UR0UU55e[3SURR6SU35e)NrrjzBWait queue timeout elapsed without a connection becoming availablerzTimeout waiting for connection from the connection pool. maxPoolSize: {}, connections in use by cursors: {}, connections in use by transactions: {}, connections in use by other operations: {}, timeout: {}zMTimed out while checking out a connection from connection pool. maxPoolSize: z , timeout: )rrrrrrrr)TIMEOUTrr%rrrr'rr&rrrrrrArUrVrrrK)rrrrr other_opss rPrPool._raise_wait_queue_timeoutispII.. >>#&;;  ( ((  9 9 <DDh   # #(:(G(G (V(V "0@@<<?<<?[4<<# ##%E)E)E 99 " "++dmm;djjHI'78>vII++MMJJ 8  $  II334Ky J  rRcLURHnURS5 M grZ)r=r)rrs rP__del__ Pool.__del__sJJD OOD !rR)__pinned_socketsr;rrNrLrOr?rArr=rrrrFrr@rKrUrBrVrSrrErJrIr:)TN)rrFrr,rFrrWr,rr)TNF) rrrirrr,rarrr)rzOptional[bool]rrr)rr,rarrrr-)rr]rrrZ)r"Optional[_MongoClientErrorHandler]rr)rrrzGenerator[Connection, None])rrrrrr)rrrrrr)rrrr)rrrr)rrrr )rrrrrrrrrprrwrzrrrr contextlibcontextmanagerrrrrrrrrrTrRrPrrs\ (, TTT T & Tl".. )-&+ O>O>O>' O> $ O>  O>b=TYe,eLPe e . /7,rBH<@K9K $KKZ6[_|%*|5W| ||F$P"H% N"rRr)rNr]rr)rs socket.socketr}rr~r]rr)rsrrr)NN) rrrrrrrOptional[dict[str, float]]rr )rzthreading.Conditionrrrr)rr,rzdict[str, float])rrrr)rrFrr,rr)rrFrr,rr) __future__rrrrrrrCrqr rrGrrtypingrrrrrr r r r bsonr pymongorrpymongo.commonrrrrrpymongo.errorsrrrrrrrrrrrr pymongo.hellor!r" pymongo.lockr#r$pymongo.loggerr%r&r'r(pymongo.monitoringr)r*pymongo.network_layerr+pymongo.pool_optionsr,pymongo.read_preferencesr-pymongo.server_apir.pymongo.server_typer/pymongo.socket_checkerr0pymongo.ssl_supportr1r2"pymongo.synchronous.client_sessionr3pymongo.synchronous.helpersr4pymongo.synchronous.networkr5r6r7 bson.objectidr8pymongo.compression_supportr9r:r;pymongo.messager<r=pymongo.pyopenssl_contextr>pymongo.read_concernr?r@pymongo.synchronous.authrArB pymongo.synchronous.mongo_clientrCrDpymongo.typingsrErFrGpymongo.write_concernrHrLrIrJrKrQ ImportErrorrrmrorplatform_winregr[reOpenKeyHKEY_LOCAL_MACHINEr`rlrnr^rvrrrrrrrrrrrr/rrTrRrPrsT#     ')    -, *,3.+01N6@!& 12045@VCC2 E99/ <<7  ( ^^  % %'\ #)##H '-c3F'M $  M ?!%26 , , ,,0 ,  ,:#    M M `D,N?D| ++>O "O "kEE E"   ( '#' (sTH(/H97II )I( H65H69 II III I'&I'