+ 8i.vRt^RIHt^RIt^RIt^RIHtHtHtH t H t H t H t H t ^RIHt^RIHtHtHt^RIHt^RIHtHt^RIHtHtHt^R IHt^R IH t ^R I!H"t"H#t#]'dG^R IH$t$^R IH%t%H&t&H't'^RIH(t(^RI)H*t*^RI+H,t,^RI-H.t.^RI/H0t0^RI1H2t2^RI3H4t4H5t5H6t6H7t7^RI8H9t9Rt:RRRllt;R#)z&Internal network layer helper methods.) annotationsN) TYPE_CHECKINGAnyMappingMutableMappingOptionalSequenceUnioncast)_decode_all_selective)_csothelpers_sharedmessage)_NO_COMPRESSION)NotPrimaryErrorOperationFailure)_COMMAND_LOGGER_CommandStatusMessage _debug_log)_OpMsg)_is_speculative_authenticate)receive_messagesendall) CodecOptions) SnappyContext ZlibContext ZstdContext)_EventListeners) ReadConcern) _ServerMode) ClientSession) MongoClient) Connection)_Address _CollationIn _DocumentOut _DocumentType) WriteConcernTc.tV^8dQhRRRRRRRRR R R R R RRRRRRRRRRRRRRRRRRRRR R!RR"RR#R$R%RR&R'R(R)/#)*connr"dbnamestrspeczMutableMapping[str, Any] is_mongosboolread_preferencezOptional[_ServerMode] codec_optionszCodecOptions[_DocumentType]sessionzOptional[ClientSession]clientzOptional[MongoClient[Any]]checkallowable_errorsz#Optional[Sequence[Union[str, int]]]addresszOptional[_Address] listenerszOptional[_EventListeners] max_bson_sizez Optional[int] read_concernzOptional[ReadConcern]parse_write_concern_error collationzOptional[_CollationIn]compression_ctxz4Union[SnappyContext, ZlibContext, ZstdContext, None] use_op_msgunacknowledged user_fieldszOptional[Mapping[str, Any]]exhaust_allowed write_concernzOptional[WriteConcern]returnr&)formats"Y/var/www/html/photoedit/myenv/lib/python3.14/site-packages/pymongo/synchronous/network.py __annotate__rF=smm m m #m m + m / m%m 'm m:m m)m!m(m $m &!m"J#m$%m&'m(-)m*+m,*-m./mcD\\V44pVR,pRpTpV'd%V'gVfQh\P!W$4pV 'dUV'dVP'g;V P 'dV P VR&V'dVPW 4VeWR&V RJ;'d V Pp\PP4pV'd \VV4pV'dVP4\9dRpV'dMVP'd;VPP'gVPP!WV4;ppV'dVP#Wr4\$P&!VV4V'dV'd\(P*M^pTV'd\(P,M^,p\P.!VW!WEVR7wpppp V'd$V e V V 8d\P0!VVV 4M!\P2!^V^RVRVV4wpppV eJVV \P4,8d.\P0!VVV \P4,4Ve\6P8!\:P<4'd\?\6\@PBVPDPFV\\V44VVVVPHVPJVPL^,VPL^,VPNR7 V'd8V fQhV fQhV PQVVVV VPJVPNR7\SVPTPVV4V'dV'dRp!R ^/p"M\YVV4p!V!PZVn-V!P]VVR 7p#V#^,p"VP^'g!V"PaR 4p$V$'dV$Vn1V'dVPeV"V4V'd%\fPh!V"VPjV VR 7\PP4V, p&Ve\6P8!\:P<4'd\?\6\@P|VPDPFV&V"\\V44VVVVPHVPJVPL^,VPL^,VPNRV9R7V'd;V fQhV fQhV PV&V"VVV VPJVPNVVR7 V'dbVP'dPV!'dHVPPV!P44p(\R\V(VV4^,4p"V"# \lEdzp%\PP4T, p&\oT%\p\r34'dT%Ptp'M\Pv!T%4p'Te\6P8!\:P<4'd\?\6\@PxTPDPFT&T'\\T44TTTTPHTPJTPL^,TPL^,TPN\oT%\r4R 7T'd:T fQhT fQhT P{T&T'TTT TPJTPNTR7hRp%?%ii;i)aqExecute a command over the socket, or raise socket.error. :param conn: a Connection instance :param dbname: name of the database on which to run the command :param spec: a command document as an ordered dict type, eg SON. :param is_mongos: are we connected to a mongos? :param read_preference: a read preference :param codec_options: a CodecOptions instance :param session: optional ClientSession instance. :param client: optional MongoClient instance for updating $clusterTime. :param check: raise OperationFailure if there are errors :param allowable_errors: errors to ignore if `check` is True :param address: the (host, port) of `conn` :param listeners: An instance of :class:`~pymongo.monitoring.EventListeners` :param max_bson_size: The maximum encoded bson size for this server :param read_concern: The read 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 compression_ctx: optional compression Context. :param use_op_msg: True if we should use OP_MSG. :param unacknowledged: True if this is an unacknowledged command. :param user_fields: Response fields that should be decoded using the TypeDecoders from codec_options, passed to bson._decode_all_selective. :param exhaust_allowed: True if we should enable OP_MSG exhaustAllowed. z.$cmdFN readConcernr;)ctx) rclientIdcommand commandName databaseName requestId operationIddriverConnectionIdserverConnectionId serverHost serverPort serviceId) service_idok)r1r?z $clusterTime)r:)rrK durationMSfailurerMrNrOrPrQrRrSrTrUisServerSideError)rV database_namespeculativeAuthenticate)rrKrXreplyrMrNrOrPrQrRrSrTrUspeculative_authenticate)rVspeculative_hellor[r%)Dnextiterr_maybe_add_read_preferencein_transactionleveldocument_update_read_concernenabled_for_commandsdatetimenowrlowerr _encrypter_bypass_auto_encryptionencrypt apply_timeoutr apply_write_concernr MORE_TO_COMEEXHAUST_ALLOWED_op_msg_raise_document_too_large_query_COMMAND_OVERHEADr isEnabledForloggingDEBUGrrSTARTED_topology_settings _topology_ididserver_connection_idr6rVpublish_command_startrr*get_connr more_to_comeunpack_responsereadyget _cluster_time_process_responser _check_command_responsemax_wire_version Exception isinstancerrdetails_convert_exceptionFAILEDpublish_command_failure SUCCEEDEDpublish_command_successdecryptraw_command_responser r ))r*r+r-r.r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rAnamensr_origpublishstartflags request_idmsgsize max_doc_sizer] response_doc unpacked_docs cluster_timeexcdurationrY decrypteds)&&&&&&&&&&&&&&&&&&&&&& rErLrL=s;f T D ' B D***11$HW)?)?)?    "."7"7D    ( ( 4%[t#FF (F(FG    ! ! #E8tD4:: ? ?$'KKG005G  ++GMM::#188#66CC'# $T$Z 0!'( *'+ww'+'@'@#||A#||A"oo&06F&G" ( ((& &&  - -))??$ .  M&sE/X XA#X8XX!$X ^&B^8B'^ :^^)TNNNNNFNNFFNFN)<__doc__ __future__rrirxtypingrrrrrrr r bsonr pymongor r rpymongo.compression_supportrpymongo.errorsrrpymongo.loggerrrrpymongo.messagerpymongo.monitoringrpymongo.network_layerrrrrrrrpymongo.read_concernrpymongo.read_preferencesr"pymongo.synchronous.client_sessionr pymongo.synchronous.mongo_clientr!pymongo.synchronous.poolr"pymongo.typingsr#r$r%r&pymongo.write_concernr'_IS_SYNCrLrCrGrErs-"   '227NM"; !SS204@<3SS2 mmrG