j8&UddlmZddlZddlZddlZddlmZmZddlm Z ddl m Z dZ de d<eed d ed hz Zd e d <d9dZd:dZej(dk(roddlZddlmZej.ddZde d<ej2gej4_ej8ej4_ej<ej8ej<gej>_ej2ej>_ej2ej@ejBej@ejBej@ejBej@ejBgejD_ej8ejD_dZ#de d<dZ$de d<dZ%de d<dZ&de d<d;d Z'd) annotationsN)EPERMESRCH)Path)Finalz Final[int]_HOST_NAME_LIMIT!?zFinal[frozenset[int]]_HOST_NAME_VERBATIMcd}tjjddD]@}|tvr t |nd|d}t |t |zt kDrn||z }B|xsdS)a The hostname recorded alongside an owner, so a marker written on another machine is never probed here. Marker formats here hold the field to printable non-space ASCII, while ``socket.gethostname()`` reports whatever the kernel stores: a space, a newline that forges an extra marker line, or a byte no codec encodes, which Python hands back as a surrogate. A holder that publishes one raw writes a marker it cannot read back, and loses the lock to the first peer that ages it out as malformed. ``?`` is illegal in a hostname, so escaping it along with every out-of-grammar byte as ``?`` leaves a real name untouched and still keeps two hosts apart, which :func:`owner_is_stale` relies on to refuse to probe a foreign PID. zutf-8surrogateescaper 02x)socket gethostnameencoder chrlenr )namebytepieces ^/home/min/hermes_workspace/demo_review/venv/lib/python3.12/site-packages/filelock/_identity.py host_namerst D""$++G5FG!%88D $sn t9s5z !$4 4    H ;3ch|tk7ryt|sy|yt|}|duxr||k7S)a Whether the recorded owner is provably gone, so reclaiming its marker cannot detach a live holder. Fail closed: return ``True`` only when this process can prove the exact recorded owner is dead. A marker from another host cannot be probed; a live PID whose start token still matches, or whose token cannot be read, is the holder or is indistinguishable from it; a live PID whose start token differs is a recycled PID, so the process that wrote the marker is gone. PostgreSQL, Qt ``QLockFile`` and Mercurial all break a stale lock only on proof of death and treat an unreadable or foreign owner as still holding. FTN)r process_aliveprocess_start_token)pidhostname start_tokencurrents rowner_is_staler$%sD9;  !#&G $  97k#99rwin32)wintypeskernel32T)use_last_errorzFinal[ctypes.WinDLL] _KERNEL32i_WIN_SYNCHRONIZEi&_WIN_PROCESS_QUERY_LIMITED_INFORMATIONW_WIN_ERROR_INVALID_PARAMETERFz Final[bool]_WIN_INHERIT_HANDLEctjtt|}|rtj |yt j tk7S)zSWhether a process with this PID exists, treating an access denial as proof it does.T)r) OpenProcessr*r. CloseHandlectypesget_last_errorr-)r handles rrrPsA&&'79LcR   ! !& )$$&*FFFrc tjtt|}|sydt dD\}}}} tj |t j|t j|t j|t j|s tj|y tj||jdz|jzS#tj|wxYw)zXThe process creation FILETIME as a 100ns tick count, or ``None`` when it cannot be read.Nc3DK|]}tjyw)N)r&FILETIME).0_s r z&process_start_token..]s6]T\qx7H7H7JT\s  ) r)r0r+r.rangeGetProcessTimesr2byrefr1dwHighDateTime dwLowDateTime)r r4creation exit_time kernel_time user_times rrrXs&&'MObdgh6]TYZ[T\6]3)[) *,, X& Y' [) Y'   ! !& )  ! !& )''2-1G1GGG  ! !& )s A%C))Dc tj|dy#t$r6}|jtk(rYd}~y|jt k(rYd}~yd}~wwxYw)z_Whether a process with this PID exists, treating an access denial (``EPERM``) as proof it does.rNFT)oskillOSErrorerrnorr)r errors rrrmsL  GGCO  {{e#{{e#   s AAAAA>linuxandroid_STARTTIME_INDEXc tdjd}t|jj dddS#t t f$rYywxYw)Nz/proc/sys/kernel/random/boot_idascii)encoding-rr)r read_textintstripreplacerI ValueError)boot_ids r _read_boot_idr[sX  @AKKU\K]7==?223;R@@Z(  sAAAA_BOOT_IDc( td|dj}||jddzdj }t |t kry t|t }tdz|zS#t$rYywxYw#t$rYywxYw)zeThe ``/proc//stat`` ``starttime`` folded with the boot id, or ``None`` when the process is gone.z/proc/z/statN)@) r read_bytesrIrfindsplitrrOrVrYr\)r datafields starttimes rrrs fSE/0;;=$**T*Q.01779F6{.. '7 89 Ni/ /    s#A6B6 BB BBdarwin) use_errnozFinal[ctypes.CDLL]_LIBCr_ _CTL_KERN _KERN_PROC_KERN_PROC_PIDzaHAMmmfll25F||CFFLL,@$JaOSYS_S_boSo$*$6$67GUV$W !G\Y&5 5rc~y)z_No proven start-time source, so the owner carries no token and liveness rests on the PID alone.N)r s rrrsr)rr$rr)returnstr)r rVr!rr" int | Nonerbool)r rVrr)r rVrr)rrV)6 __future__rrGrsysrJrrpathlibrtypingrr __annotations__ frozensetr=ordr rr$platformr2r&WinDLLr)HANDLEr1argtypesBOOLrestypeDWORDr0POINTERr7r>r*r+r-r.rrrOr[r\rvCDLLrirjrlrmrncalcsizero__all__rrrrsE"  #*"-6uT47H-ISQTXJ-V*V*:(<<7&3fmmJt&TI#T&.oo%6I"$,MMI!&.nnhmmX^^%TI"$,OOI!x(()x(()x(()x(() *I&)1 I%#+j+9?*J?/1 *1',,GH*  ||++ (**)  -*. 0  !$/FKK$E!E ! :!!# J#%& &(-*,$3FOO4D$E zE 6    r