
    &g                    
   S r SSKJr  SSKrSSKrSSKrSSKrSSKJrJ	r	J
r
Jr  SSKJr  SSKJr  Sr\
" S\	S	\4   S
9rSS jr        SS jr\R(                  S:  a  \R*                  r\R,                  rgSS jrSS jrg)z2Miscellaneous pieces that need to be synchronized.    )annotationsN)AnyCallableTypeVarcast)OperationFailure)_REAUTHENTICATION_REQUIRED_CODEFF.)boundc                4   ^  SU 4S jjn[        [        U5      $ )Nc                   >#    UR                  SS5      nSSKJn  SSKJn   T" U 0 UD6I S h  vN $  N! [
         a  nU(       a  e UR                  [        :X  ak  S nU  H5  n[        Xs5      (       a  Un  O"[        Xt5      (       d  M)  UR                  n  O   U(       a  UR                  SS9I S h  vN    Oe T" U 0 UD6s S nA$ e S nAff = f7f)N	no_reauthFr   )AsyncConnection)_BulkWriteContextT)reauthenticate)poppymongo.asynchronous.poolr   pymongo.messager   r   coder	   
isinstanceconnauthenticate)	argskwargsr   r   r   excr   argfuncs	           aC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\pymongo/asynchronous/helpers.pyinner_handle_reauth.<locals>.inner)   s     JJ{E2	=5	t.v.... 	xx:: C!#77"!#99"xx   ++4+@@@T,V,,)	sU   C5 35 C5 
CAC)C1B42C CCCCC)r   r   r   r   returnr   )r   r
   )r   r   s   ` r   _handle_reauthr"   (   s    : 5>    c                   #    [         (       d0  [        R                  " 5       nUR                  " X40 UD6I S h  vN $ [        R                  " X40 UD6$  N7f)N)_IS_SYNCasyncioget_running_loopgetaddrinfosocket)hostportr   loops       r   _getaddrinfor-   I   sN      8'')%%d;F;;;!!$777 <s   7AAA)   
   c                >   #    U R                  5       I Sh  vN $  N7f)iCompatibility function until we drop 3.9 support: https://docs.python.org/3/library/functions.html#anext.N)	__anext__clss    r   anextr5   `   s     ]]_$$$s   c                "    U R                  5       $ )r1   )	__aiter__r3   s    r   aiterr8   d   s    }}r#   )r   r
   r!   r
   )r*   r   r+   r   r   r   r!   zklist[tuple[socket.AddressFamily, socket.SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int]]])r4   r   r!   r   )__doc__
__future__r   r&   builtinsr)   systypingr   r   r   r   pymongo.errorsr   pymongo.helpers_sharedr	   r%   r
   r"   r-   version_infor5   r8    r#   r   <module>rB      s    9 "    
  C CxS)*B8
88$'88$ wNNENNE%r#   