=wgdZddlZddlZddlZddlZd dZGddeZGddeZGdd eZ ejd k(re Z yeZ y) ai This module contains classes implementing exclusive locks for platforms with fcntl (UNIX and Mac OS X) and Windows. Whoosh originally used directory creation as a locking method, but it had the problem that if the program crashed the lock directory was left behind and would keep the index locked until it was cleaned up. Using OS-level file locks fixes this. Nctj|z}|}|sMtj|kr6tj||}|stj|kr6|S)aCalls ``fn`` every ``delay`` seconds until it returns True or ``timeout`` seconds elapse. Returns True if the lock was acquired, or False if the timeout was reached. :param timeout: Length of time (in seconds) to keep retrying to acquire the lock. 0 means return immediately. Only used when blocking is False. :param delay: How often (in seconds) to retry acquiring the lock during the timeout period. Only used when blocking is False and timeout > 0. )timesleep)fntimeoutdelayuntilvs K/var/www/horilla/myenv/lib/python3.12/site-packages/whoosh/util/filelock.pytry_forr *sW IIK' !E ADIIK%' 5 DDIIK%' Hc*eZdZdZdZdZddZdZy)LockBasezBase class for file locks. c.d|_||_d|_y)NF)fdfilenamelocked)selfrs r __init__zLockBase.__init__As   r cht|dr|jr |jyyy#YyxYw)Nr)hasattrrreleasers r __del__zLockBase.__del__Fs2 4 477  $+  s-1cy)a"Acquire the lock. Returns True if the lock was acquired. :param blocking: if True, call blocks until the lock is acquired. This may not be available on all platforms. On Windows, this is actually just a delay of 10 seconds, rechecking every second. N)rblockings r acquirezLockBase.acquireMs r cy)Nrrs r rzLockBase.releaseVs r NF)__name__ __module__ __qualname____doc__rrrrrr r rr=s   r rceZdZdZddZdZy) FcntlLockz/File lock based on UNIX-only fcntl module. c ddl}tjtjz}tj|j ||_|j}|s||jz} |j|j |d|_ y#t$rmtjd}|jtjtj fvrtj"|j d|_YywxYw)NrTF)fcntlosO_CREATO_WRONLYopenrrLOCK_EXLOCK_NBflockrIOErrorsysexc_infoerrnoEAGAINEACCESclose)rrr)flagsmodees r rzFcntlLock.acquire^s R[[(''$--/}} EMM !D  KK &DK  q!Awwu||U\\:: HHTWW DG  s)#B A3DDc|j tdddl}|j|j|jt j |jd|_y)NLock was not acquiredr)r Exceptionr)r0LOCK_UNr*r7)rr)s r rzFcntlLock.releasetsG 77?34 4 DGGU]]+ r Nr r!r"r#r$rrrr r r&r&Zs,r r&ceZdZdZddZdZy) MsvcrtLockz3File lock based on Windows-only msvcrt module. cddl}tjtjz}|j}|r |j }tj |j||_ |j|j|dy#t$r|tjd}|jtjtjtj fvrtj"|jd|_YywxYw)Nrr(TF)msvcrtr*r+r,LK_NBLCKLK_LOCKr-rrlockingr1r2r3r4r5r6EDEADLKr7)rrrCr8r9r:s r rzMsvcrtLock.acquires R[[( >>D''$--/  NN477D! ,  q!Awwu||U\\5==II HHTWW DG  s&BBD D cddl}|j td|j|j|jdt j |jd|_y)Nrr<r()rCrr=rFLK_UNLCKr*r7)rrCs r rzMsvcrtLock.releasesI 77?34 4tww3 r Nr r?rr r rArA~s(r rAnt)g@g?) r$r4r*r2rr objectrr&rAnameFileLockrr r rNsZ8  & v :!!HD77d?HHr