"jt(<dZddlmZmZmZddlmZGddZy)z ReadWriteLock Taken from http://code.activestate.com/recipes/502283/ locks.py - Read-Write lock thread lock implementation See the class documentation for more info. Copyright (C) 2007, Heiko Wundram. Released under the BSD-license. ) ConditionLockcurrent_thread)timec4eZdZdZdZdddZdddZdZy) ReadWriteLocka[Read-Write lock class. A read-write lock differs from a standard threading.RLock() by allowing multiple threads to simultaneously hold a read lock, while allowing only a single thread to hold a write lock at the same point of time. When a read lock is requested while a write lock is held, the reader is blocked; when a write lock is requested while another write lock is held or there are read locks, the writer is blocked. Writers are always preferred by this implementation: if there are blocked threads waiting for a write lock, current readers may request more read locks (which they eventually should free, as they starve the waiting writers otherwise), but a new thread requesting a read lock will not be granted one, and block. This might mean starvation for readers if two writer threads interweave their calls to acquire_write() without leaving a window only for readers. In case a current reader requests a write lock, this can and will be satisfied without giving up the read locks first, but, only one thread may perform this kind of lock upgrade, as a deadlock would otherwise occur. After the write lock has been granted, the thread will hold a full write lock, and not be downgraded after the upgrading call to acquire_write() has been match by a corresponding release(). cltt|_d|_d|_g|_i|_y)z Initialize this read-write lock.Nr)rr_ReadWriteLock__condition_ReadWriteLock__writer"_ReadWriteLock__upgradewritercount_ReadWriteLock__pendingwriters_ReadWriteLock__readers)selfs >/srv/dav/.venv/lib/python3.12/site-packages/wsgidav/rw_lock.py__init__zReadWriteLock.__init__2s5 %TV, $%! "N)timeoutc0| t|z}t}|jj |j|ur1|xj dz c_ |jj y |j|js |jrA||jvr{|j|xxdz cc< |jj y|jj|ddz|j|< |jj y|9tz }|dkr td|jj|n|jj#|jj wxYw)afAcquire a read lock for the current thread, waiting at most timeout seconds or doing a non-blocking check in case timeout is <= 0. In case timeout is None, the call to acquire_read blocks until the lock request can be serviced. In case the timeout expires before the lock could be serviced, a RuntimeError is thrown.NrzAcquiring read lock timed out) rrr acquirer _ReadWriteLock__writercountreleaser r rget RuntimeErrorwait)rrendtimeme remainings r acquire_readzReadWriteLock.acquire_readAsg  fw&G     " '}}"""a'"6    $ $ &5==(00D4I4I/ !NN2.!3."    $ $ &.2^^-?-?A-F-Jr*    $ $ && '$& 0I A~*+JKK$$)))4$$))+14    $ $ &s#E94A E9,E9"AE99Fc| t|z}td}}|jj |j|ur1|xj dz c_ |jj y||jvr:|jr tdd}|jj||_n|jj| |js|j|jr@|r||_|jdz|_d|_ |jj y|jd|ur>||_d|_|jdd|_ |jj y|tz }|dkrS|r+|j|j|<d|_td|jj|td|jj|n|jjR#|jj wxYw)aAcquire a write lock for the current thread, waiting at most timeout seconds or doing a non-blocking check in case timeout is <= 0. In case the write lock cannot be serviced due to the deadlock condition mentioned above, a ValueError is raised. In case timeout is None, the call to acquire_write blocks until the lock request can be serviced. In case the timeout expires before the lock could be serviced, a RuntimeError is thrown.NFrz(Inevitable dead lock, denying write lockTrzAcquiring write lock timed out)rrr rr rrrr ValueErrorpopr appendremoverr)rrrr upgradewriterrs r acquire_writezReadWriteLock.acquire_writeps%  fw&G*,eM   "B '}}"""a'"|    $ $ &{t~~%,, %%OPP $ ,0NN,>,>r,B)%%,,R0~~$--*?00(-/DM151J1JQ1ND.89D5"H    $ $ &?..q1R7 )+ -.*040E0Eab0I-.    $ $ &-& '$& 0I A~(261J1JDNN2.89D5 ++KLL!1188<*+KLL$$)))4$$))+Y\    $ $ &s#H,6B,H,>3H, BH,,IcHt}|jj |j|urC|xjdzc_|jsd|_|jj ns||j vrZ|j |xxdzcc<|j |s?|j |=|j s&|jj n td|jjy#|jjwxYw)zkRelease the currently held lock. In case the current thread holds no lock, a ValueError is thrown.rNzTrying to release unheld lock) rr rr r notify_allrr!r)rrs rrzReadWriteLock.releases     " '}}"""a'"))%)DM$$//1t~~%r"a'"~~b)r*>>((335 !@AA    $ $ &D   $ $ &s CDD!)__name__ __module__ __qualname____doc__rrr&rrrrrs(2 '+-'^(,S'j'rrN)r, threadingrrrrrr-rrr/s!  65 J'J'r