jDUddlmZgdZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z mZmZmZddlmZmZmZddlmZmZd Zd ed <d Zd ed<ej6dej8Zded<e dZGddeZGdde Z ddZ!ddZ"ddZ#gdZ$y)) annotations) contextlibzfilelock._identityzfilelock._utilmathN)suppress)FinalLiteral NamedTuple) host_nameowner_is_current_processowner_is_staleprocess_start_token) SoftFileLock_read_lock_file parse_decimal) pin_inode write_allz filelock/2z Final[str] _PROTOCOLiz Final[int]_MAX_PIDz#[0-9]+(?:\.[0-9]+)?(?:e[+-][0-9]+)?zFinal[re.Pattern[str]] _DURATION)lease exclusiveunknownceZdZUdZdZded<eddZeddZeddZ ddZ dfd Z e dfd Z e dfd Zdd Zdd ZddZxZS)MarkerSoftFileLockzAAn existence lock whose marker carries a protocol 2 owner record.r OwnerMode _owner_modec"|jS)z The owner named by the marker on disk. :returns: the published record, or ``None`` when no marker exists or its record is malformed or protocol 1 ) _read_ownerselfs ]/home/oem/CyberBrain26-unified/dev-env/.venv/lib/python3.12/site-packages/filelock/_marker.pyownerzMarkerSoftFileLock.owner$s!!cB|jx}dS|jS)z The PID of the process holding this lock, read from the marker. :returns: the PID, or ``None`` when no marker exists or its record is unreadable N)rpidr r"s r!r%zMarkerSoftFileLock.pid.s&"&!1!1!33OGVdFMM22  3 3 3 &g..7-/y(^EIIu~~W\WbWb-c 2 3 3 3 3 3 3s/C6*C*C6'A2C*C6*C3 /C66C?clt|x}|j|jfSt||SN)r4r%r(r5_recorded_holder)clsr:r"r<s r!r?z#MarkerSoftFileLock._recorded_holderWs6!'* *E 799enn, ,w'00r#c t|x}t| ||S|jdk(xsV|j|k7xs|j t k7xr,t|j|j |j Sr/) r4r5_marker_is_liver7r%r(r r r))r@r: breaker_pidr"r<s r!rBz"MarkerSoftFileLock._marker_is_live]sx!'* *E 37*7K@ @zzY& YY+ % F9;)F K"599ennekkJJ r#cttt5tt |j dcdddS#1swYyxYw)Nr)rr0r1r4rr2rs r!rzMarkerSoftFileLock._read_ownerfs> gz * E @ CD E E Es !AA cJt|t|jyr>)r encode_marker_published_record)r fds r!_write_lock_infoz#MarkerSoftFileLock._write_lock_infoks"mD$:$:$<=>r#c ttjt|jt tjS)N)r%r(r7r)) OwnerRecordosgetpidr rr rs r!rGz$MarkerSoftFileLock._published_recordns4 [!!%biik2   r#)returnOwnerRecord | None)rN int | None)rNbool)rNNone)r: str | NonerNztuple[int, str] | None)r:rSrCintrNrQ)rHrTrNrR)rNrK)__name__ __module__ __qualname____doc__r__annotations__propertyr"r%r*r-r6 classmethodr?rBrrIrG __classcell__)r<s@r!rrsK)K( ""LLff 311    ? r#rcZeZdZUdZded<ded<ded<dZd ed <dZd ed <dZd ed<y)rKz7Keep optional metadata when reading unknown lock modes.rTr%strr(rr7NrStokenz float | Nonelease_durationrPr))rUrVrWrXrYr_r`r)r#r!rKrKws2A HM OE:#'NL'E:r#rKctd|jd|jd|jg}|j|j d|j|j |j d|j |j|j d|jdjd|DjS) z>Render an owner record as the bytes a protocol 2 marker holds.zpid=zhost=zmode=ztoken=z duration=zstart=c3&K|] }|d yw) Nra).0lines r! z encode_marker..s14dV2;1s) rr%r(r7r_appendr`r)joinencode)recordliness r!rFrFs $vzzl+uV__4E-F%PVP[P[}H] ^E || vfll^,- ( y!6!6 9:; || vfll^,- 77151 1 8 8 ::r#c|r4|ddk7s,|jjx}r |dtk7ryi}|ddD] }|jd\}}}|sy|||<"t |S)zcReturn the owner a protocol 2 marker names, or ``None`` when the record is malformed or protocol 1.rerN=)strip splitlinesr partition _build_record)r:rmfieldsrgkey separatorvalues r!r4r4s gbkT)7==?;U;U;W2W%2W\abc\dhq\qFab  $s 3Ys    r#c|jdx}y|dvr|nd}|jd}|r d|vsd|vrtj|dsy t|d}d|vrt |dnd}d|vrt|dnd}d|cxkr t ksyy|jd }|d k(r|r|tj|r|d kDsyt|||||| S#t $rYywxYw) Nr7>rrrhostr%durationr)rpr_rr)r%r(r7r_r`r)) getr fullmatchrfloatr1rrisfiniterK)rv publishedr7r(r%r|r)r_s r!rurus ZZ'' 0*37M*MYS\Dzz&!H uF*zV/CIL_L_`fgq`rLsF5M*0:f0D5 +,$29V2C fWo.  x   JJw E w)9$--PXBY^fij^j 3EZbjo pp s6C C,+C,)rrrKrFr4)rlrKrNbytes)r:rSrNrO)rvzdict[str, str]rNrO)% __future__r__lazy_modules__rrLrerrtypingrrr filelock._identityr r r r filelock._softrrrfilelock._utilrrrrYrcompileASCIIrrrrKrFr4ru__all__rar#r!rs"Q --ggGG/ % :$ * %/BJJ/UWYW_W_$` !` 3 4 V V r* ; !q6 r#