o 'h O@s\dZddlmZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z m Z ddlmZddlmZddlmZmZmZmZddlmZmZmZdd lmZdd lmZmZm Z eefZ!e rndd l"m#Z#dd l$m%Z%zdd l&m'Z'm(Z(m)Z)m&Z&dOddZ*Wne+ydOddZ*YnwdZ,dZ-dZ.ej/dkrzddl0Z1Wn e+yddl1Z1YnwddZ2z%e13e1j4dZ5e2e5ddZ6e2e5ddZ7Wdn1swYWn e8ydZ6dZ7Ynwd d!Z9n dPd'd(Z:dQd)d!Z9  dRdSd3d4Z;dTd8d9Zd>Z>dVd@dAZ?dWdCdDZ@dXdFdGZAdVdHdIZBdWdJdKZCdYdMdNZDdS)Zz)Pool utilities and shared helper methods.) annotationsN) TYPE_CHECKINGAnyNoReturnOptionalUnion)_csot) _getaddrinfo) AutoReconnectConnectionFailureNetworkTimeout_CertificateError)AsyncNetworkingInterfaceNetworkingInterfacePyMongoProtocol) PoolOptions) PYSSLErrorSSLError_has_sni)_sslConn)_Address)F_GETFDF_SETFD FD_CLOEXECfcntlfdintreturnNonecCst|t}t|t|tBdS)z8Set the close-on-exec flag on the given file descriptor.N)rrrr)rflagsr O/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/pool_shared.py_set_non_inheritable_non_atomic3s r"cCsdS)z6Dummy function for platforms that don't provide fcntl.Nr )rr r r!r"<sx win32c Cs6z t||\}}t|WSttfy|YSwN)winreg QueryValueExrOSError ValueError)keynamedefaultvalue_r r r!_queryJs  r1z2SYSTEM\CurrentControlSet\Services\Tcpip\Parameters KeepAliveTimeimKeepAliveIntervalcCsHtttd}tttd}|tks|tkr"|tjd||fdSdS)Nr4)min_WINDOWS_TCP_IDLE_MS_MAX_TCP_KEEPIDLE_WINDOWS_TCP_INTERVAL_MS_MAX_TCP_KEEPINTVLioctlsocketSIO_KEEPALIVE_VALS)sockidle_ms interval_msr r r!_set_keepalive_times`s rAr> socket.socket tcp_optionstr max_valuecCs`tt|r.tt|}z|tj|}||kr!|tj||WdSWdSty-YdSwdSr')hasattrr<getattr getsockopt IPPROTO_TCP setsockoptr*)r>rCrEsockoptr.r r r!_set_tcp_optionhs   rLcCs(t|dtt|dtt|dtdS)N TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNT)rLr8r:_MAX_TCP_KEEPCNTr>r r r!rAus  addressrerror Exception msg_prefix Optional[str]timeout_detailsOptional[dict[str, float]]rcCs|\}}|durd|||f}n|d|}|r||}d|vr'|t|7}t|tjr2t||t|trBdt|vrBt||t||)z9Convert a socket.error to ConnectionFailure and raise it.Nz %s:%d: %s: zconfigured timeouts timed out)format_timeout_details isinstancer<timeoutr SSLErrorsrDr )rRrSrUrWhostportmsgr r r!_raise_connection_failure{s     rboptionsrdict[str, float]cCsPi}t}|j}|j}|r|d|d<|r|s|d|d<|r&|d|d<|S)Nr4 timeoutMSsocketTimeoutMSconnectTimeoutMS)r get_timeoutsocket_timeoutconnect_timeout)rcdetailsr]rirjr r r!_get_timeout_detailss   rlrkcCsTd}|r(|d7}dD]}||vr|d|d||d7}q |dd}|d7}|S) Nz (configured timeouts:)rfrerg rYzms,)r )rkresultr]r r r!r[s r[c@s.eZdZd ddZd ddZed dd Zd S) _CancellationContextrrcCs d|_dS)NF _cancelledselfr r r!__init__s z_CancellationContext.__init__cCs d|_dS)zCancel this context.TNrsrur r r!cancels z_CancellationContext.cancelboolcCs|jS)zWas cancel called?rsrur r r! cancelledsz_CancellationContext.cancelledN)rr)rry)__name__ __module__ __qualname__rwrxpropertyrzr r r r!rrs   rrrc s|\}}|dr4ttdstdttj}t|z|||WSty3| wtj }tj rA|dkrAtj }d}t |||tjdIdHD]}|\}} } } } zt|| ttddB| }Wntywt|| | }Ynwt|z:|tjtjd t} | dur|j} n | dkrtd || |tjtjd t||| |WSty}z |}| WYd}~qOd}~ww|dur|td  zGiven (host, port) and PoolOptions, connect and return a raw 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)familytype SOCK_CLOEXECrr5rZTzgetaddrinfo failed)endswithrFr<r rr"filenoconnectr*closeAF_INEThas_ipv6 AF_UNSPECr SOCK_STREAMrGrJrI TCP_NODELAYr remainingrjr] settimeout SOL_SOCKET SO_KEEPALIVErArRrcr_r`r>rerrresafsocktypeprotodummysar]er r r!_async_create_connections\            rUnion[socket.socket, _sslConn]c sBt||IdH}|j}|dur||j|S|d}z*tdr6t}|dtj |j ||dIdH}nt}|d|j |IdH}Wn1t yR| t gtRyw}z| t|}t||d|dWYd}~nd}~ww|jr|js|jsz tj||dWn t y| w||j|S)Given (host, port) and PoolOptions, return a raw configured socket. Can raise socket.error, ConnectionFailure, or _CertificateError. Sets socket's SSL and timeout options. NrFserver_hostnameSSL handshake failed: rWhostname)r _ssl_contextrrirasyncioget_running_looprun_in_executor functoolspartial wrap_socketr rr*r^rlrb verify_modecheck_hostnametls_allow_invalid_hostnamessslmatch_hostname getpeercert) rRrcr> ssl_contextr_loopssl_sockexcrkr r r!_async_configured_socketsP      rrc s"t||IdH}|j}|j|dur%ttjfdd|dIdHS|d}ztjfdd|||dIdH\}}Wn)tyGtgt Ryh}zt |}t ||d|d WYd}~nd}~ww|j r|j s|jsz tj|d |d Wn ty|wt||fS) zGiven (host, port) and PoolOptions, return a configured AsyncNetworkingInterface. Can raise socket.error, ConnectionFailure, or _CertificateError. Sets protocol's SSL and timeout options. Nc tdSNr]rr rr r!O z0_configured_protocol_interface..rQrcrrrr rr r!rXr)r>rrrrpeercertr)rrrirrrcreate_connectionr r*r^rlrbrrrrrget_extra_infoabort) rRrcr>rr_ transportprotocolrrkr rr!_configured_protocol_interface?sL       rc Cs|\}}|dr3ttdstdttj}t|z|||WSty2| wtj }tj r@|dkr@tj }d}tj |||tjdD]}|\}} } } } zt|| ttddB| }Wntytt|| | }Ynwt|z:|tjtjd t} | dur|j} n | dkrtd || |tjtjd t||| |WSty}z |}| WYd}~qLd}~ww|dur|td r)rrFr<r rr"rrr*rrrr getaddrinforrGrJrIrrrrjr]rrrrArr r r!_create_connectionusZ            rc Cs t||}|j}|dur||j|S|d}ztdr%|j||d}n||}Wn1ty7|tgt Ry\}z|t |}t ||d|dWYd}~nd}~ww|j r~|j s~|js~z tj||dWn ty}|w||j|S)rNrTrrrr)rrrrirrr rr*r^rlrbrrrrrrrRrcr>rr_rrrkr r r!_configured_socketsD      rrc Cst||}|j}|dur||jt|S|d}ztdr'|j||d}n||}Wn1ty9|t gt Ry^}z|t |}t ||d|dWYd}~nd}~ww|j r|js|jsz tj||dWn ty|w||jt|S)zGiven (host, port) and PoolOptions, return a NetworkingInterface wrapping a configured socket. Can raise socket.error, ConnectionFailure, or _CertificateError. Sets socket's SSL and timeout options. NrTrrrr)rrrrirrrr rr*r^rlrbrrrrrrrr r r!_configured_socket_interfacesD      r)rrrr)r>rBrCrDrErrr)r>rBrr)NN) rRrrSrTrUrVrWrXrr)rcrrrd)rkrXrrD)rRrrcrrrB)rRrrcrrr)rRrrcrrr)rRrrcrrr)E__doc__ __future__rrrr<rsystypingrrrrrpymongorpymongo.asynchronous.helpersr pymongo.errorsr r r r pymongo.network_layerrrrpymongo.pool_optionsrpymongo.ssl_supportrrrr^pymongo.pyopenssl_contextrpymongo.typingsrrrrrr" ImportErrorr8r:rPplatform_winregr(r1OpenKeyHKEY_LOCAL_MACHINEr,r7r9r*rArLrbrlr[rrrrrrrrr r r r!s|                      G 8 6 G1