dtj2&UddlmZddlZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z ddlmZddlmZmZdd lmZmZmZdd lmZdd lmZmZmZmZd Zd ed<dZ ded<dZ!ded<dZ"ded<GddeZ#d%dZ$d&d Z%d'd$Z&dgZ'dS)() 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 ddZ ddZ e ddZ ed dZed!dZddZddZd"dZd#dZdS)$ 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_supportedreturnNonecbt|jt|jtjtjztjztjz}ttddx}||z} tj |j|| }n]#t$rP}|j tks!|j tkrtjdks|Yd}~dSd}~wwxYw||||dS)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 L/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/filelock/_soft.py_acquirezSoftFileLock._acquire3s"4>222/// bj(294rzA!"lD99 9J F Z E 0A0ABBBB   6))io.G.GCL\cLcLc  & & ( ( ( FFFFF   %%b))) !!"%%%%%s:-B(( D2AC==Dr<intcd} ttj|}||n#t$r|tj|tt5|Pttj |j |kr&t|j  dddn #1swxYwYwxYw| ||dSN)_file_identityr*fstat_write_lock_info BaseException_mark_descriptor_releasedcloserr2lstatr)runlink_mark_descriptor_owned)r9r<identitys r>r8z!SoftFileLock._publish_held_markerGs;,0 %bhrll33H  ! !" % % % %     * * , , , HRLLL'"" 2 2'N28DN;S;S,T,TX`,`,`((//111 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2    ##B11111s/6;AC-AC  C- C$ $C-'C$ (C-cttt5t|j\}}}|t kr ddddSt |}|Ctj|z tkrt|j|| ddddSt|rt|j||ddddS#1swxYwYdSrB) rr2 ValueError_read_lock_filer)r_parse_lock_holdertimerrr)r9contentmtimeinoholders r>r6z"SoftFileLock._try_break_stale_lockXsR gz * * < <"1$."A"A GUC555 < < < < < < < <(00F~9;;&*GGG#DNE3??? < < < < < < < <v& <s;;; < < < < < < < < < < < < < < < < < rEzSoftFileLock._write_lock_infojsk )++00000(55 5E B uLLL D"dkkmm$$$$$ int | Nonecttt5tt |jd}||dcdddS dddn #1swxYwYdS)z The PID of the process holding this lock, read from the lock file. :returns: the PID as an integer, or ``None`` if the lock file does not exist or cannot be parsed rN)rr2rNrPrOr))r9rUs r>pidzSoftFileLock.pidtsgz * * ! !'(G(G(JKKF!ay ! ! ! ! ! ! ! !! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !ts1A&&A*-A*c4ttt5tt |jd}|;|\}}}|t jko|tkcdddS dddn #1swxYwYdS)z Whether this lock is held by the current process. :returns: ``True`` if the lock file exists and names the current process's PID and hostname rNF) rr2rNrPrOr)r*rXr )r9rUr_hostname_s r>is_lock_held_by_uszSoftFileLock.is_lock_held_by_ussgz * * F F'(G(G(JKKF!#) Xqbikk)Eh)++.E  F F F F F F F F! F F F F F F F F F F F F F F F usAB  BBctt5t|jddddS#1swxYwYdS)zNForcibly break the lock by removing the lock file, regardless of who holds it.N)rr2rr)rJ)r9s r> break_lockzSoftFileLock.break_locks g   * *  ' ' ) ) ) * * * * * * * * * * * * * * * * * *s'A  A A c|jj}|Jd}tt5t t j|}dddn #1swxYwY| ||dnR#t$rE} | |n(#t$r}td||Yd}~nd}~wwxYwd}~wwxYw| |dS)NF)default_suppressesz4lock descriptor close and marker cleanup both failed) _context lock_file_fdrr2rCr*rDrG_close_released_fdrF_unlink_held_markerr )r9r<rL close_error cleanup_errors r>_releasezSoftFileLock._releasesx ] '~~~,0 g   4 4%bhrll33H 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 &&(((   # #B5 # A A A A    ((2222    %J!      *****sM"AAA5B CB.-C. C8C CCCCrLtuple[int, int] | NonecV|dStjdkr||dStt5t t j|j|kr&t|j ddddS#1swxYwYdS)Nr() r4r5_windows_unlink_if_oursrr2rCr*rIr)rrJ)r9rLs r>rkz SoftFileLock._unlink_held_markers   F <7 " "  ( ( 2 2 2 2 2'"" 2 2!"(4>":":;;xGG((//111 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2sABB"%B"tuple[int, int]cd}ttD]} ttj|j|krdSt |jdS#t$rM}|j tthvrYd}~dS|tdz krtj ||dz}Yd}~d}~wwxYwdS)NgMbP?r )rangerrCr*rIr)rrJr2r3rrrQsleep)r9rL retry_delayattemptexcs r>rqz$SoftFileLock._windows_unlink_if_ourss 011  G !"(4>":":;;xGGFFT^$$++--- % % %9VUO33FFFFFF01444J{+++1$K  %  s#*A0&A00 C:C'CCN)r$r%)r<r@r$r%)r$r])r$r)rLror$r%)rLrrr$r%)__name__ __module__ __qualname____doc__r__annotations__r!r"r#r?r8r6 staticmethodrEpropertyr_rcrernrkrqr\r>rrs]   !%$$$$6]\\\\+0!////$)((((&&&&(2222"<<<<$%%%\%   X    X **** ++++62222r\rstos.stat_resultr$rrc|j|jfSrB)st_devst_ino)rs r>rCrCs 9bi r\pathstrtuple[str | None, float, int]c 6tj|}tj|jsd|j|jfStj|tjttddzttddz} tj |}tj|js#d|j|jftj |Stj |tdz}tj |n#tj |wxYwt|tkrNtt 5|d|j|jfcdddS#1swxYwYd|j|jfS)Nr'r O_NONBLOCKr zutf-8)r*rIstatS_ISREGst_modest_mtimerr0O_RDONLYr/rDrHreadrlenrUnicodeDecodeErrordecode)rrr<datas r>rOrOs $B < # #,R[")++ r{WRq%A%AAGBP\^_D`D`` a aB Xb\\|BJ'' 0bi/  wr.233    4yy''' ( ) ) @ @;;w''bi? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ bi ''s$ ;D D D#"FFFrR str | None"tuple[int, str, int | None] | Nonec^|r7t|x}dvrdS t|d}t|tkrt|dnd}n#t $rYdSwxYwd|cxkrdksndS||d|fS)N>rtrrrtr i)rstrip splitlinesr@rrN)rRlinesr_ start_tokens r>rPrPs c7==??#=#=#?#??%@@NNt%(mm'*5zz5X'X'Xc%(mmm^b tt  y t a+ %%sAB BB)rrr$rr)rrr$r)rRrr$r)( __future__rr*rr4rQ contextlibrr3rrrpathlibrtypingr _apir r _identityr rr_soft_protocolr_utilrrrrrr~rrrrrCrOrP__all__rr\r>rs""""""" ''''''''''55555555EEEEEEEEEE777777bbbbbbbbbbbb.11111"&&&&&"$$$$$23#3333ttttt<tttn    ((((2&&&&, r\