+
    8i
                      a  0 t $ R t^ RIHt ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIH	t	 ^ RI
HtHtHt ^ RIt]! ]R4      t]P$                  ! 4       tR]R&   ]! R4      t]P,                  R8  d   ]P.                  t]P0                  tM,]P2                  P.                  t]P2                  P0                  tR	 R
 ltR R ltRR R lltRR R lltR R ltR R ltR R lt R# )z@Internal helpers for lock and condition coordination primitives.)annotationsN)wait_for)AnyOptionalTypeVarregister_at_forkzweakref.WeakSet[threading.Lock]_forkable_locks_Tc                   V ^8  d   QhRR/# )   returnthreading.Lock )formats   "J/var/www/html/photoedit/myenv/lib/python3.14/site-packages/pymongo/lock.py__annotate__r   .   s      n     c                 r    \         P                  ! 4       p \        '       d   \        P	                  V 4       V # )zhRepresents a lock that is tracked upon instantiation using a WeakSet and
reset by pymongo upon forking.
)	threadingLock_HAS_REGISTER_AT_FORKr   addlocks    r   _create_lockr   .   s)     >>DD!Kr   c                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r   8   s      D r   c                     \        4       # )zRepresents an asyncio.Lock.)r   r   r   r   _async_create_lockr   8   s	    6Mr   c               $    V ^8  d   QhRRRRRR/# )r   r   r   condition_classOptional[Any]r   threading.Conditionr   )r   s   "r   r   r   =   s$     % %
%+8%%r   c                N    V'       d	   V! V 4      # \         P                  ! V 4      # )z!Represents a threading.Condition.)r   	Conditionr   r   s   &&r   _create_conditionr%   =   s#     t$$t$$r   c               $    V ^8  d   QhRRRRRR/# )r   r   r   r   r    r   r#   r   )r   s   "r   r   r   F   s"      $  R[ r   c                8    V'       d	   V! V 4      # \        V 4      # )z Represents an asyncio.Condition.)r#   r$   s   &&r   _async_create_conditionr(   F   s    t$$T?r   c                   V ^8  d   QhRR/# )r   r   Noner   )r   s   "r   r   r   M   s       r   c                 p    \          F+  p V P                  4       '       g   K  V P                  4        K-  	  R # N)r   lockedreleaser   s    r   _release_locksr/   M   s     ;;==LLN  r   c               $    V ^8  d   QhRRRRRR/# )r   	conditionr#   timeoutOptional[float]r   boolr   )r   s   "r   r   r   T   s!      i / d r   c                   "    \        V P                  4       V4      G R j  xL
 #  L  \        P                   d     R# i ; i5i)NF)r   waitasyncioTimeoutErrorr1   r2   s   &&r   _async_cond_waitr:   T   s;     inn.8888 s0   A( &( A( AA AAc               $    V ^8  d   QhRRRRRR/# )r   r1   r!   r2   r3   r   r4   r   )r   s   "r   r   r   [   s"     # #- # #D #r   c                $    V P                  V4      # r,   )r6   r9   s   &&r   
_cond_waitr=   [   s    >>'""r   )      r,   )!__conditional_annotations____doc__
__future__r   r7   ossysr   weakrefr   typingr   r   r   pymongo._asyncio_lockpymongohasattrr   WeakSetr   __annotations__r	   version_infor   r#   _asyncio_lockr   r   r%   r(   r/   r:   r=   )r@   s   @r   <module>rN      s    G "  	 
    ) ) $67  4;??3D0 DT] w<<D!!I  %%D%%//I
%#r   