^j2UddlmZddlZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z ddlmZddlmZmZdd lmZmZmZdd lmZdd lmZmZmZmZd Zd ed<dZ ded<dZ!ded<dZ"ded<GddeZ#ddZ$ddZ%ddZ&dgZ'y)) annotationsN)suppress)EACCESEEXISTEPERM)Path)Final) BaseFileLock_raise_grouped_errors) host_nameowner_is_staleprocess_start_token)STRICT_SOFT_SENTINEL_RECORD)break_lock_fileensure_directory_existsraise_on_not_writable_file write_allg@z Final[float]_MALFORMED_LOCK_AGE_THRESHOLDiz Final[int]_MAX_LOCK_FILE_SIZE _UNLINK_MAX_RETRIES#_MARKER_WITH_START_TOKEN_LINE_COUNTceZdZUdZdZded<dZded<dZded <dZded <dd Z dd Z dd Z e ddZ eddZeddZddZddZddZddZy) SoftFileLockaz Cooperative file lock based on a shared existence marker. Unlike :class:`UnixFileLock ` and :class:`WindowsFileLock `, this lock does not use OS-level locking primitives. Instead, it creates the lock file with ``O_CREAT | O_EXCL`` and treats its existence as the lock indicator. The filesystem must provide coherent exclusive creation and directory updates to each participating process. A crash can leave the marker behind. The marker contains the holder's PID and hostname. A contender may remove it when it can no longer find a same-host process with that PID. A configured :attr:`~filelock.BaseFileLock.lifetime` also permits removal based on marker age, including while the holder remains alive. Age-based expiry can overlap protected operations and does not provide strict mutual exclusion. Tbool_lifetime_supported)StrictSoftFileLock SoftFileLeaseztuple[str, str] | None_lifetime_replacementsF_preserve_lock_file_supported_on_acquired_supportedcrt|jt|jtjtj ztj ztjz}ttddx}||z} tj|j||j}|j%||j'|y#t$rT}|jtk(s'|jtk(rtj dk(s|j#Yd}~yd}~wwxYw)N O_NOFOLLOWwin32)r lock_filerosO_WRONLYO_CREATO_EXCLO_TRUNCgetattropen _open_modeOSErrorerrnorrsysplatform_try_break_stale_lock_mark_descriptor_pending_publish_held_marker)selfflags o_nofollowfd exceptions Y/var/www/ramen.bs-engineer-server.com/venv/lib/python3.12/site-packages/filelock/_soft.py_acquirezSoftFileLock._acquire3s"4>>2/ bjj(2994rzzA!"lD9 9J F Z E 0ABB %%b) !!"% 6)ioo.GCLL\cLc  & & (   s/C D6"A D11D6cd} ttj|}|j||j||y#t$r|j tj |tt5|Nttj|j|k(r#t|jjddd#1swYxYwwxYwN)_file_identityr(fstat_write_lock_info BaseException_mark_descriptor_releasedcloserr0lstatr'runlink_mark_descriptor_owned)r7r:identitys r<r6z!SoftFileLock._publish_held_markerGs,0 %bhhrl3H  ! !" % ##B1   * * , HHRL'" 2'N288DNN;S,TX`,`(//1 2  2   s$/A=C*AC C*C& "C*cttt5t|j\}}}|t k(r dddyt |}|?tj|z tk\rt|j|| dddyt|rt|j||dddy#1swYyxYwr?) rr0 ValueError_read_lock_filer'r_parse_lock_holdertimerrr)r7contentmtimeinoholders r<r4z"SoftFileLock._try_break_stale_lockXs gz * <"1$.."A GUC55 < <(0F~99;&*GG#DNNE3? < <v&s; < < >":;xG(//1 2 2 2s ABBcd}ttD]T} ttj|j |k7ryt |j jyy#t$rN}|jtthvrYd}~y|tdz krtj||dz}Yd}~d}~wwxYw)NgMbP?r )rangerr@r(rFr'rrGr0r1rrrNsleep)r7rI retry_delayattemptexcs r<rlz$SoftFileLock._windows_unlink_if_ourss 01 G !"((4>>":;xGT^^$++-  %99VUO30144JJ{+1$K  %s#+A*#A** C3B<&B<<CN)returnNone)r:intrtru)rtz int | None)rtr)rIztuple[int, int] | Nonertru)rItuple[int, int]rtru)__name__ __module__ __qualname____doc__r__annotations__r!r"r#r=r6r4 staticmethodrBpropertyr[r_rarjrgrlrYr<rrs  !%$6]2\+0!4/$)D(&(2"<$%%    * +62rYrc2|j|jfSr?)st_devst_ino)sts r<r@r@s 99bii rYc ztj|}tj|jsd|j |j fStj|tjttddzttddz} tj|}tj|js.d|j |j ftj|Stj|tdz}tj|t|tkrAtt 5|j#d|j |j fcdddSd|j |j fS#tj|wxYw#1swYrnrrrnr i)rstrip splitlinesrvrrK)rOlinesr[ start_tokens r<rMrMs c7==?#=#=#??%@N%(m'*5z5X'Xc%(m^b   y  ! a+ %% s0A66 BB)rzos.stat_resultrtrw)rstrrtztuple[str | None, float, int])rOz str | Nonertz"tuple[int, str, int | None] | None)( __future__rr(rr2rN contextlibrr1rrrpathlibrtypingr _apir r _identityr rr_soft_protocolr_utilrrrrrr|rrrrr@rLrM__all__rrYr<rs" ''5EE7bb.1|1"&Z&"$Z$23#Z3t<tn (2&, rY