ejCUddlmZgdZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z dZded <eed d ed hz Zd ed<dZded<dZded<dZded<dUdZdUdZdVd ZdVd!ZdWd$Zejd%kr ddlZdd&lmZejd'd()Z d*ed+<ej!ge j"_#ej$e j"_%ej&ej$ej&ge j'_#ej!e j'_%ej!ej(ej)ej(ej)ej(ej)ej(ej)ge j*_#ej$e j*_%d,Z+ded-<d.Z,ded/<d0Z-ded1<d2Z.d3ed4<dXd5Z/dYd6Z0ndXd7Z/ejd8vr6d9Z1ded:<dZd;Z2e2Z3ded<<d=Z4ded><dYd?Z0d[d@Z5dYdAZ6d\dBZ7d]dDZ8ndejdEkrUddlZddl9Z9ej:dd(FZ;dGedH<dIZdedM<dNZ?dedO<e9j@e?ZAdedP<dYdQZ0ndYdRZ0ejd8vrd\dSZ7gdTZBdS)^) annotations)hashlibpathlibsockettypingN)EPERMESRCH)Path)Finalz Final[int]_HOST_NAME_LIMIT!?zFinal[frozenset[int]]_HOST_NAME_VERBATIM_HOST_NAME_DIGEST_LENl__INITIAL_PID_NAMESPACEz?pidns-z Final[str]_NAMESPACE_MARKreturnstrcddtjddDt z}t |t krlt tz dz }|d|dtj ||d dt}|pdS) 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. Linux appends the PID namespace, as Mercurial's lock prefix does. Two containers in one pod share the hostname and the boot id but not the PID namespace, so a PID recorded in one names another process, or none, in the other. The suffix starts with a ``?`` no escape can produce, so ``a`` in a namespace never reads as a host literally named ``a?pidns-...``. The initial namespace adds nothing, which keeps a host's name what older releases recorded. An over-long name ends in a digest of the part cut to fit the limit. A bare cut gives every name that shares the kept prefix one identity, and :func:`owner_is_stale` would then probe a local PID for another host's holder. c3RK|]"}|tvrt|nd|dV#dS)r02xN)rchr).0bytes Z/home/spazio/cosmos_universe_media/venv/lib/python3.11/site-packages/filelock/_identity.py zhost_name..-sS  !444CIII.d...      zutf-8surrogateescapeN-r) joinr gethostnameencode_pid_namespace_suffixlenr rrsha256 hexdigest)namekeeps r host_namer.s(   *,,33G=NOO      ! !  "  4yy###"77!;uu+jjtDEE{/A/A/C/C D D N N P PQgRgQg hjj ;3r!c tdj}n#t$rYdSwxYw|tkrdn t |dS)Nz/proc/self/ns/pidrx)r statst_inoOSErrorrr) namespaces rr(r(:sk 34499;;B rr44422_:[i:[:[:[[s &) 77pidinthostname start_token int | Noneboolc|tkrdSt|r%|!t|x}t||rdSt|vpt || S)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. F)r. process_aliveprocess_start_token _same_startr_owner_runs_elsewhere)r5r7r8currents rowner_is_stalerABsv9;;uS+>s+C+C CLP[\cepPqPqLu h & U.CC.U.U*UUr!c|tjks|tkrdS|dup|t|kS)a Whether the recorded owner is this process, so a marker a recycled PID left behind never reads as ours. Fail closed: a recorded start token must match this process's. One that differs was written by an earlier process that reused this PID, and when this process cannot read its own token nothing proves the marker is ours. A marker without a token falls back to the PID and hostname. FN)osgetpidr.r=)r5r7r8s rowner_is_current_processrEVsF bikkX44u $  I+1DS1I1I"IIr!r@recordedc>||kpd|dz |dz hvo |dz|dzkS)Nr@l)r@rFs rr>r>cs< h  p1BB(G#G#oGV[O_gjo_oLopr!win32)wintypeskernel32T)use_last_errorzFinal[ctypes.WinDLL] _KERNEL32i_WIN_SYNCHRONIZEi&_WIN_PROCESS_QUERY_LIMITED_INFORMATIONW_WIN_ERROR_INVALID_PARAMETERFz Final[bool]_WIN_INHERIT_HANDLEcttt|}|rt|dSt jtkS)zSWhether a process with this PID exists, treating an access denial as proof it does.T)rN OpenProcessrOrS CloseHandlectypesget_last_errorrR)r5handles rr<r<sQ&&'79LcRR    ! !& ) ) )4$&&*FFFr!c 4ttt|}|sdSdt dD\}}}} t|t j|t j|t j|t j|s t|dS t|n#t|wxYw|j dz|j zS)zXThe process creation FILETIME as a 100ns tick count, or ``None`` when it cannot be read.Nc3<K|]}tjVdSN)rKFILETIME)r_s rr z&process_start_token..s+6]6]qx7H7J7J6]6]6]6]6]6]r! ) rNrUrPrSrangeGetProcessTimesrWbyrefrVdwHighDateTime dwLowDateTime)r5rYcreation exit_time kernel_time user_times rr=r=s&&'MObdghh 46]6]TYZ[T\T\6]6]6]3)[) *,, X&& Y'' [)) Y''    ! !& ) ) ) ) )   ! !& ) ) ) )I ! !& ) ) ) )'2-1GGGs A&C))Dc tj|dn?#t$r2}|jtkrYd}~dS|jt krYd}~dSd}~wwxYwdS)z_Whether a process with this PID exists, treating an access denial (``EPERM``) as proof it does.rNFT)rCkillr3errnor r)r5errors rr<r<su  GCOOOO   {e##uuuuu{e##ttttt    ts AAAAA>linuxandroid_STARTTIME_INDEXc tdd}t|dddS#t t f$rYdSwxYw)Nz/proc/sys/kernel/random/boot_idasciiencodingr$rr)r read_textr6stripreplacer3 ValueError)boot_ids r _read_boot_idr|sv  @AAKKU\K]]7==??223;;R@@@Z(   qq sAAA0/A0_BOOT_IDl__INITIAL_TIME_NAMESPACEc@trt|ndS)am The ``/proc//stat`` ``starttime`` folded with the boot id. ``None`` when the process is gone, or when this process runs in a time namespace with a boottime offset. Since Linux 5.6 the kernel shifts ``starttime`` by the reader's offset, so a value read there differs from what a peer outside reads. N)_starttime_unshifted_read_start_tokenr5s rr=r=s$.B-C-CM$S))) Mr!c tdj}n#t$rYdSt$rYdSwxYw|t krdS tdj|krdStdd}n#t$rYdSwxYwtd|DS) Nz/proc/self/ns/timeTFz/proc/self/ns/time_for_childrenz/proc/self/timens_offsetsrsrtc3NK|] }|gdgdfvV!dS))boottime0r)7rrN)splitrlines rr z'_starttime_unshifted..s@rrUYtzz||(>(>(>'PPrrrrrrr!) r r1r2FileNotFoundErrorr3r~rwany splitlines)r4offsetss rrrs #'(<#=#=#B#B#D#D#K $   tt   uu 333t 9::??AAHIUU 5!%&A!B!B!L!LV]!L!^!^   uu rr]d]o]o]q]qrrrrr rs,&) A AA*B$#B$$ B21B2c~ td|d}n#t$rYdSwxYw||ddzd}t |t krdS t|t }n#t$rYdSwxYwtdz|zS)N/proc/z/stat)r#rH) r read_bytesr3rfindrr)rqr6rzr})r5datafields starttimes rrrs /S///00;;==   tt $**T**Q.0017799F6{{...t '7 899    tt Ni/ /s%( 66B!! B/.B/ctrdz dthvrdSt tjd5}t fd|DcdddS#1swxYwYdS#t $rYdSwxYw)a  Whether the owner runs in another PID namespace as *pid*. An older release in a container sharing this hostname recorded its in-container PID, which means nothing here. Readers without a boottime offset read the same starttime and boot id. A task with the recorded start token whose innermost PID is *pid* is therefore the owner; one that started in the same tick is not. A reader with an offset cannot compare start tokens, so the innermost PID alone keeps the marker. NrHrFz/procc3K|]p}|joRt|jxko8 p"txduot ot kVqdSr\)r,isdigitr6rr>_innermost_pid)rentryr5r8tasktoken unshifteds rr z(_owner_runs_elsewhere..s  " **,,8%(__4T<8!*Mt*;D*A*A!A$ N rS^_dfqSrSr 8 +400C7      r!)r}rrCscandirrr3)r5r8entriesrrrs`` @@@rr?r?s"x"K24EaQY]4Z4Zu355I Z(( G        &-                          uu s5A;A.! A;.A22A;5A26A;; B B rc td|d}n#t$rYdSwxYwtd|dDdS)Nrz/statusc3K|]@}|dt|dVAdS)sNSpid:N) startswithr6rrs rr z!_innermost_pid..sIee4$//ZcJdJdeTZZ\\"%&&eeeeeer! )r rr3nextr)rstatuss rrr s  $%;d%;%;%; < < G G I I   tt ee6<<3F3Feee s %( 66darwin) use_errnozFinal[ctypes.CDLL]_LIBCr# _CTL_KERN _KERN_PROC_KERN_PROC_PIDz*>aHHAMMtmfl255F||CFFL,@,@$JJaOOSYS_boSoSot$*$67GUV$W$W !G\Y&5 5r!c~dS)z_No proven start-time source, so the owner carries no token and liveness rests on the PID alone.NrIrs rr=r=4s 4r!c ~~dS)zbWithout Linux PID namespaces, a PID that is gone or recycled leaves its owner nowhere else to run.FrI)r5r8s rr?r?<s ur!)r.rErAr<r=)rr)r5r6r7rr8r9rr:)r@r6rFr6rr:)r5r6rr:)r5r6rr9)rr6)rr:)r5r6r8r9rr:)rr6rr9)C __future__r__lazy_modules__rrCrsysrlrr rr rr r __annotations__ frozensetraordrrrrr.r(rArEr>platformrWrKWinDLLrNHANDLErVargtypesBOOLrestypeDWORDrUPOINTERr]rbrOrPrRrSr<r=rqr|r}r~rrr?rrCDLLrrrrrcalcsizer__all__rIr!rrs"""""""===  #""""-6YuuT47H7H-I-ISSQTXXJ-VVVVV$%%%%%&0////'''''B\\\\VVVV( J J J Jqqqq<7MMM&3fmJt&T&T&TITTTT&.o%6I"$,MI!&.nhmX^%TI"$,OI!x())x())x())x()) *I&)1 I%#+++++9?*????/1 1111',,,,,GGGGHHHHH*     |+++ (*))))     -}.....88888 N N N N s s s s* 0 0 0 0    8       ! !  $/FK$E$E$EEEEE ! !!!!!# ####%&&&&&(-,,,,$3FO4D$E$E EEEE 6 6 6 6 6      <+++    r!