o 'h @sUdZddlmZddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z ddl ZeedZeZded<e d Zejd krNejZejZnejjZejjZd&d dZd'ddZ d(d)ddZd(d*ddZd+ddZd,d"d#Zd-d$d%ZdS).z@Internal helpers for lock and condition coordination primitives.) annotationsN)wait_for)AnyOptionalTypeVarregister_at_forkzweakref.WeakSet[threading.Lock]_forkable_locks_T) returnthreading.LockcCst}tr t||S)zpRepresents a lock that is tracked upon instantiation using a WeakSet and reset by pymongo upon forking. ) threadingLock_HAS_REGISTER_AT_FORKraddlockrH/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/lock.py _create_lock.s rrcCstS)zRepresents an asyncio.Lock.)rrrrr_async_create_lock8srrcondition_class Optional[Any]threading.ConditioncCs|r||St|S)z!Represents a threading.Condition.)r Conditionrrrrr_create_condition=s rrcCs|r||St|S)z Represents an asyncio.Condition.)rrrrr_async_create_conditionFsrNonecCstD] }|r |qdSN)rlockedreleaserrrr_release_locksMs r# conditiontimeoutOptional[float]boolcs0z t||IdHWStjyYdSw)NF)rwaitasyncio TimeoutErrorr$r%rrr_async_cond_waitTs r,cCs ||Sr )r(r+rrr _cond_wait[s r-)r r )r rr )rr rrr r)rrrrr r)r r)r$rr%r&r r')r$rr%r&r r') __doc__ __future__rr)ossysrweakrefrtypingrrrpymongo._asyncio_lockpymongohasattrrWeakSetr__annotations__r version_inforr _asyncio_lockrrrrr#r,r-rrrrs4