§
    eÉÝjºž ã                  óœ
  — U d dl mZ g d¢Zd dlZd dlZd dlZd dlZd dlZd dlZd dl	Z	d dl
Z
d dlZd dlZd dlZd dlZd dlmZmZ d dlmZmZ d dlmZ d dlmZmZ d dlmZ d d	lmZmZ d d
lmZm Z  d dl!m"Z" d dl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z* d dl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3 d dl4m5Z5m6Z6m7Z7 d dl8m9Z9m:Z: d dl;m<Z< dZ=de>d<   e
j?        e
j@        z  e
jA        z  ZBde>d<   dZCde>d<   e/d         ZD eEddh¦  «        ZFde>d<   e/d         ZG eEh d£¦  «        ZHde>d<   e,rrd dlmIZImJZJ d d l#mKZK d d!lmLZLmMZM d d"l+mNZN d d#lOmPZP d d$lQmRZR d d%lSmTZT d d&lUmVZV  G d'„ d(eN¦  «        ZW G d)„ d*eN¦  «        ZX G d+„ d,eN¦  «        ZY G d-„ d.eN¦  «        ZZd d/l+m[Z[  ej\        d0¦  «        Z]d1e>d2<    e3d3 e^ed4d¦  «        ¦  «        Z_d5e>d6<   e_duZ`d7e>d8<    e2d9¦  «        Za e2d:¦  «        Zb e2d;¦  «        Zcedeez  efz  egz  dz  eeegdf         z  Zh G d<„ d=e1d>¬?¦  «        Zi�d	dD„ZjddEœ�d
dN„Zk�ddR„Zl�ddU„Zm�ddX„Zn�ddZ„Zo�dd[„Zp�dd^„Zqe,r G d_„ d`eN¦  «        Zr�d�dda„Zs�ddb„Zt�dde„Zu�ddh„Zvejw        dik    rejx        jy        nejx        jz        Z{dje>dk<   �ddn„Z| G do„ dpe*¦  «        Z} e}¦   «         Z~dqe>dr<    e2dsdt¬u¦  «        Z e2dvdw¬u¦  «        Z€ G dx„ dye¦  «        Z��dd€„Z‚�ddƒ„Zƒ�dd…„Z„�ddˆ„Z…�dd‹„Z†�ddŽ„Z‡�dd�„Zˆ�dd“„Z‰�dd–„ZŠ�d d™„Z‹�d!d�„ZŒ�d"dž„Z� e5¦   «         ZŽdŸe>d <   �d#d¢„Z� ed£¬¤¦  «         G d¥„ d¡¦  «        ¦   «         Z� G d¦„ dtej‘        e�¬§¦  «        Z’�d$d¨„Z“�d%d­„Z”�d$d®„Z• ed£d£¬¯¦  «         G d°„ d±¦  «        ¦   «         Z– e—¦   «         Z˜d²e>d³<   �d&d¸„Z™�d	d¹„Zš�d'd¼„Z› G d½„ d¾e.e€         ¦  «        Zœe G d¿„ dÀ¦  «        ¦   «         Z� G dÁ„ dÂe�e*¦  «        Zž�d(dÄ„ZŸ ee�¦  «        D ]"Z  e¡eže j¢         eŸe j¢        ¦  «        ¦  «         Œ# ed£¬¤¦  «         G dÅ„ dÆ¦  «        ¦   «         Z£ G dÇ„ dÈ¦  «        Z¤ e6¦   «         Z¥dÉe>dÊ<    e6¦   «         Z¦dËe>dÌ<   i Z§dÍe>dÎ<    e¦   «         Z¨dÏe>dÐ<    e¦   «         Z©dÏe>dÑ<    e¤¦   «         ZªdÒe>dÓ<    eEdÔdÕh¦  «        Z«de>dÖ<   ej¬        j¢        d×k    p
ej­        dØk    Z®d7e>dÙ<   e�d)dÚ„¦   «         Z¯�d)dÛ„Z°�d)dÜ„Z±e�d�d*dà„¦   «         Z²�d+dâ„Z³�d,dã„Z´�d�d-dè„Zµ�d.dé„Z¶�d/dê„Z·�d0dì„Z¸�d)dí„Z¹�d)dî„Zº�d)dï„Z»�d)dð„Z¼�d1dò„Z½�d2dó„Z¾�d)dô„Z¿�d/dõ„ZÀ�d3dü„ZÁ�d)dý„ZÂe«eªe)dþœ�d4�d„ZÃ e±¦   «          g �d¢ZÄdS (5  é    )Úannotations)
ÚatexitÚdecimalzfilelock._errorzfilelock._utilÚinspectÚmathÚnumbersÚsecretsÚtypesÚwarningsN)ÚABCMetaÚabstractmethod)ÚCallableÚHashable)Úcontextmanager)Ú	dataclassÚfields)ÚDecimal)ÚcacheÚpartial)ÚcountÚstarmap)ÚReal)ÚTIMEOUT_MAXÚ	ConditionÚRLockÚThreadÚcurrent_threadÚ	get_identÚlocal)ÚTYPE_CHECKINGÚFinalÚGenericÚLiteralÚNoReturnÚ	TypedDictÚTypeVarÚcast)ÚWeakKeyDictionaryÚWeakValueDictionaryÚref)ÚSoftFileLockLifetimeWarningÚTimeout)Úensure_directory_existséÿÿÿÿz
Final[int]Ú_UNSET_FILE_MODEÚ_PERMISSION_BITSé   Ú_MAX_BACKOFF_EXPONENT)ÚchainÚgroupr3   r4   zFinal[frozenset[str]]Ú_CONTEXT_ERROR_POLICIES)ÚdefaultÚraiseÚsuppress>   r7   r6   r8   Ú_CLOSE_ERROR_POLICIES)Ú	GeneratorÚMapping)ÚLock)Ú	FrameTypeÚTracebackType)ÚProtocol)ÚUnused)Ú_LeaseClaim)ÚReadWriteLock)ÚSoftReadWriteLockc                  ó   — e Zd Zdd„ZdS )Ú_ForkResettableÚreturnÚNonec                ó   — d S ©N© ©Úselfs    úU/home/spazio/cosmos_universe_media/venv/lib/python3.11/site-packages/filelock/_api.pyÚ_reset_after_fork_in_childz*_ForkResettable._reset_after_fork_in_childI   ó   € € € ó    N©rF   rG   )Ú__name__Ú
__module__Ú__qualname__rN   rJ   rP   rM   rE   rE   H   s   € € € € € Ø9Ð9Ð9Ð9Ð9Ð9rP   rE   c                  ó   — e Zd Zdd„ZdS )Ú_ForkDescriptorOwnerrF   ú.tuple[tuple[int, tuple[int, int] | None], ...]c                ó   — d S rI   rJ   rK   s    rM   Ú_descriptors_for_forkz*_ForkDescriptorOwner._descriptors_for_forkL   rO   rP   N©rF   rW   )rR   rS   rT   rY   rJ   rP   rM   rV   rV   K   s   € € € € € Ø^Ð^Ð^Ð^Ð^Ð^rP   rV   c                  ó   — e Zd Zdd„ZdS )Ú_ForkResettableClassrF   rG   c                ó   — d S rI   rJ   rK   s    rM   Ú_reset_class_after_forkz,_ForkResettableClass._reset_class_after_forkQ   rO   rP   NrQ   )rR   rS   rT   r^   rJ   rP   rM   r\   r\   P   s   € € € € € Ø6Ð6Ð6Ð6Ð6Ð6rP   r\   c                  ó    — e Zd Zddddœd
d	„ZdS )Ú_RegisterAtForkN©ÚbeforeÚafter_in_parentÚafter_in_childrb   úCallable[[], None] | Nonerc   rd   rF   rG   c               ó   — d S rI   rJ   )rL   rb   rc   rd   s       rM   Ú__call__z_RegisterAtFork.__call__T   s	   € ð �3rP   )rb   re   rc   re   rd   re   rF   rG   )rR   rS   rT   rg   rJ   rP   rM   r`   r`   S   s=   € € € € € ð 15Ø9=Ø8<ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	rP   r`   )ÚSelfÚfilelockzFinal[logging.Logger]Ú_LOGGERz_RegisterAtFork | NoneÚregister_at_forkzFinal[_RegisterAtFork | None]Ú_REGISTER_AT_FORKzFinal[bool]Ú_HAS_REGISTER_AT_FORKÚ_ExtraValueÚ_MarkerValueÚ_SubclassValuec                  óŒ   — e Zd ZU dZded<   ded<   ded<   ded<   ded	<   ded
<   ded<   ded<   ded<   ded<   ded<   ded<   dS )ÚLockOptionszhEvery option the metaclass forwards, so a subclass adding its own can still type what it passes through.ÚfloatÚtimeoutÚintÚmodeÚboolÚthread_localÚblockingÚis_singletonÚpoll_intervalúfloat | NoneÚlifetimeÚContextErrorPolicyÚcontext_error_policyÚCloseErrorPolicyÚclose_error_policyÚfallback_to_softÚpreserve_lock_fileúCallable[[int], None] | NoneÚon_acquiredN©rR   rS   rT   Ú__doc__Ú__annotations__rJ   rP   rM   rr   rr   h   sŸ   € € € € € € ØrÐrà€N€N�NØ€I€I�IØÐÐÑØ€N€N�NØÐÐÑØÐÐÑØÐÐÑØ,Ð,Ð,Ñ,Ø(Ð(Ð(Ñ(ØÐÐÑØÐÐÑØ-Ð-Ð-Ñ-Ð-Ð-rP   rr   F)ÚtotalÚerrorÚBaseExceptionrF   rw   c                ó,   — t          | t          ¦  «        S rI   )Ú
isinstanceÚBaseExceptionGroup©rŠ   s    rM   Ú_is_exception_groupr�   y   s   € Ý�eÕ/Ñ0Ô0Ð0rP   )ÚmarkerÚmessageÚstrÚfirst_errorÚsecond_errorÚadditional_errorsr‘   útuple[str, _MarkerValue] | Noner$   c               ó’   — ||g|¢R }t          |¦  «         t          | |¦  «        }|�t          ||d         |d         ¦  «         |d ‚)Nr   é   )Ú_detach_grouped_contextsrŽ   Úsetattr)r’   r”   r•   r‘   r–   Úerrorsr4   s          rM   Ú_raise_grouped_errorsr�   }   s\   € ð ˜<Ð<Ð*;Ð<Ð<€FÝ˜VÑ$Ô$Ð$Ý% g¨vÑ6Ô6€EØÐÝ��v˜a”y &¨¤)Ñ,Ô,Ð,Ø
�TÐrP   rœ   útuple[BaseException, ...]rG   c                ó<  ‡— t          ¦   «         }t          | ¦  «        }|rû|                     ¦   «         }t          |¦  «        |v rŒ(|                     t          |¦  «        ¦  «         |j        xŠ�7‰|u s+t          |‰¦  «        st          ˆfd„| D ¦   «         ¦  «        rd |_        n‰�|                     ‰¦  «         |j	        �|                     |j	        ¦  «         t          |¦  «        r(|                     t          d|¦  «        j        ¦  «         |°ùd S d S )Nc              3  ó@   •K  — | ]}‰|u pt          |‰¦  «        V — Œd S rI   )Ú_contains_exception)Ú.0ÚrootÚcontexts     €rM   ú	<genexpr>z+_detach_grouped_contexts.<locals>.<genexpr>—   s7   øè è € Ð\Ð\ÈT�7˜d�?ÐHÕ&9¸$ÀÑ&HÔ&HÐ\Ð\Ð\Ð\Ð\Ð\rP   Ú_ExceptionGroupProtocol)ÚsetÚlistÚpopÚidÚaddÚ__context__Ú_same_exception_treeÚanyÚappendÚ	__cause__r�   Úextendr'   Ú
exceptions)rœ   ÚseenÚpendingrŠ   r¤   s       @rM   rš   rš   Œ   s?  ø€ Ý‘U”U€DÝ�6‰lŒl€GØ
ð NØ—’‘”ˆÝˆe‰9Œ9˜ÐÐØØ�Š•�E‘”ÑÔÐØÔ(Ð(ˆGÐ5Ø�uÐÐÝ# E¨7Ñ3Ô3ð åÐ\Ð\Ð\Ð\ÐU[Ð\Ñ\Ô\Ñ\Ô\ð ð !%ˆEÔÐØÐ Ø�NŠN˜7Ñ#Ô#Ð#ØŒ?Ð&Ø�NŠN˜5œ?Ñ+Ô+Ð+Ý˜uÑ%Ô%ð 	NØ�NŠN�4Ð 9¸5ÑAÔAÔLÑMÔMÐMð! ð Nð Nð Nð Nð NrP   ÚfirstÚsecondc                ór  — | |fg}t          ¦   «         }|�r |                     ¦   «         \  }}||u rŒt          |¦  «        t          |¦  «        fx}|v rŒB|                     |¦  «         t	          |¦  «        t	          |¦  «        ust          |¦  «        rt          |¦  «        sdS t          d|¦  «        }t          d|¦  «        }|j        |j        k    s*t          |j	        ¦  «        t          |j	        ¦  «        k    rdS | 
                    t          |j	        |j	        d¬¦  «        ¦  «         |�° dS )NFr¦   T)Ústrict)r§   r©   rª   r«   Útyper�   r'   r’   Úlenr²   r±   Úzip)	rµ   r¶   r´   r³   r”   r•   ÚpairÚfirst_groupÚsecond_groups	            rM   r­   r­   ¢   sI  € Ø�vˆÐ€GÝ!$¡¤€DØ
ñ ZØ$+§K¢K¡M¤MÑ!ˆ�\Ø˜,Ð&Ð&ØÝ˜‘_”_¥b¨Ñ&6Ô&6Ð7Ð7ˆD¸DÐ@Ð@ØØ�Š�‰Œˆå�ÑÔ¥T¨,Ñ%7Ô%7Ð7Ð7Ý& {Ñ3Ô3ð 8å& |Ñ4Ô4ð 8ð �5ÝÐ4°kÑBÔBˆÝÐ5°|ÑDÔDˆØÔ ,Ô"6Ò6Ð6½#¸kÔ>TÑ:UÔ:UÕY\Ð]iÔ]tÑYuÔYuÒ:uÐ:uØ�5Ø�Š•s˜;Ô1°<Ô3JÐSWÐXÑXÔXÑYÔYÐYð# ñ Zð$ ˆ4rP   ÚtargetúBaseException | Nonec                óž  — |�t          | ¦  «        sdS t          t          d| ¦  «        j        ¦  «        }t	          ¦   «         }|r‡|                     ¦   «         }||u rdS t          |¦  «        |v rŒ.|                     t          |¦  «        ¦  «         t          |¦  «        r(|                     t          d|¦  «        j        ¦  «         |°‡dS )NFr¦   T)	r�   r¨   r'   r²   r§   r©   rª   r«   r±   )rŠ   r¿   r´   r³   Úchilds        rM   r¡   r¡   º   sÐ   € Ø€~Õ0°Ñ7Ô7€~ØˆuÝ•4Ð1°5Ñ9Ô9ÔDÑEÔE€GÝ‘U”U€DØ
ð NØ—’‘”ˆØ�Fˆ?ˆ?Ø�4Ýˆe‰9Œ9˜ÐÐØØ�Š•�E‘”ÑÔÐÝ˜uÑ%Ô%ð 	NØ�NŠN�4Ð 9¸5ÑAÔAÔLÑMÔMÐMð ð Nð ˆ5rP   r¤   c                óZ  — t          | |¦  «        st          || ¦  «        rd S | j        €	|| _        d S | }t          ¦   «         }t          |¦  «        |vrW|                     t          |¦  «        ¦  «         |j        �|j        n|j        x}€	||_        d S |}t          |¦  «        |v°Ud S d S rI   )Ú_exception_graph_containsr¬   r§   rª   r«   r°   )rŠ   r¤   Útailr³   Ú
next_errors        rM   Ú_append_exception_contextrÇ   Ë   sÅ   € Ý  ¨Ñ0Ô0ð Õ4MÈgÐW\Ñ4]Ô4]ð ØˆØÔÐ Ø#ˆÔØˆØ€DÝ‘U”U€DÝ
ˆT‰(Œ(˜$Ð
Ð
Ø�Š•�D‘”ÑÔÐØ,0¬NÐ,F˜$œ.˜.ÈDÔL\Ð\ˆJÐeØ&ˆDÔØˆFØˆõ ˆT‰(Œ(˜$Ð
Ð
Ð
Ð
Ð
Ð
rP   c                ó¾  — | g}t          ¦   «         }|rÉ|                     ¦   «         }||u rdS t          |¦  «        |v rŒ.|                     t          |¦  «        ¦  «         |j        �|                     |j        ¦  «         |j        �|                     |j        ¦  «         t          |¦  «        r(|                     t          d|¦  «        j
        ¦  «         |°ÉdS )NTr¦   F)r§   r©   rª   r«   r°   r¯   r¬   r�   r±   r'   r²   ©rŠ   r¿   r´   r³   Úcurrents        rM   rÄ   rÄ   Û   sã   € Øˆg€GÝ‘U”U€DØ
ð PØ—+’+‘-”-ˆØ�fÐÐØ�4Ýˆg‰;Œ;˜$ÐÐØØ�Š•�G‘”ÑÔÐØÔÐ(Ø�NŠN˜7Ô,Ñ-Ô-Ð-ØÔÐ*Ø�NŠN˜7Ô.Ñ/Ô/Ð/Ý˜wÑ'Ô'ð 	PØ�NŠN�4Ð 9¸7ÑCÔCÔNÑOÔOÐOð ð Pð ˆ5rP   útuple[str, _MarkerValue]ú tuple[BaseException, ...] | Nonec                óª   — t          | ¦  «        sd S t          d| ¦  «        }|j        |k    r&t          ||d         d ¦  «        |d         u r|j        nd S )Nr¦   r   r™   )r�   r'   r’   Úgetattrr²   )rŠ   r’   r‘   r4   s       rM   Ú_grouped_errorsrÏ   î   sg   € õ ˜uÑ%Ô%ð ØˆtÝÐ*¨EÑ2Ô2€EØ$œ}°Ò7Ð7½GÀEÈ6ÐRSÌ9ÐVZÑ<[Ô<[Ð_eÐfgÔ_hÐ<hÐ<hˆ5ÔÐÐnrÐrrP   c                  ó>   — e Zd Zedd„¦   «         Zedd„¦   «         ZdS )	r¦   rF   r“   c                ó   — d S rI   rJ   rK   s    rM   r’   z_ExceptionGroupProtocol.messageú   s   € Ø"% #rP   rž   c                ó   — d S rI   rJ   rK   s    rM   r²   z"_ExceptionGroupProtocol.exceptionsý   s   € Ø;>¸3rP   N©rF   r“   )rF   rž   )rR   rS   rT   Úpropertyr’   r²   rJ   rP   rM   r¦   r¦   ù   s<   € € € € € Ø	Ø%Ð%Ð%ñ 
ŒØ%à	Ø>Ð>Ð>ñ 
ŒØ>Ð>Ð>rP   r¦   c                ó  — |€ | j         }	 | ‚# t          $ r	 || _         ‚ w xY w|j         x}�$|| ur t          || ¦  «         t          | |¦  «         | j         }	 | ‚# t          $ r( || _         	 |‚# t          $ r | |_         || _         ‚ w xY ww xY wrI   )r¬   r‹   Ú_detach_exception_contextrÇ   )r”   r•   Úfirst_contextÚsecond_contexts       rM   Ú_raise_chained_errorsrÙ     së   € ØÐØ#Ô/ˆð	ØÐøÝð 	ð 	ð 	Ø&3ˆKÔ#Øð	øøøð 'Ô2Ð2ˆÐ?ÀNÐZeÐDeÐDeÝ! .°+Ñ>Ô>Ð>Ý! +¨~Ñ>Ô>Ð>ØÔ+€Mð	ØÐøÝð ð ð Ø"/ˆÔð	ØÐøÝð 	ð 	ð 	Ø'2ˆLÔ$Ø&3ˆKÔ#Øð	øøøð	øøøs&   ‹ � ÁA ÁBÁ,A.Á.BÂBc                óØ  — | g}t          ¦   «         }|rÖ|                     ¦   «         }t          |¦  «        |v rŒ(|                     t          |¦  «        ¦  «         |j        |u rd |_        n!|j        �|                     |j        ¦  «         |j        �|                     |j        ¦  «         t          |¦  «        r(|                     t          d|¦  «        j
        ¦  «         |°Ôd S d S ©Nr¦   )r§   r©   rª   r«   r¬   r¯   r°   r�   r±   r'   r²   rÉ   s        rM   rÖ   rÖ     sý   € Øˆg€GÝ‘U”U€DØ
ð PØ—+’+‘-”-ˆÝˆg‰;Œ;˜$ÐÐØØ�Š•�G‘”ÑÔÐØÔ &Ð(Ð(Ø"&ˆGÔÐØÔ Ð,Ø�NŠN˜7Ô.Ñ/Ô/Ð/ØÔÐ(Ø�NŠN˜7Ô,Ñ-Ô-Ð-Ý˜wÑ'Ô'ð 	PØ�NŠN�4Ð 9¸7ÑCÔCÔNÑOÔOÐOð ð Pð Pð Pð Pð PrP   Ú
body_errorÚrelease_errorc                ó(   — t          d| |¦  «         d S )Nz!lock body and release both failed©r�   )rÜ   rÝ   s     rM   Ú_raise_body_and_releaserà   +  s   € õ
 Ð=¸zÈ=ÑYÔYÐYÐYÐYrP   Úprimary_errorÚcleanup_errorsc                ó6   — t          | |gd„ |D ¦   «         ¢R Ž  d S )Nc              3  ó   K  — | ]}|®|V — Œ	d S rI   rJ   )r¢   rŠ   s     rM   r¥   z(_raise_cleanup_errors.<locals>.<genexpr>;  s'   è è € Ð	AÐ	A�E¨uÐ/@ˆ%Ð/@Ð/@Ð/@Ð/@Ð	AÐ	ArP   rß   )r’   rá   râ   s      rM   Ú_raise_cleanup_errorsrå   3  sD   € õ
 ØØðð 
BÐ	A˜^Ð	AÑ	AÔ	Aðð ð ð ð ð rP   Úwin32zFinal[Callable[[str], str]]Ú_resolve_dirÚpathústr | os.PathLike[str]c                óÜ   — t           j                             t          j        | ¦  «        ¦  «        \  }}t           j                             t          |pt           j        ¦  «        |¦  «        S )aÞ  
    Return one stable key for *path*, collapsing equivalent spellings without following a final symlink.

    Relative, absolute, and ``./`` spellings of one lock file must map to a single singleton instance, deadlock-registry
    entry, and removal key. Resolving the whole path with ``realpath`` would follow a final symlink and alias a lock
    target the backend deliberately rejects, so the registry identity would differ from the backend's. Resolving only
    the parent directory and re-appending the literal final component collapses the equivalent spellings while keeping a
    final symlink a distinct key. On Windows the parent is resolved with ``abspath`` so junctions and reparse points are
    not followed either.
    )Úosrè   ÚsplitÚfspathÚjoinrç   Úcurdir)rè   ÚparentÚnames      rM   Ú
_canonicalrò   D  sH   € õ ”7—=’=¥¤¨4¡¤Ñ1Ô1�L€FˆDÝŒ7�<Š<� VÐ%8­r¬yÑ9Ô9¸4Ñ@Ô@Ð@rP   c                  ó    ‡ — e Zd Zdˆ fd„Zˆ xZS )Ú_ThreadLocalRegistryrF   rG   c                óV   •— t          ¦   «                              ¦   «          i | _        d S rI   )ÚsuperÚ__init__Úheld)rL   Ú	__class__s    €rM   r÷   z_ThreadLocalRegistry.__init__T  s$   ø€ Ý‰Œ×ÒÑÔÐØ)+ˆŒ	ˆ	ˆ	rP   rQ   )rR   rS   rT   r÷   Ú__classcell__©rù   s   @rM   rô   rô   S  s=   ø€ € € € € ð,ð ,ð ,ð ,ð ,ð ,ð ,ð ,ð ,ð ,rP   rô   zFinal[_ThreadLocalRegistry]Ú	_registryÚ_TÚBaseFileLock)ÚboundÚ_LockTú0BaseFileLock | ReadWriteLock | SoftReadWriteLockc                  ó^   ‡ — e Zd ZU ded<   ded<   ded<   dedfdd	d
ddddd	ddœ	d+ˆ fd*„Zˆ xZS ),ÚFileLockMetaú&WeakValueDictionary[str, BaseFileLock]Ú
_instancesr   Ú_instances_lockúset[str]Ú_instances_under_constructionr.   TFçš™™™™™©?Nr3   r6   ©	ry   rz   r{   r}   r   r�   r‚   rƒ   r…   Úclsútype[_T]Ú	lock_fileré   rt   rs   rv   ru   rx   rw   ry   rz   r{   r}   r|   r   r~   r�   r€   r‚   rƒ   r…   r„   Úkwargsrn   rF   rý   c       	        óê  •— t          ¦   «          t          ¦   «          t          || | j        ¬¦  «        }t	          |¦  «        }t          |¦  «         t          d|¦  «        }t          || j        ¦  «         t          |	¦  «        }	t          |
¦  «        }
t          || j        | j        ¬¦  «        }t          || j        | j        ¬¦  «        }t          | ||||||||	|
|||dœ|¥¦  «        }|s t!          ¦   «         j        |fi |¤ŽS t%          |¦  «        }| j        5  | j                             |¦  «        x}�t%          |j        ¦  «        |k    rÞ|| j        v rd|›�}t1          |¦  «        ‚| j        }t3          j        ¦   «         }|                     |¦  «         	  t!          ¦   «         j        |fi |¤Ž}|                     |¦  «         n# |                     |¦  «         w xY wt3          j        ¦   «         |k    rd}t1          |¦  «        ‚|| j        |<   ||_        |cd d d ¦  «         S 	 d d d ¦  «         n# 1 swxY w Y   d„ ||                     ¦   «         ft?          |d	¬
¦  «        t?          |j         d	¬
¦  «        f||j!        j"        f||j#        f||j$        f||j%        f|	|j&        f|
|j'        f||j(        f||j)        fdœ
 *                    ¦   «         D ¦   «         }| +                    | ,                    |¦  «        ¦  «         ||j-        u}|s|s|S d}|dz  }| *                    ¦   «         D ]\  }\  }}|d|› d|› d|› d�z  }Œ|r|d|j-        › d|› d�z  }t]          |¦  «        ‚)N©Ú
stacklevelrt   )ÚpreserveÚ	supportedÚcls_name)r  r  )rt   rv   rx   ry   rz   r{   r}   r   r�   r‚   rƒ   r…   z2Singleton lock construction is already active for zOLock construction cannot continue after fork; construct a new lock in the childc                ód   — i | ]-\  }\  }}||k    ¯|t          |¦  «        t          |¦  «        f“Œ.S rJ   )r“   )r¢   rñ   Úpassed_paramÚ	set_params       rM   ú
<dictcomp>z)FileLockMeta.__call__.<locals>.<dictcomp>½  sO   € ð 
ð 
ð 
á/�Ñ/�| Yð  ˜yÒ(Ð(ð# •3�|Ñ$Ô$¥c¨)¡n¤nÐ5ð" )Ð(Ð(rP   T)Úany_negative)
rx   rt   rv   ry   r{   r}   r   r�   r‚   rƒ   zGSingleton lock instances cannot be initialized with differing argumentsz
Non-matching arguments: z
	z (existing lock has z but z was passed)z!
	on_acquired (existing lock has )/Ú_ensure_current_processÚ%_resolve_lazy_imports_before_shutdownÚ_resolve_lifetimeÚ(_constructor_lifetime_warning_stacklevelÚ_resolve_poll_intervalÚ_check_blockingÚ_secondsÚ_check_moderR   Ú_resolve_context_error_policyÚ_resolve_close_error_policyÚ_resolve_preserve_lock_fileÚ_preserve_lock_file_supportedÚ_resolve_on_acquiredÚ_on_acquired_supportedÚ_supported_init_paramsrö   rg   rò   r  r  ÚgetÚ
_lock_pathr  ÚRuntimeErrorrë   Úgetpidr«   ÚdiscardÚ_singleton_keyÚis_thread_localÚ_timeout_behaviorrt   Ú_contextrv   ry   r{   r}   r   r�   r‚   rƒ   ÚitemsÚupdateÚ_singleton_extra_mismatchesr…   Ú
ValueError)r  r  rt   rv   rx   ry   rz   r{   r}   r   r�   r‚   rƒ   r…   r  ÚparamsÚsingleton_keyÚinstanceÚmsgÚconstruction_registryÚconstruction_pidÚnon_matching_paramsÚhook_mismatchÚ
param_namer  r  rù   s                             €rM   rg   zFileLockMeta.__call__e  s¯  ø€ õ$ 	 Ñ!Ô!Ð!Ý-Ñ/Ô/Ð/Ý$ X¨s¸sÔ?kÐlÑlÔlˆÝ.¨}Ñ=Ô=ˆõ 	˜Ñ!Ô!Ð!å˜9 gÑ.Ô.ˆÝ�D˜#œ,Ñ'Ô'Ð'Ý<Ð=QÑRÔRÐÝ8Ð9KÑLÔLÐÝ8Ø'°3Ô3TÐ_bÔ_kð
ñ 
ô 
Ðõ +¨;À#ÔB\ÐgjÔgsÐtÑtÔtˆå.Øà"ØØ ,Ø$Ø ,Ø!.Ø$Ø(<Ø&8Ø$4Ø&8Ø*ðð ð ðñ
ô 
ˆð$ ð 	9Ø#•5‘7”7Ô# IÐ8Ð8°Ð8Ð8Ð8õ # 9Ñ-Ô-ˆØÔ ð 	 ð 	 ð  œN×.Ò.¨}Ñ=Ô=Ð=�ÐFÍ*ØÔ#ñKô KàòKð Kð ! CÔ$EÐEÐEØ\ÈyÐ\Ð\�CÝ& sÑ+Ô+Ð+Ø(+Ô(IÐ%Ý#%¤9¡;¤;Ð Ø%×)Ò)¨-Ñ8Ô8Ð8ðAØ/�u™wœwÔ/°	ÐDÐD¸VÐDÐD�Hà)×1Ò1°-Ñ@Ô@Ð@Ð@øÐ)×1Ò1°-Ñ@Ô@Ð@Ð@øøøÝ”9‘;”;Ð"2Ò2Ð2Øk�CÝ& sÑ+Ô+Ð+Ø08�”˜}Ñ-Ø*7�Ô'Øð-	 ð 	 ð 	 ð 	 ñ 	 ô 	 ð 	 ð 	 ðKð		 ð 	 ð 	 ñ 	 ô 	 ð 	 ð 	 ð 	 ð 	 ð 	 ð 	 øøøð 	 ð 	 ð 	 ð 	 ð0
ð 
ð ".¨x×/GÒ/GÑ/IÔ/IÐ Jõ & g¸DÐAÑAÔAÝ% hÔ&6ÀTÐJÑJÔJðð ˜xÔ0Ô5Ð6Ø% xÔ'8Ð9Ø"/°Ô1GÐ!HØ% xÔ'8Ð9Ø)=¸xÔ?\Ð(]Ø'9¸8Ô;VÐ&WØ%5°xÔ7PÐ$QØ'9¸8Ô;VÐ&Wð4ð 4÷ Še‰gŒgð#
ñ 
ô 
Ðð* 	×"Ò" 8×#GÒ#GÈÑ#OÔ#OÑPÔPÐPð $¨8Ô+?Ð?ˆØ"ð 	¨=ð 	ØˆOàWˆØÐ+Ñ+ˆØ5H×5NÒ5NÑ5PÔ5Pð 	eð 	eÑ1ˆJÑ1˜ yØÐd˜*ÐdÐd¸)ÐdÐdÈ,ÐdÐdÐdÑdˆCˆCØð 	nØÐm¸Ô9MÐmÐmÐT_ÐmÐmÐmÑmˆCÝ˜‰oŒoÐs+   ÄBH?Æ!GÆ;H?ÇG(Ç(=H?È?IÉI) r  r  r  ré   rt   rs   rv   ru   rx   rw   ry   rw   rz   rw   r{   rs   r}   r|   r   r~   r�   r€   r‚   rw   rƒ   rw   r…   r„   r  rn   rF   rý   )rR   rS   rT   rˆ   r/   rg   rú   rû   s   @rM   r  r  `  s§   ø€ € € € € € Ø6Ð6Ð6Ñ6ØÐÐÑØ+Ð+Ð+Ñ+ð
 Ø$Ø!ðzð Ø"Ø#Ø!%Ø3:Ø/8Ø!%Ø#(Ø48ðzð zð zð zð zð zð zð zð zð zð zð zrP   r  r}   r|   r  útype[BaseFileLock]r  ru   c               óÞ  — | €dS t          | t          ¦  «        st          | t          ¦  «        st          d| ¦  «        } | dk     s)t          | t          ¦  «        r(t          j        | ¦  «        sd| ›�}t          |¦  «        ‚|j        s)t          j
        d|j        › d|j        › d�|¬¦  «         dS |j        �4|j        \  }}t          j
        |j        › d	|› d
|› d�t          |¬¦  «         | S )ar  
    Validate ``lifetime`` and drop a value the backend cannot honor.

    ``lifetime`` is a deliberate age-based lease: a lock file older than ``lifetime`` is broken even while its holder is
    still alive. Existence locks (:class:`SoftFileLock`) implement that behavior by unlinking a reclaimable pathname,
    which can overlap a live holder. A native OS lock lives on the inode, so unlinking the pathname by age cannot revoke
    the kernel lock; a contender would lock a fresh inode and overlap the live holder (#590). Ignore the request with a
    warning rather than accept a setting that breaks mutual exclusion.
    Nr}   r   z.lifetime must be finite and non-negative, not zlifetime is ignored for z: z2; only SoftFileLock supports lifetime-based expiryr  zH(lifetime=...) uses age-based expiry and can overlap a live holder; use z for expiry or z for fail-closed locking)r�   rw   ru   r   rs   r   Úisfiniter5  Ú_lifetime_supportedr   ÚwarnrR   Ú_lifetime_unsupported_reasonÚ_lifetime_replacementsr+   )r}   r  r  r9  Ústrict_lockÚleases         rM   r  r  â  sK  € ð ÐØˆtå�(�DÑ!Ô!ð 2­°H½cÑ)BÔ)Bð 2Ý˜J¨Ñ1Ô1ˆØ�!‚|€|�
 8­UÑ3Ô3€|½D¼MÈ(Ñ<SÔ<S€|ØK¸xÐKÐKˆÝ˜‰oŒoÐØÔ"ð ÝŒð@ s¤|ð @ð @°sÔ7Wð @ð @ð @à!ð	
ñ 	
ô 	
ð 	
ð
 ˆtØ
Ô!Ð-Ø Ô7Ñˆ�UÝŒØŒ|ð Oð OØðOð OØ)4ðOð Oð Oå'Ø!ð		
ñ 	
ô 	
ð 	
ð €OrP   r{   rs   c                ó¢   — t          d| ¦  «        x} dk     st          j        | ¦  «        sd| ›�}t          |¦  «        ‚t	          d| ¦  «         | S )zOValidate ``poll_interval`` used for ``time.sleep`` / ``asyncio.sleep`` retries.r{   r   z3poll_interval must be finite and non-negative, not )r   r   rA  r5  Ú_check_timeout_max)r{   r9  s     rM   r  r    s[   € å! /°=ÑAÔAÐAˆÀQÒFÐFÍdÌmÐ\iÑNjÔNjÐFØUÀMÐUÐUˆÝ˜‰oŒoÐÝ�¨Ñ6Ô6Ð6ØÐrP   ry   c                ó|   — t          | t          ¦  «        s&dt          | ¦  «        j        › �}t	          |¦  «        ‚d S )Nzblocking must be a bool, not )r�   rw   r¹   rR   Ú	TypeError)ry   r9  s     rM   r  r    s@   € Ý�h¥Ñ%Ô%ð ØG­d°8©n¬nÔ.EÐGÐGˆÝ˜‰nŒnÐðð rP   rñ   Úvaluec                óÐ  — t          |t          ¦  «        st          |t          t          f¦  «        s(| › dt	          |¦  «        j        › �}t          |¦  «        ‚t          |t          ¦  «        r |                     ¦   «         rt          j	        S 	 t          |¦  «        }n%# t          $ r | › d|›�}t          |¦  «        d ‚w xY w|dk    r|dk     rt          j        d¦  «         n|S )Nz" must be a number of seconds, not z) is too large to be a number of seconds: r   ç        )r�   rw   r   r   r¹   rR   rK  Úis_snanr   Únanrs   ÚOverflowErrorr5  Úulp)rñ   rL  r9  Úsecondss       rM   r   r     sí   € å�%�ÑÔð ¥j°½½w¸Ñ&HÔ&Hð ØÐOÐO½¸e¹¼Ô9MÐOÐOˆÝ˜‰nŒnÐå�%�Ñ!Ô!ð  e§m¢m¡o¤oð ÝŒxˆð(Ý˜u™œˆˆøÝð (ð (ð (ØÐIÐIÀÐIÐIˆÝ˜‰oŒo 4Ð'ð(øøøð %¨š\˜\¨e°aªi¨i�DŒH�S‰MŒMˆ>ˆ>¸WÐDs   ÂB  Â "Crv   r  c                ó‚  — | t           k    rd S t          | t          ¦  «        st          | t          ¦  «        s&dt	          | ¦  «        j        › �}t          |¦  «        ‚d| cxk    rt          k    sn d| d›d|› �}t          |¦  «        ‚|  t          j
        t          j        z  z  rd| d›d|› �}t          |¦  «        ‚d S )Nzmode must be an int, not r   zmode=z#oz  must be within 0o000-0o777 for z) must grant the owner read and write for )r/   r�   rw   ru   r¹   rR   rK  r0   r5  ÚstatÚS_IRUSRÚS_IWUSR)rv   r  r9  s      rM   r!  r!  &  sä   € ØÕÒÐØˆÝ�$�ÑÔð ¥Z°µcÑ%:Ô%:ð Ø?­$¨t©*¬*Ô*=Ð?Ð?ˆÝ˜‰nŒnÐà�Ð(Ð(Ò(Ð(Õ(Ò(Ð(Ð(Ð(ØI�dÐIÐIÐI¸xÐIÐIˆÝ˜‰oŒoÐð 	€u•”�tœ|Ñ+Ñ,ð ØR�dÐRÐRÐRÈÐRÐRˆÝ˜‰oŒoÐðð rP   Úpolicyr~   c                ó\   — | t           vrd| ›�}t          |¦  «        ‚t          d| ¦  «        S )Nz5context_error_policy must be 'chain' or 'group', got r~   )r5   r5  r'   ©rX  r9  s     rM   r"  r"  7  s8   € ØÕ,Ð,Ð,ØPÀfÐPÐPˆÝ˜‰oŒoÐÝÐ$ fÑ-Ô-Ð-rP   r€   c                ó\   — | t           vrd| ›�}t          |¦  «        ‚t          d| ¦  «        S )NzBclose_error_policy must be 'default', 'raise', or 'suppress', got r€   )r9   r5  r'   rZ  s     rM   r#  r#  >  s9   € ØÕ*Ð*Ð*Ø]ÐSYÐ]Ð]ˆÝ˜‰oŒoÐÝÐ" FÑ+Ô+Ð+rP   r  r  c                ó8   — | r|sd|› d�}t          |¦  «        ‚| S )Nz,preserve_lock_file=True is not supported by z): unlinking its marker is how it releases©r5  )r  r  r  r9  s       rM   r$  r$  E  s4   € ð ð ˜	ð Øp¸XÐpÐpÐpˆÝ˜‰oŒoÐØ€OrP   r…   r„   c               ó<   — | €d S |sd|› d�}t          |¦  «        ‚| S )Nz on_acquired is not supported by z.: only native locks expose the lock descriptorr]  )r…   r  r  r9  s       rM   r&  r&  N  s;   € ð ÐØˆtð ð Øi°ÐiÐiÐiˆÝ˜‰oŒoÐØÐrP   r6  ú'dict[str, _LockInitValue | _ExtraValue]c                ó2  ‡‡— t          | ¦  «        xŠj        r|S t          ˆˆfd„|                     ¦   «         D ¦   «         ¦  «        x}r.| j        › dd                     |¦  «        › �}t          |¦  «        ‚ˆfd„|                     ¦   «         D ¦   «         S )Nc              3  ó‚   •K  — | ]9\  }}|‰j         vr+‰j                             |¦  «        xŠ�|‰j        k    ¯5|V — Œ:d S rI   )Úaccepted_paramsÚdefault_paramsr)  r6   )r¢   rñ   rL  ÚmodelÚ	parameters      €€rM   r¥   z)_supported_init_params.<locals>.<genexpr>`  sn   øè è € ð ð áˆD�%Ø�uÔ,Ð,Ð,Ø Ô/×3Ò3°DÑ9Ô9Ð9ˆiÐBÀeÈyÔO`ÒF`ÐF`ð 	ð GaÐF`ÐF`ÐF`ð	ð rP   z, does not support non-default lock options: z, c                ó.   •— i | ]\  }}|‰j         v ¯||“ŒS rJ   )rb  )r¢   rñ   rL  rd  s      €rM   r  z*_supported_init_params.<locals>.<dictcomp>i  s,   ø€ Ð[Ð[Ð[™K˜D %¸TÀUÔEZÐ=ZÐ=ZˆD�%Ð=ZÐ=ZÐ=ZrP   )Ú_init_parameter_modelÚaccepts_kwargsÚsortedr2  rR   rî   rK  )r  r6  Úunsupportedr9  rd  re  s       @@rM   r(  r(  [  sÁ   øø€ õ ' sÑ+Ô+Ð+ˆÔ;ð ØˆÝð ð ð ð ð à!Ÿ<š<™>œ>ðñ ô ñ ô ð €{ð ð ”ÐcÐcÈ4Ï9Ê9ÐU`ÑKaÔKaÐcÐcˆÝ˜‰nŒnÐà[Ð[Ð[Ð[¨6¯<ª<©>¬>Ð[Ñ[Ô[Ð[rP   rt   r  úfloat | strc               óf   — t          j        | ¦  «        rdS | t           j        k    s|r| dk     rdn| S )NrP  r   g      ð¿)r   ÚisnanÚinf)rt   r  s     rM   r0  r0  l  s<   € å„z�'ÑÔð ØˆuØ�dœhÒ&Ð&¨<Ð&¸GÀaºK¸Kˆ4ˆ4ÈgÐUrP   c                óX   — |t           k    r| › dt           › d|›�}t          |¦  «        ‚d S )Nz( must not exceed threading.TIMEOUT_MAX (z), got )r   r5  )rñ   rL  r9  s      rM   rI  rI  s  s=   € à�{ÒÐØÐ\Ð\½{Ð\Ð\ÐSXÐ\Ð\ˆÝ˜‰oŒoÐð ÐrP   zAFinal[WeakKeyDictionary[type[BaseFileLock], _InitParameterModel]]Ú_INIT_PARAMETER_MODELSÚ_InitParameterModelc                ón  — t          ¦   «         5  t          j        5  t                               | ¦  «        x}€¿t          j        | j        ¦  «        j         	                    ¦   «         }t          t          d„ |D ¦   «         ¦  «        t          d„ |D ¦   «         ¦  «        d„ t          j        t          | ¦  «        j        ¦  «        j                             ¦   «         D ¦   «         ¬¦  «        }|t          | <   |cd d d ¦  «         cd d d ¦  «         S # 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nc              3  óv   K  — | ]4}|j         t          j        j        t          j        j        hv ¯+|j        V — Œ5d S rI   )Úkindr   Ú	ParameterÚPOSITIONAL_OR_KEYWORDÚKEYWORD_ONLYrñ   ©r¢   re  s     rM   r¥   z(_init_parameter_model.<locals>.<genexpr>ƒ  sO   è è € ð *ð *à!Ø ”~­'Ô*;Ô*QÕSZÔSdÔSqÐ)rÐrÐrð ”NàrÐrÐrÐrð*ð *rP   c              3  óF   K  — | ]}|j         t          j        j        u V — Œd S rI   )rt  r   ru  ÚVAR_KEYWORDrx  s     rM   r¥   z(_init_parameter_model.<locals>.<genexpr>ˆ  s0   è è € Ð"oÐ"oÐW` 9¤>µWÔ5FÔ5RÐ#RÐ"oÐ"oÐ"oÐ"oÐ"oÐ"orP   c                óJ   — i | ] \  }}|j         t          j        j        u¯||“Œ!S rJ   )r6   r   ru  Úempty)r¢   rñ   re  s      rM   r  z)_init_parameter_model.<locals>.<dictcomp>‰  s<   € ð  ð  ð  á'˜˜iØ Ô(µÔ0AÔ0GÐGÐGð ˜)àGÐGÐGrP   )rb  rh  rc  )Ú_fork_transitionÚ_FORK_STATEÚparameter_models_lockrp  r)  r   Ú	signaturer÷   Ú
parametersÚvaluesrq  Ú	frozensetr®   r¹   rg   r2  )r  rd  r�  s      rM   rg  rg  }  sÚ  € å	Ñ	Ô	ð ð �[Ô>ð ð Ý+×/Ò/°Ñ4Ô4Ð4ˆEÐ=Ý Ô*¨3¬<Ñ8Ô8ÔC×JÒJÑLÔLˆJÝ'Ý )ð *ð *à%/ð*ñ *ô *ñ !ô !õ
  #Ð"oÐ"oÐdnÐ"oÑ"oÔ"oÑoÔoð ð  å+2Ô+<½TÀ#¹Y¼YÔ=OÑ+PÔ+PÔ+[×+aÒ+aÑ+cÔ+cð ñ  ô  ðñ ô ˆEð +0Õ" 3Ñ'Øð#ð ð ð ñ ô ð ð ð ð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð ð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð s5   �D*œCDÃ9D*ÄD	ÄD*ÄD	ÄD*Ä*D.Ä1D.T)Úfrozenc                  ó.   — e Zd ZU ded<   ded<   ded<   dS )rq  úfrozenset[str]rb  rw   rh  zdict[str, inspect.Parameter]rc  N©rR   rS   rT   rˆ   rJ   rP   rM   rq  rq  “  s6   € € € € € € à#Ð#Ð#Ñ#ØÐÐÑØ0Ð0Ð0Ñ0Ð0Ð0rP   c                  óè  ‡ — e Zd ZU dZded<   ded<   ded<   dZd	ed
<   dZded<   dZded<   dZd	ed<   dZ	ded<   dZ
ded<   dZded<   dZded<   dZded<   d¤ˆ fd"„Zed¥d#„¦   «         Zd$edfddd%dd&d'dddd(œ	d¦d;„Zd§d?„Zd¨d@„Zed¨dA„¦   «         Zed©dB„¦   «         ZedªdC„¦   «         Zd«dF„Zd¬dG„Zed¨dH„¦   «         Zed¨dI„¦   «         Zed­dJ„¦   «         Zed®dK„¦   «         Zed®dL„¦   «         Zed¯dM„¦   «         Z e j!        d°dP„¦   «         Z ed¨dQ„¦   «         Z"e"j!        d±dR„¦   «         Z"ed¯dS„¦   «         Z#e#j!        d²dT„¦   «         Z#ed³dU„¦   «         Z$e$j!        d´dV„¦   «         Z$edµdW„¦   «         Z%ed¨dX„¦   «         Z&dµdY„Z'ed¨dZ„¦   «         Z(edµd[„¦   «         Z)d¶d]„Z*d·dd„Z+d¸df„Z,d¥dg„Z-d¥dh„Z.d¥di„Z/	 	 d¹ddddjœdºdp„Z0e1j2        d»ds„¦   «         Z3d¼d½du„Z4d½dv„Z5d¥dw„Z6d¾dy„Z7d¿d{„Z8d¥d|„Z9dÀdÁd„Z:dÀdÁd€„Z;d¥d�„Z<d¥d‚„Z=dÂd„„Z>dÃd†„Z?dÄdˆ„Z@eAdÅdŠ„¦   «         ZBdÆd‹„ZCdÇd�„ZDdÈdŽ„ZEd¥d�„ZFd¥d�„ZGdÉd“„ZHdÊd•„ZId¥d–„ZJd¥d—„ZKd¥d˜„ZLd¥d™„ZMd¥dš„ZNdÈd›„ZOdÈdœ„ZPd¥d�„ZQd¥dž„ZRd¥dŸ„ZSdËd „ZTdÌd¡„ZUeVd¥d¢„¦   «         ZWeVd¥d£„¦   «         ZXˆ xZYS )Írþ   a;  
    Abstract base class for a file lock object.

    Provides the common reentrant API and state management. Subclasses implement the locking mechanism
    (:class:`UnixFileLock <filelock.UnixFileLock>`, :class:`WindowsFileLock <filelock.WindowsFileLock>`,
    :class:`SoftFileLock <filelock.SoftFileLock>`).

    r  r  r   r  r  r  z FileLock instance in this threadr“   Ú_deadlock_holder_descFrw   rB  Nztuple[str, str] | NonerE  z4a native OS lock cannot be broken safely by file agerD  é   ru   r  Tr%  r'  rN  rs   Ú_poll_backoff_capú
str | Noner.  r  rp   rF   rG   c                óÊ   •—  t          ¦   «         j        di |¤Ž t          ¦   «         | _        t	          ¦   «         | _        t          ¦   «         | _        t          | ¦  «         dS )z<Give each lock subclass its own singleton registry and lock.NrJ   )	rö   Ú__init_subclass__r)   r  r   r  r§   r  Ú_register_fork_class)r  r  rù   s     €rM   rŽ  zBaseFileLock.__init_subclass__Ç  sY   ø€ à!�‰ŒÔ!Ð+Ð+ FÐ+Ð+Ð+Ý,Ñ.Ô.ˆŒÝ#™gœgˆÔÝ,/©E¬EˆÔ)Ý˜SÑ!Ô!Ð!Ð!Ð!rP   c                óx   — t          ¦   «         | _        t          ¦   «         | _        t	          ¦   «         | _        d S rI   )r)   r  r   r  r§   r  ©r  s    rM   r^   z$BaseFileLock._reset_class_after_forkÏ  s-   € å,Ñ.Ô.ˆŒÝ#™gœgˆÔÝ,/©E¬EˆÔ)Ð)Ð)rP   r.   r	  r3   r6   r
  r  ré   rt   rv   rx   ry   rz   r{   r}   r|   r   r~   r�   r€   r‚   rƒ   r…   r„   c       	        óŒ  — t          j        ¦   «         | _        t          | ¦  «        | _        t          ¦   «         | _        || _        || _        |	| _	        |
| _
        || _        || _        || _         |rt          nt          t          j        |¦  «        |||||¬¦  «        | _        i | _        i | _        t)          | ¦  «         dS )a’  
        Create a new lock object.

        :param lock_file: path to the file
        :param timeout: default timeout when acquiring the lock, in seconds. It will be used as fallback value in the
            acquire method, if no timeout value (``None``) is given. If you want to disable the timeout, set it to a
            negative value or ``inf``. A timeout of 0 means that there is exactly one attempt to acquire the file lock.
        :param mode: file permissions for the lockfile. When not specified, the OS controls permissions via umask and
            default ACLs, preserving POSIX default ACL inheritance in shared directories. Construction raises
            :class:`ValueError` unless it grants the owner read and write, which the lock needs for its own files. On
            Windows a native lock creates its file with an owner-only ACL when the mode has no group and other bits; any
            other mode, and a soft lock, leave the file the ACL its directory hands down. A Unix lock file that already
            exists keeps its permissions.
        :param thread_local: Whether this object's internal context should be thread local or not. If this is set to
            ``False`` then the lock will be reentrant across threads. When ``True`` (the default), **all fields of the
            lock's internal context are per-thread**, including the configuration values ``poll_interval``, ``timeout``,
            ``blocking``, ``mode``, and ``lifetime``. Setting one of these properties from one thread does not change
            the value seen by another thread; threads that did not perform the write continue to see the value supplied
            at construction time. ``mode`` has no setter, so construction is the only place it is ever set. If you need
            configuration values to be visible across threads, construct the lock with ``thread_local=False``.
        :param blocking: whether the lock should be blocking or not
        :param is_singleton: If this is set to ``True`` then only one instance of this class will be created per lock
            file. This is useful if you want to use the lock object for reentrant locking without needing to pass the
            same object around.
        :param poll_interval: default interval for polling the lock file, in seconds. It will be used as fallback value
            in the acquire method, if no poll_interval value (``None``) is given.
        :param lifetime: for :class:`SoftFileLock`, the age in seconds after which a waiting process may delete the
            marker, even while its holder remains alive. This legacy expiry mode does not provide strict mutual
            exclusion. ``None`` (the default) disables age-based expiry. Native OS locks (:class:`FileLock`) cannot be
            revoked by file age and ignore a non-``None`` ``lifetime`` with a warning.
        :param context_error_policy: how a context manager reconciles a failure in its body with a failure while
            releasing on exit. ``"chain"`` (the default) keeps Python's behavior: the release error propagates with the
            body error in its ``__context__``. ``"group"`` raises a :class:`BaseExceptionGroup` holding the body error
            first and the release error second, so neither hides the other.
        :param close_error_policy: what to do with an ``os.close`` failure after relinquishing descriptor ownership.
            ``"default"`` keeps each backend's historical behavior (Unix native locks drop a FUSE/Docker ``EIO``;
            Windows native locks and :class:`SoftFileLock` propagate); ``"raise"`` always propagates the ``OSError``;
            ``"suppress"`` always ignores it. Held state is released either way. It does not affect unlock failures or
            lock-file deletion.
        :param fallback_to_soft: for :class:`UnixFileLock`, whether to switch to :class:`SoftFileLock` when the
            filesystem's ``flock`` returns ``ENOSYS``. ``True`` (the default) keeps the historical fallback;
            ``False`` fails closed, letting the ``ENOSYS`` propagate so a caller that needs kernel-enforced
            locking is never silently downgraded. It has no effect on Windows or :class:`SoftFileLock`.
        :param preserve_lock_file: for native locks (:class:`FileLock`), whether filelock promises not to unlink the
            lock pathname on release. ``False`` (the default) keeps each backend's cleanup: Windows removes the lock
            file, Unix already leaves it. ``True`` keeps a stable file identity for ACLs, auditing, and holder metadata:
            Windows skips its post-release unlink and Unix refuses to enter the ``ENOSYS`` soft fallback (which releases
            by unlinking). :class:`SoftFileLock` rejects ``True``. The promise covers filelock's own release path only;
            it cannot stop another process or the filesystem from removing the pathname.
        :param on_acquired: for native locks (:class:`FileLock`), a callable invoked with the borrowed lock descriptor
            once per physical acquisition, after filelock holds the native lock and finished backend initialization but
            before :meth:`~BaseFileLock.acquire` returns. Recursive acquisitions do not call it again. The callback may
            read, write, seek, truncate, or set metadata through ``os`` on the descriptor, but must not close, unlock,
            or take ownership of it, and filelock does not fsync its writes. If it raises, filelock releases the lock
            and re-raises. :class:`SoftFileLock` rejects the hook.

        :raises TypeError: if *timeout* or *poll_interval* is a :class:`bool` or not a real number, *blocking* is not a
            :class:`bool`, or *mode* is not an :class:`int`
        :raises ValueError: if *poll_interval* is negative, not finite, or above :data:`threading.TIMEOUT_MAX`, if
            *timeout* is too large to convert to :class:`float`, or if *mode* falls outside ``0o000``-``0o777`` or
            denies the owner read and write

        ©r  rt   rv   ry   r{   r}   N)rë   r,  Ú_creator_pidrª   Ú
_holder_idr   Ú_transition_lockÚ_is_thread_localÚ_is_singletonÚ_context_error_policyÚ_close_error_policyÚ_fallback_to_softÚ_preserve_lock_fileÚ_on_acquiredÚThreadLocalFileContextÚFileLockContextrí   r1  Ú_thread_holdsÚ_thread_pendingÚ_register_fork_object)rL   r  rt   rv   rx   ry   rz   r{   r}   r   r�   r‚   rƒ   r…   s                 rM   r÷   zBaseFileLock.__init__Õ  sÌ   € õ` œI™KœKˆÔå˜T™(œ(ˆŒÝ %¡¤ˆÔØ ,ˆÔØ)ˆÔØ%9ˆÔ"Ø#5ˆÔ Ø!1ˆÔØ#5ˆÔ Ø'ˆÔà*eÀLÐ*eÕ*@Ð*@ÕVeÝ”i 	Ñ*Ô*ØØØØ'Øð*
ñ *
ô *
ˆŒð IKˆÔàJLˆÔÝ˜dÑ#Ô#Ð#Ð#Ð#rP   Ú_kwargsúMapping[str, _ExtraValue]údict[str, tuple[str, str]]c               ó   — i S rI   rJ   )rL   r£  s     rM   r4  z(BaseFileLock._singleton_extra_mismatches?  s	   € ð
 ˆ	rP   c                ó   — | j         S )z?:returns: a flag indicating if this lock is thread local or not)r—  rK   s    rM   r/  zBaseFileLock.is_thread_localF  s   € àÔ$Ð$rP   c                ó   — | j         S )zh
        A flag indicating if this lock is singleton or not.

        .. versionadded:: 3.13.0

        )r˜  rK   s    rM   rz   zBaseFileLock.is_singletonJ  s   € ð Ô!Ð!rP   c                ó   — | j         S )z„
        How a context manager reconciles a body failure with a release failure on exit.

        .. versionadded:: 3.30.0

        )r™  rK   s    rM   r   z!BaseFileLock.context_error_policyT  s   € ð Ô)Ð)rP   c                ó   — | j         S )zŒ
        What a lock does with an ``os.close`` failure after relinquishing descriptor ownership.

        .. versionadded:: 3.30.0

        ©rš  rK   s    rM   r�   zBaseFileLock.close_error_policy^  s   € ð Ô'Ð'rP   ÚfdÚdefault_suppressesc               ó€   — 	 t          j        |¦  «         d S # t          $ r |                      |¬¦  «        s‚ Y d S w xY w)N)r­  )rë   ÚcloseÚOSErrorÚ_suppresses_close_error)rL   r¬  r­  s      rM   Ú_close_released_fdzBaseFileLock._close_released_fdh  s_   € ð	ÝŒH�R‰LŒLˆLˆLˆLøÝð 	ð 	ð 	Ø×/Ò/ÐCUÐ/ÑVÔVð Øðð ð ð	øøøs   ‚ ˜!=¼=c               ó2   — | j         dk    p| j         dk    o|S )Nr8   r6   r«  )rL   r­  s     rM   r±  z$BaseFileLock._suppresses_close_errorq  s$   € ØÔ'¨:Ò5Ðw¸$Ô:RÐV_Ò:_Ð:vÐdvÐwrP   c                ó   — | j         S )a:  
        Whether a :class:`FileLock` falls back to :class:`SoftFileLock` when the filesystem lacks ``flock``.

        Only :class:`UnixFileLock` acts on it: when ``False`` an ``ENOSYS`` from ``flock`` propagates instead of
        switching to existence-lock semantics.

        .. versionadded:: 3.30.0

        )r›  rK   s    rM   r‚   zBaseFileLock.fallback_to_softt  s   € ð Ô%Ð%rP   c                ó   — | j         S )aG  
        Whether filelock promises not to unlink the lock pathname on release.

        When ``True``, Windows skips its post-release unlink and Unix refuses the ``ENOSYS`` soft fallback.
        :class:`SoftFileLock` rejects ``True`` because unlinking its marker is how it releases.

        .. versionadded:: 3.30.0

        )rœ  rK   s    rM   rƒ   zBaseFileLock.preserve_lock_file�  s   € ð Ô'Ð'rP   c                ó   — | j         S )av  
        The callback run with the borrowed lock descriptor once per physical acquisition, or ``None``.

        Native locks only. It runs after the native lock is held and backend initialization finished, before
        :meth:`~BaseFileLock.acquire` returns; a raise rolls back the acquisition. :class:`SoftFileLock` rejects it.

        .. versionadded:: 3.30.0

        )r�  rK   s    rM   r…   zBaseFileLock.on_acquiredŽ  s   € ð Ô Ð rP   c                ó   — | j         j        S )zPath to the lock file.)r1  r  rK   s    rM   r  zBaseFileLock.lock_file›  s   € ð Œ}Ô&Ð&rP   c                ó2   — | j         j        p| j         j        S rI   )r1  Ú
claim_rootr  rK   s    rM   r*  zBaseFileLock._lock_path   s   € ð Œ}Ô'ÐB¨4¬=Ô+BÐBrP   c                ó   — | j         j        S )zZ
        The default timeout value, in seconds.

        .. versionadded:: 2.0.0

        )r1  rt   rK   s    rM   rt   zBaseFileLock.timeout¦  s   € ð Œ}Ô$Ð$rP   rL  úfloat | str | bytes | bytearrayc                óÔ   — t          |t          t          t          f¦  «        r+t	          j        dt          d¬¦  «         t          |¦  «        }t          d|¦  «        | j	        _
        dS )a˜  
        Change the default timeout value.

        :param value: the new value, in seconds; a negative value or ``inf`` waits without a limit

        :raises TypeError: if *value* is a :class:`bool` or not a real number
        :raises ValueError: if *value* is too large to convert to :class:`float`

        .. deprecated:: 4.0.13

            Passing a numeric string; pass the number instead.

        zNsetting timeout from a string is deprecated and will be removed; pass a numberé   r  rt   N)r�   r“   ÚbytesÚ	bytearrayr   rC  ÚDeprecationWarningrs   r   r1  rt   ©rL   rL  s     rM   rt   zBaseFileLock.timeout°  sf   € õ �e�c¥5­)Ð4Ñ5Ô5ð 	!ÝŒMØ`Ý"Øðñ ô ð õ
 ˜%‘L”LˆEÝ (¨°EÑ :Ô :ˆŒÔÐÐrP   c                ó   — | j         j        S )z\
        Whether the locking is blocking or not.

        .. versionadded:: 3.14.0

        )r1  ry   rK   s    rM   ry   zBaseFileLock.blockingÈ  s   € ð Œ}Ô%Ð%rP   c                ó<   — t          |¦  «         || j        _        dS )z—
        Change the default blocking value.

        :param value: the new value as bool

        :raises TypeError: if *value* is not a bool

        N)r  r1  ry   rÁ  s     rM   ry   zBaseFileLock.blockingÒ  s"   € õ 	˜ÑÔÐØ!&ˆŒÔÐÐrP   c                ó   — | j         j        S )z^
        The default polling interval, in seconds.

        .. versionadded:: 3.24.0

        )r1  r{   rK   s    rM   r{   zBaseFileLock.poll_intervalß  s   € ð Œ}Ô*Ð*rP   c                ó8   — t          |¦  «        | j        _        dS )a  
        Change the default polling interval.

        :param value: the new value, in seconds

        :raises ValueError: if *value* is negative, not finite, or above :data:`threading.TIMEOUT_MAX`
        :raises TypeError: if *value* is a :class:`bool` or not a real number

        N)r  r1  r{   rÁ  s     rM   r{   zBaseFileLock.poll_intervalé  s   € õ '=¸UÑ&CÔ&CˆŒÔ#Ð#Ð#rP   c                ó   — | j         j        S )aY  
        The soft marker age in seconds that permits expiry, or ``None`` to disable age-based expiry.

        A non-``None`` value permits a waiter to enter while the previous holder remains active, so it does not provide
        strict mutual exclusion. Native locks ignore the value with a warning.

        .. versionadded:: 3.24.0

        )r1  r}   rK   s    rM   r}   zBaseFileLock.lifetimeö  s   € ð Œ}Ô%Ð%rP   c                óX   — t          |t          | ¦  «        d¬¦  «        | j        _        dS )a!  
        Change the legacy age-based expiry threshold.

        :param value: the new value in seconds, or ``None`` to disable expiration

        :raises ValueError: if *value* is negative or not finite
        :raises TypeError: if *value* is not ``None`` and not a real number

        rŠ  r  N)r  r¹   r1  r}   rÁ  s     rM   r}   zBaseFileLock.lifetime  s*   € õ "3°5½$¸t¹*¼*ÐQRÐ!SÑ!SÔ!SˆŒÔÐÐrP   c                óH   — | j         j        t          k    rdn| j         j        S )a¡  
        The file permissions requested for the lock file.

        Without an explicit ``mode`` this reports ``0o644`` for backwards compatibility, but the file is created with
        ``0o666`` filtered through the umask and default ACLs, so with a ``002`` umask it ends up ``0o664``. Check
        :attr:`has_explicit_mode` before relying on the value, or ``os.stat`` the file for its actual permissions.

        i¤  ©r1  rv   r/   rK   s    rM   rv   zBaseFileLock.mode  s#   € ð œÔ*Õ.>Ò>Ð>ˆuˆuÀDÄMÔDVÐVrP   c                ó,   — | j         j        t          k    S )z1Whether the file permissions were explicitly set.rÉ  rK   s    rM   Úhas_explicit_modezBaseFileLock.has_explicit_mode  s   € ð Œ}Ô!Õ%5Ò5Ð5rP   c                óH   — | j         j        t          k    rdn| j         j        S )z]Mode for ``os.open``: 0o666 when unset so umask and ACLs decide, otherwise the explicit mode.i¶  rÉ  rK   s    rM   Ú
_open_modezBaseFileLock._open_mode!  s!   € àœÔ*Õ.>Ò>Ð>ˆuˆuÀDÄMÔDVÐVrP   c                ó:   — t          ¦   «          | j        j        duS )z»
        A boolean indicating if the lock file is holding the lock currently.

        .. versionchanged:: 2.0.0

            This was previously a method and is now a property.

        N)r  r1  Úlock_file_fdrK   s    rM   Ú	is_lockedzBaseFileLock.is_locked%  s    € õ 	 Ñ!Ô!Ð!ØŒ}Ô)°Ð5Ð5rP   c                ó6   — t          ¦   «          | j        j        S )zGThe number of times this lock has been acquired (but not yet released).)r  r1  Úlock_counterrK   s    rM   rÒ  zBaseFileLock.lock_counter2  s   € õ 	 Ñ!Ô!Ð!ØŒ}Ô)Ð)rP   rh   c                ó.   — |                       ¦   «          | S )zG
        Acquire the lock.

        :returns: the lock object

        )ÚacquirerK   s    rM   Ú	__enter__zBaseFileLock.__enter__8  s   € ð 	�Š‰ŒˆØˆrP   Úexc_typeútype[BaseException] | NoneÚ	exc_valuerÀ   Ú	tracebackúTracebackType | Nonec                ó0   — |                       |¦  «         dS )zgRelease the lock, reconciling a release failure with any body failure per :attr:`context_error_policy`.N)Ú_release_in_context)rL   rÖ  rØ  rÙ  s       rM   Ú__exit__zBaseFileLock.__exit__B  s   € ð 	× Ò  Ñ+Ô+Ð+Ð+Ð+rP   rÜ   c                óœ   — 	 |                       ¦   «          d S # t          $ r)}|�| j        dk    r‚ t          ||¦  «         Y d }~d S d }~ww xY w)Nr3   )Úreleaser‹   r™  rà   )rL   rÜ   rÝ   s      rM   rÜ  z BaseFileLock._release_in_contextK  so   € ð	?Ø�LŠL‰NŒNˆNˆNˆNøÝð 	?ð 	?ð 	?ØÐ! TÔ%?À7Ò%JÐ%JØÝ# J°Ñ>Ô>Ð>Ð>Ð>Ð>Ð>Ð>Ð>øøøøð	?øøøs   ‚ ˜
A¢AÁAc                ó<  — t          | ¦  «                             d¦  «        t          j        ¦   «         k    rdS | j        x}�Et          j        ¦   «         s2| j                             |¦  «        | u r|                      ¦   «          dS |  	                    ¦   «          dS )z\Force-release so a dropped reference never leaks a held lock, including every thread's hold.r”  N)
Úvarsr)  rë   r,  r.  ÚsysÚis_finalizingr  Ú_release_once_unreachableÚ_release_abandoned_holds)rL   Úkeys     rM   Ú__del__zBaseFileLock.__del__U  s–   € å�‰:Œ:�>Š>˜.Ñ)Ô)­R¬Y©[¬[Ò8Ð8ØˆFð Ô&Ð&ˆCÐ3½CÔ<MÑ<OÔ<OÐ3ÐTXÔTc×TgÒTgÐhkÑTlÔTlÐptÐTtÐTtØ×*Ò*Ñ,Ô,Ð,Ð,Ð,à×)Ò)Ñ+Ô+Ð+Ð+Ð+rP   c                ó$  — t          j        t          ¦  «        5  |                      d¬¦  «         d d d ¦  «         n# 1 swxY w Y   t          j        t          ¦  «        5  |                      d¬¦  «         d d d ¦  «         d S # 1 swxY w Y   d S )NT©ÚforceF©Úexited_only)Ú
contextlibr8   Ú	Exceptionrß  Ú_release_thread_holdsrK   s    rM   rå  z%BaseFileLock._release_abandoned_holdsa  s  € õ Ô ¥Ñ+Ô+ð 	%ð 	%Ø�LŠL˜tˆLÑ$Ô$Ð$ð	%ð 	%ð 	%ñ 	%ô 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%øøøð 	%ð 	%ð 	%ð 	%õ Ô ¥Ñ+Ô+ð 	:ð 	:Ø×&Ò&°5Ð&Ñ9Ô9Ð9ð	:ð 	:ð 	:ñ 	:ô 	:ð 	:ð 	:ð 	:ð 	:ð 	:ð 	:ð 	:øøøð 	:ð 	:ð 	:ð 	:ð 	:ð 	:s!   š=½AÁAÁ!BÂB	ÂB	c                óþ   — t          t          | ¦  «        ¦  «        | _        t                               t          | t          t          t          | j        ¦  «        t          | ¦  «        ¦  «        ¦  «        ¦  «         d S rI   )	Ú_FinalizerStaterá  Ú_finalizer_stateÚ_UNREACHABLE_LOCKSr«   r*   r   Ú_finalize_unreachabler¹   rK   s    rM   rä  z&BaseFileLock._release_once_unreachablek  s`   € õ !0µ°T±
´
Ñ ;Ô ;ˆÔÝ×Ò�s 4­Õ1FÍÈDÔLaÑHbÔHbÕdhÐimÑdnÔdnÑ)oÔ)oÑpÔpÑqÔqÐqÐqÐqrP   )Úpoll_intervallry   Úcancel_checkrõ  úbool | Nonerö  úCallable[[], bool] | NoneúAcquireReturnProxy[Self]c               óò  — |                       ¦   «          |€| j        j        }|€| j        j        }|� d}t	          j        |t          d¬¦  «         |}|�|n| j        j        }t          |¦  «        }t          ||¬¦  «        }t          j        ¦   «         }|                      |||||¬¦  «        5  | j        s3t          | j        j        ¦  «        rd| j        › d�}t#          |¦  «        ‚t          | j        j        ¦  «        rd	| j        › d
�}t#          |¦  «        ‚t'          | j        ¦  «        }| j        xj        dz  c_        |                      |||¬¦  «         | j        s|                      |¦  «         	 |                      |||||¬¦  «         n$# t0          $ r |                      |¦  «         ‚ w xY w|                      |¦  «         t7          | ¬¦  «        cddd¦  «         S # 1 swxY w Y   dS )a
  
        Try to acquire the file lock.

        :param timeout: maximum wait time for acquiring the lock, ``None`` means use the default :attr:`~timeout` is and
            if ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired
        :param poll_interval: interval of trying to acquire the lock file, ``None`` means use the default
            :attr:`~poll_interval`
        :param poll_intervall: deprecated, kept for backwards compatibility, use ``poll_interval`` instead
        :param blocking: whether to retry until this call holds the lock or the timeout expires, ``None`` means use
            the default :attr:`~blocking`. ``False`` makes one attempt and raises :class:`~Timeout` on failure.
        :param cancel_check: a callable returning ``True`` when the acquisition should be canceled. Checked on each poll
            iteration. When triggered, raises :class:`~Timeout` just like an expired timeout.

        :returns: a context object that will unlock the file when the context is exited

        :raises Timeout: if fails to acquire lock within the timeout period
        :raises ValueError: if a blocking call gets a ``nan`` timeout, or *poll_interval* exceeds
            :data:`threading.TIMEOUT_MAX`

        .. code-block:: python

            # You can use this method in the context manager (recommended)
            with lock.acquire():
                pass

            # Or use an equivalent try-finally construct:
            lock.acquire()
            try:
                pass
            finally:
                lock.release()

        .. versionchanged:: 2.0.0

            This method returns now a *proxy* object instead of *self*, so that it can be used in a with statement
            without side effects.

        Nz+use poll_interval instead of poll_intervallr½  r  ©ry   )ry   rö  rt   r{   Ú
start_timeúDeadlock: lock 'z;' is acquired again while this thread's acquire of it waitszlock 'z:' is acquired again while this thread's release of it runsr™   )rt   ry   ©Úlock)Ú_raise_if_inheritedr1  rt   ry   r   rC  rÀ  r{   r  Ú_resolve_timeoutÚtimeÚperf_counterÚ_transition_admissionrÐ  Ú_on_this_stackÚ	acquiringr  r+  Ú	releasingrò   rÒ  Ú_raise_if_would_deadlockÚ_pin_lock_pathÚ_poll_until_acquiredr‹   Ú_reconcile_failed_acquireÚ_commit_acquireÚAcquireReturnProxy)	rL   rt   r{   rõ  ry   rö  r9  rü  Ú	canonicals	            rM   rÔ  zBaseFileLock.acquireq  s’  € ð^ 	× Ò Ñ"Ô"Ð"Øˆ?Ø”mÔ+ˆGàÐØ”}Ô-ˆHàÐ%Ø?ˆCÝŒM˜#Õ1¸aÐ@Ñ@Ô@Ð@Ø*ˆMà)6Ð)B˜˜ÈÌÔHcˆÝ.¨}Ñ=Ô=ˆÝ" 7°XÐ>Ñ>Ô>ˆåÔ&Ñ(Ô(ˆ
ð ×'Ò'ØØ%ØØ'Ø!ð (ñ 
ô 
ð $	1ð $	1ð ”>ð (¥n°T´]Ô5LÑ&MÔ&Mð (Øt¨¬ÐtÐtÐt�Ý" 3Ñ'Ô'Ð'õ ˜dœmÔ5Ñ6Ô6ð (Øi˜tœ~ÐiÐiÐi�Ý" 3Ñ'Ô'Ð'Ý" 4¤>Ñ2Ô2ˆIØŒMÐ&Ô&¨!Ñ+Ð&Ô&à×)Ò)¨)¸WÈxÐ)ÑXÔXÐXØ”>ð /Ø×#Ò# IÑ.Ô.Ð.ð
Ø×)Ò)Ø%Ø!-Ø#Ø"/Ø)ð *ñ ô ð ð øõ !ð ð ð Ø×.Ò.¨yÑ9Ô9Ð9Øðøøøð × Ò  Ñ+Ô+Ð+Ý%¨4Ð0Ñ0Ô0ðI$	1ð $	1ð $	1ð $	1ñ $	1ô $	1ð $	1ð $	1ð $	1ð $	1ð $	1ð $	1øøøð $	1ð $	1ð $	1ð $	1ð $	1ð $	1s+   Â0CG,Å<FÆG,Æ!F8Æ8'G,Ç,G0Ç3G0rü  úGenerator[None]c          
   #  óœ  K  — | j         rd V — d S |dk     rd n||z   }|r|nd}| j                             |€|n1t          |t	          |t          j        ¦   «         z
  d¦  «        ¦  «        ¬¦  «        sž|r|� |¦   «         rt          | j        ¦  «        ‚|�+t          j        ¦   «         |k    rt          | j        ¦  «        ‚| j                             |€|n1t          |t	          |t          j        ¦   «         z
  d¦  «        ¦  «        ¬¦  «        ¯ž	 d V — | j         	                    ¦   «          d S # | j         	                    ¦   «          w xY w)Nr   rN  ©rt   )
r—  r–  rÔ  ÚminÚmaxr  r  r,   r  rß  )rL   ry   rö  rt   r{   rü  ÚdeadlineÚwaits           rM   r  z"BaseFileLock._transition_admissionÙ  s|  è è € ð Ô ð 	ØˆEˆEˆEØˆFØ")¨A¢+ +˜$˜$°:ÀÑ3GˆØ'/Ð8�m�m°SˆàÔ'×/Ò/Ø$Ð,�D�Dµ#°d½CÀÍ4ÔK\ÑK^ÔK^Ñ@^Ð`cÑ<dÔ<dÑ2eÔ2eð 0ñ 
ô 
ð 	.ð ð . Ð 8¸\¸\¹^¼^Ð 8Ý˜dœnÑ-Ô-Ð-ØÐ#­Ô(9Ñ(;Ô(;¸xÒ(GÐ(GÝ˜dœnÑ-Ô-Ð-ð Ô'×/Ò/Ø$Ð,�D�Dµ#°d½CÀÍ4ÔK\ÑK^ÔK^Ñ@^Ð`cÑ<dÔ<dÑ2eÔ2eð 0ñ 
ô 
ð 	.ð	,ØˆEˆEˆEàÔ!×)Ò)Ñ+Ô+Ð+Ð+Ð+øˆDÔ!×)Ò)Ñ+Ô+Ð+Ð+øøøs   ÄD0 Ä0Erê  c                ó”  — d}	 | j         j        }|                      |¬¦  «         n‡# t          $ rz}|�r|| j         j        k    rb| j         j        �Vt          |¦  «        sGt          j        t          ¦  «        5  |                      |¬¦  «         ddd¦  «         n# 1 swxY w Y   ‚ d}~ww xY w|r|  	                    d¬¦  «         dS dS )a$  
        Release the file lock. The lock is only completely released when the lock counter reaches 0. The lock file
        itself may be deleted automatically, the behavior is platform-specific.

        :param force: If true, the lock counter is ignored and the lock is released in every case. On a thread-local
            lock it also releases the holds of threads that exited without releasing; a hold of a thread still running
            stays with that thread. Dropping the last reference to the lock releases every thread's hold.

        Nré  Trë  )
r1  rÒ  Ú_release_currentr‹   rÏ  Ú_is_system_call_failurerí  r8   rî  rï  )rL   rê  Úcounter_beforerÝ   s       rM   rß  zBaseFileLock.releaseù  s7  € ð &*ˆð	Ø!œ]Ô7ˆNØ×!Ò!¨Ð!Ñ.Ô.Ð.Ð.øÝð 	ð 	ð 	ð
 Ð*Ø" d¤mÔ&@Ò@Ð@Ø”MÔ.Ð:Ý/°Ñ>Ô>ð ;õ  Ô(­Ñ3Ô3ð 7ð 7Ø×)Ò)°Ð)Ñ6Ô6Ð6ð7ð 7ð 7ñ 7ô 7ð 7ð 7ð 7ð 7ð 7ð 7øøøð 7ð 7ð 7ð 7àøøøøð	øøøð ð 	9Ø×&Ò&°4Ð&Ñ8Ô8Ð8Ð8Ð8ð	9ð 	9s9   „"' §
B+±AB&Á7BÂB&ÂB	ÂB&Â!B	Â"B&Â&B+c               ó„  — | j         j        €"| j         j        �|                      ¦   «          d S | j        rt          j        ¦   «         n| j        5  |                      ¦   «         }| j	        t          j        ¦   «         k    s|j        �t          |j        ¦  «        r	 d d d ¦  «         d S |s)|j        dk    r|xj        dz  c_        	 d d d ¦  «         d S t          j        ¦   «         |_        	 t"                               dt'          | ¦  «        | j        ¦  «         |                      ¦   «          |j        €|                      ¦   «          d |_        n'# |j        €|                      ¦   «          d |_        w xY wt"                               dt'          | ¦  «        | j        ¦  «         d d d ¦  «         d S # 1 swxY w Y   d S )Nr™   z#Attempting to release lock %s on %szLock %s released on %s)r1  rÏ  Úlock_file_registryÚ_finish_interrupted_releaser—  rí  Únullcontextr–  Ú_hold_stater”  rë   r,  r  r  rÒ  r   Úcurrentframerj   Údebugrª   r  Ú_release_with_fork_trackingÚ_commit_release)rL   rê  Ústates      rM   r  zBaseFileLock._release_current  sZ  € ð Œ=Ô%Ð-ð Œ}Ô/Ð;Ø×0Ò0Ñ2Ô2Ð2ØˆFØ)-Ô)>ÐY�ZÔ#Ñ%Ô%Ð%ÀDÔDYð 	Nð 	NØ×+Ò+Ñ-Ô-ˆEð Ô ¥B¤I¡K¤KÒ/Ð/°5Ô3EÐ3MÕQ_Ð`eÔ`oÑQpÔQpÐ3MØð	Nð 	Nð 	Nñ 	Nô 	Nð 	Nð 	Nð 	Nð ð ˜UÔ/°!Ò3Ð3ØÐ"Ô" aÑ'Ð"Ô"Øð	Nð 	Nð 	Nñ 	Nô 	Nð 	Nð 	Nð 	Nõ &Ô2Ñ4Ô4ˆEŒOð	'Ý—’ÐCÅRÈÁXÄXÈtÌ~Ñ^Ô^Ð^Ø×0Ò0Ñ2Ô2Ð2ð
 Ô%Ð-Ø×(Ò(Ñ*Ô*Ð*Ø"&�”�øð Ô%Ð-Ø×(Ò(Ñ*Ô*Ð*Ø"&�”Ð&Ð&Ð&Ð&Ý�MŠMÐ2µB°t±H´H¸d¼nÑMÔMÐMð+	Nð 	Nð 	Nñ 	Nô 	Nð 	Nð 	Nð 	Nð 	Nð 	Nð 	Nð 	Nøøøð 	Nð 	Nð 	Nð 	Nð 	Nð 	Ns8   ÁAF5Â*F5ÃF5Ã.AEÄ0#F5Å$E7Å71F5Æ5F9Æ<F9c                óð   — | j                              d¬¦  «        sd S 	 | j        j        €|                      ¦   «          | j                              ¦   «          d S # | j                              ¦   «          w xY w)NFrû  )r–  rÔ  r1  rÏ  r"  rß  rK   s    rM   r  z(BaseFileLock._finish_interrupted_release8  s{   € àÔ$×,Ò,°eÐ,Ñ<Ô<ð 	ØˆFð	,ØŒ}Ô)Ð1Ø×$Ò$Ñ&Ô&Ð&àÔ!×)Ò)Ñ+Ô+Ð+Ð+Ð+øˆDÔ!×)Ò)Ñ+Ô+Ð+Ð+øøøs   Ÿ A ÁA5rŸ  c                ó\   — t          | j        t          ¦  «        r| j        j        n| j        S rI   )r�   r1  rž  rÊ   rK   s    rM   r  zBaseFileLock._hold_stateB  s(   € Ý(2°4´=ÕBXÑ(YÔ(YÐlˆtŒ}Ô$Ð$Ð_cÔ_lÐlrP   rì  c               ó„  — t          | j        x}t          ¦  «        sd S | j        5  |j        }| j                             ¦   «                              ¦   «         D ]M\  }}|r|                     ¦   «         rŒ||_        	 |  	                    d¬¦  «         ||_        ŒB# ||_        w xY w	 d d d ¦  «         d S # 1 swxY w Y   d S )NTré  )
r�   r1  rž  r–  rÊ   r   Úcopyr‚  Úis_aliver  )rL   rì  r¤   Úownrø   Úthreads         rM   rï  z"BaseFileLock._release_thread_holdsE  s#  € Ý T¤]Ð2˜'Õ4JÑKÔKð 	ØˆFàÔ"ð 		*ð 		*Ø œˆCØ $Ô 2× 7Ò 7Ñ 9Ô 9× @Ò @Ñ BÔ Bð *ð *‘��fØð  6§?¢?Ñ#4Ô#4ð ØØ"&�”ð*Ø×)Ò)°Ð)Ñ5Ô5Ð5à&)�G”O�Oø c�G”OÐ)Ð)Ð)Ð)ð*ð		*ð 		*ð 		*ñ 		*ô 		*ð 		*ð 		*ð 		*ð 		*ð 		*ð 		*ð 		*øøøð 		*ð 		*ð 		*ð 		*ð 		*ð 		*s*   ¦AB5Á=BÂB5Â	B$Â$B5Â5B9Â<B9c                óš   — | j         t          j        ¦   «         k    r.t          | ¦  «        j        › d| j        › d�}t          |¦  «        ‚d S )Nz on z4 was inherited across fork; construct a new instance)r”  rë   r,  r¹   rR   r  r+  )rL   r9  s     rM   r   z BaseFileLock._raise_if_inheritedT  sM   € ØÔ¥¤	¡¤Ò+Ð+Ý˜$‘Z”ZÔ(ÐrÐr¨d¬nÐrÐrÐrˆCÝ˜sÑ#Ô#Ð#ð ,Ð+rP   Úidentityútuple[int, int] | Nonec                ó8  — |                       ¦   «         }||_        ||_        d |_        d |_        t          | j        t          ¦  «        rO| j         	                    t          |¦  «        d ¦  «         |t          ¦   «         f| j        t          |¦  «        <   d S d S rI   )r  rÏ  Úlock_file_fd_identityÚpending_lock_file_fdÚpending_lock_file_fd_identityr�   r1  rž  r¡  r©   rª   r   r   ©rL   r¬  r,  r#  s       rM   Ú_mark_descriptor_ownedz#BaseFileLock._mark_descriptor_ownedY  s˜   € Ø×'Ò'Ñ)Ô)ˆàˆÔØ&.ˆÔ#Ø%)ˆÔ"Ø.2ˆÔ+Ý�d”mÕ%;Ñ<Ô<ð 	DØÔ ×$Ò$¥R¨¡Y¤Y°Ñ5Ô5Ð5Ø,1µ>Ñ3CÔ3CÐ,CˆDÔ�r %™yœyÑ)Ð)Ð)ð	Dð 	DrP   c                óÌ   — |                       ¦   «         }||_        ||_        t          | j        t
          ¦  «        r'|t          ¦   «         f| j        t          |¦  «        <   d S d S rI   )	r  r0  r1  r�   r1  rž  r   r¡  rª   r2  s       rM   Ú_mark_descriptor_pendingz%BaseFileLock._mark_descriptor_pendingd  si   € Ø×'Ò'Ñ)Ô)ˆØ%'ˆÔ"Ø.6ˆÔ+Ý�d”mÕ%;Ñ<Ô<ð 	FØ.3µ^Ñ5EÔ5EÐ.EˆDÔ ¥ E¡¤Ñ+Ð+Ð+ð	Fð 	FrP   c                ó>  — |                       ¦   «         }d |_        d |_        d |_        d |_        t          | j        t          ¦  «        rR| j         	                    t          |¦  «        d ¦  «         | j         	                    t          |¦  «        d ¦  «         d S d S rI   )r  r0  r1  rÏ  r/  r�   r1  rž  r¡  r©   rª   r   )rL   r#  s     rM   Ú_mark_descriptor_releasedz&BaseFileLock._mark_descriptor_releasedk  s–   € Ø×'Ò'Ñ)Ô)ˆØ%)ˆÔ"Ø.2ˆÔ+Ø!ˆÔØ&*ˆÔ#Ý�d”mÕ%;Ñ<Ô<ð 	4ØÔ ×$Ò$¥R¨¡Y¤Y°Ñ5Ô5Ð5ØÔ×"Ò"¥2 e¡9¤9¨dÑ3Ô3Ð3Ð3Ð3ð	4ð 	4rP   c                óä  — t          ¦   «         | _        t          | j        t          ¦  «        r2| j                             ¦   «          | j                             ¦   «          d| j        _        d | j        _	        d | j        _
        d | j        _        d | j        _        d | j        _        d | j        _        d| j        _        d | j        _        d | j        _        d | j        _        d | j        _        d S )NrJ   r   )r   r–  r�   r1  rž  r   Úclearr¡  Úowner_claim_pathsr¹  rÏ  Úlock_file_fd_tokenr/  r0  r1  rÒ  r  r  Úlock_file_keyr  rK   s    rM   rN   z'BaseFileLock._reset_after_fork_in_childu  sË   € å %¡¤ˆÔÝ�d”mÕ%;Ñ<Ô<ð 	)ØÔ×$Ò$Ñ&Ô&Ð&ØÔ ×&Ò&Ñ(Ô(Ð(Ø*,ˆŒÔ'Ø#'ˆŒÔ Ø%)ˆŒÔ"Ø+/ˆŒÔ(Ø.2ˆŒÔ+Ø-1ˆŒÔ*Ø6:ˆŒÔ3Ø%&ˆŒÔ"Ø"&ˆŒÔØ"&ˆŒÔØ&*ˆŒÔ#Ø+/ˆŒÔ(Ð(Ð(rP   rW   c                ó  — g }| j         j        �7| j         j        €+|                     | j         j        | j         j        f¦  «         | j         j        �+|                     | j         j        | j         j        f¦  «         t          |¦  «        S rI   )r1  rÏ  r;  r¯   r/  r0  r1  Útuple)rL   Údescriptorss     rM   rY   z"BaseFileLock._descriptors_for_forkˆ  s{   € Ø@BˆØŒ=Ô%Ð1°d´mÔ6VÐ6^Ø×Ò ¤Ô :¸D¼MÔ<_Ð`ÑaÔaÐaØŒ=Ô-Ð9Ø×Ò ¤Ô BÀDÄMÔDoÐpÑqÔqÐqÝ�[Ñ!Ô!Ð!rP   r  c               ó2  — | j         j        dk    o| j         o|dk     o|}|rrt          j                             |                      |¦  «        ¦  «        d| j        hvr9| j         xj        dz  c_        d| j        › d| j	        › d�}t          |¦  «        ‚dS dS )a^  
        Fail fast when a *different* live instance already holds this path in the current deadlock scope.

        Only the first, indefinitely-blocking acquire can self-deadlock this way: waiting in the OS primitive would
        block on a lock this flow already owns. A finite timeout or ``blocking=False`` keeps the normal Timeout path.
        r™   r   Nrý  z!' is already held by a different zE. Use is_singleton=True to enable reentrant locking across instances.)r1  rÒ  rÐ  rü   rø   r)  Ú_registry_keyr•  r  r‰  r+  )rL   r  rt   ry   Úwould_blockr9  s         rM   r  z%BaseFileLock._raise_if_would_deadlock�  sÒ   € ð ”mÔ0°AÒ5Ði¸d¼nÐ:LÐiÐQXÐ[\ÒQ\ÐiÐaiˆØð 	$�9œ>×-Ò-¨d×.@Ò.@ÀÑ.KÔ.KÑLÔLÐUYÐ[_Ô[jÐTkÐkÐkØŒMÐ&Ô&¨!Ñ+Ð&Ô&ðW 4¤>ð Wð WÐTXÔTnð Wð Wð Wð õ ˜sÑ#Ô#Ð#ð	$ð 	$ÐkÐkrP   r   c                ó:   — |                       ¦   «         x}€|n||fS rI   )Ú_deadlock_scope)rL   r  Úscopes      rM   rA  zBaseFileLock._registry_key   s(   € Ø&*×&:Ò&:Ñ&<Ô&<Ð<˜UÐEˆyˆyÈEÐS\ÐK]Ð]rP   úHashable | Nonec                 ó   — dS )aX  
        Execution unit whose own hold would deadlock a new acquire.

        ``None`` scopes holders to the thread, which the thread-local registry already separates. Async locks
        override it with the running task, since one event loop thread runs many tasks and only a reacquire from
        the *same* task can self-deadlock.
        NrJ   rJ   rP   rM   rD  zBaseFileLock._deadlock_scope£  s	   € ð ˆtrP   c               ó�  — t          | ¦  «        }| j        }d}t          j        ¦   «         | j        _        	 t          | j        ¦  «         	 |                      ¦   «          | j	        sX|  
                    ¦   «          t                               d||¦  «         |                      ¦   «          |                      ¦   «          | j	        r+t                               d||¦  «         	 d | j        _        d S |                      ||||¬¦  «        r"t          ||                      ¦   «         ¦  «        ‚|dz  }|                      ||¦  «        }	|dk    r5t%          |	t'          ||z   t)          j        ¦   «         z
  d¦  «        ¦  «        }	d}
t                               |
|||	¦  «         t)          j        |	¦  «         �Œk# d | j        _        w xY w)	Nr   Tz#Attempting to acquire lock %s on %szLock %s acquired on %s)ry   rö  rt   rü  r™   rN  z2Lock %s not acquired on %s, waiting %s seconds ...)rª   r  r   r  r1  r  r-   r*  r   rÐ  Ú_try_break_expired_lockrj   r   Ú_acquire_with_fork_trackingÚ_check_give_upr,   Ú_unprobeable_holderÚ_poll_delayr  r  r  r  Úsleep)rL   ry   rö  rt   r{   rü  Úlock_idÚlock_filenameÚattemptÚdelayr9  s              rM   r
  z!BaseFileLock._poll_until_acquired®  sÓ  € õ �T‘(”(ˆØœˆØˆÝ")Ô"6Ñ"8Ô"8ˆŒÔð	+õ $ D¤OÑ4Ô4Ð4ð"Ø×(Ò(Ñ*Ô*Ð*Ø”~ð /Ø×0Ò0Ñ2Ô2Ð2Ý—M’MÐ"GÈÐR_Ñ`Ô`Ð`Ø×4Ò4Ñ6Ô6Ð6Ø×,Ò,Ñ.Ô.Ð.Ø”>ð Ý—M’MÐ":¸GÀ]ÑSÔSÐSØð  '+ˆDŒMÔ#Ð#Ð#ð ×&Ò&Ø%Ø!-Ø#Ø)ð	 'ñ ô ð Mõ " -°×1IÒ1IÑ1KÔ1KÑLÔLÐLØ˜1‘�Ø×(Ò(¨¸Ñ@Ô@�Ø˜a’<�<Ý ¥s¨:¸Ñ+?Å$ÔBSÑBUÔBUÑ+UÐWZÑ'[Ô'[Ñ\Ô\�EØJ�Ý—’˜c 7¨M¸5ÑAÔAÐAÝ”
˜5Ñ!Ô!Ð!ñ/"øð2 '+ˆDŒMÔ#Ð*Ð*Ð*Ð*s   ·B+F7 Ã1CF7 Æ7GrQ  c           	     óà   — | j         s|S t          | j         |dt          |t          ¦  «        z  z  ¦  «        }t          |t	          j        t          |dz  ¦  «        dz   ¦  «        dz  ¦  «        S )Nr½  i@B r™   )r‹  r  r2   r  r	   Ú	randbelowru   )rL   r{   rQ  Úwindows       rM   rM  zBaseFileLock._poll_delayÚ  sx   € ð Ô%ð 	!Ø Ð õ ØÔ" M°A½¸WÕF[Ñ9\Ô9\Ñ4\Ñ$\ñ
ô 
ˆõ �=¥'Ô"3µC¸ÀÑ8JÑ4KÔ4KÈaÑ4OÑ"PÔ"PÐS\Ñ"\Ñ]Ô]Ð]rP   c                ój   — | j         r|                      |¦  «         d S |                      ¦   «          d S rI   )rÐ  r  Ú_undo_acquire©rL   r  s     rM   r  z&BaseFileLock._reconcile_failed_acquireç  s@   € ð Œ>ð 	!Ø× Ò  Ñ+Ô+Ð+Ð+Ð+à×ÒÑ Ô Ð Ð Ð rP   c                óP  — | j         �| j        j        dk    rd S 	 |                       t          d| j        j        ¦  «        ¦  «         d S # t
          $ rQ}|j        }	 |                      ¦   «          n'# t
          $ r}t          ||¦  «         Y d }~nd }~ww xY w||_        ‚ d }~ww xY w)Nr™   ru   )	r�  r1  rÒ  r'   rÏ  r‹   r¬   r!  rà   )rL   Úcallback_errorÚcallback_contextrÝ   s       rM   Ú_invoke_on_acquiredz BaseFileLock._invoke_on_acquiredð  sÝ   € àÔÐ$¨¬Ô(BÀaÒ(GÐ(GØˆFð		Ø×Ò�d 5¨$¬-Ô*DÑEÔEÑFÔFÐFÐFÐFøÝð 	ð 	ð 	Ø-Ô9ÐðGØ×0Ò0Ñ2Ô2Ð2Ð2øÝ ð Gð Gð GÝ'¨¸ÑFÔFÐFÐFÐFÐFÐFÐFøøøøðGøøøà)9ˆNÔ&Øøøøøð	øøøsA   ›-A
 Á

B%ÁB ÁA1Á0B Á1
BÁ;BÂB ÂBÂB Â B%c                óˆ  — t          | ¦  «        5  	 |                      ¦   «          n(# t          $ r}|                      |¦  «         ‚ d }~ww xY w	 |                      ¦   «          n(# t          $ r}|                      |¦  «         ‚ d }~ww xY w	 d d d ¦  «         n# 1 swxY w Y   | j        r|                      ¦   «          d S d S rI   )r}  Ú_acquirer‹   Ú_rollback_failed_acquireÚ_register_context_descriptorÚ_rollback_failed_registrationrÐ  r\  )rL   Úacquisition_errorÚregistration_errors      rM   rJ  z(BaseFileLock._acquire_with_fork_trackingÿ  s4  € Ý˜dÑ#Ô#ð 
	ð 
	ðØ—’‘”��øÝ ð ð ð Ø×-Ò-Ð.?Ñ@Ô@Ð@ØøøøøðøøøðØ×1Ò1Ñ3Ô3Ð3Ð3øÝ ð ð ð Ø×2Ò2Ð3EÑFÔFÐFØøøøøðøøøð 4ð
	ð 
	ð 
	ñ 
	ô 
	ð 
	ð 
	ð 
	ð 
	ð 
	ð 
	øøøð 
	ð 
	ð 
	ð 
	ð Œ>ð 	'Ø×$Ò$Ñ&Ô&Ð&Ð&Ð&ð	'ð 	'sT   �B’'¦B§
A±AÁAÁBÁA%Á$BÁ%
B
Á/BÂB
Â
BÂBÂ!Brb  r‹   c                óˆ  — | j         sd S d }d }	 |                      ¦   «          nH# t          $ r;}|}	 |                      ¦   «          n# t          $ r}|}Y d }~nd }~ww xY wY d }~nd }~ww xY w	 |                      ¦   «          n*# t          $ r}t          d||||¦  «         Y d }~nd }~ww xY w|�t          d|||¦  «         d S d S )Nzlock acquisition cleanup failed)rÐ  r`  r‹   Ú'_register_unverified_context_descriptorr!  rå   )rL   rb  rc  Útracking_errorrŠ   Úrollback_errors         rM   r_  z%BaseFileLock._rollback_failed_acquire  sS  € ØŒ~ð 	ØˆFØ37ÐØ/3ˆð	'Ø×-Ò-Ñ/Ô/Ð/Ð/øÝð 	'ð 	'ð 	'Ø!&Ðð'à×<Ò<Ñ>Ô>Ð>Ð>øÝ ð 'ð 'ð 'Ø!&������øøøøð'øøøøøøøøøøøøð	'øøøð		Ø×,Ò,Ñ.Ô.Ð.Ð.øÝð 	ð 	ð 	Ý!Ø1Ø!Ø"ØØñô ð ð ð ð ð ð øøøøð	øøøð Ð)Ý!Ø1Ð3DÐFXÐZhñô ð ð ð ð *Ð)sU   �$ ¤
A)®A$±AÁA$Á
AÁAÁA$ÁAÁA$Á$A)Á-B Â
B)ÂB$Â$B)rc  c                ó  — d }	 |                       ¦   «          n# t          $ r}|}Y d }~nd }~ww xY w	 |                      ¦   «          n)# t          $ r}t          d|||¦  «         Y d }~nd }~ww xY w|�t          d||¦  «         d S d S )Nz&descriptor registration cleanup failed)re  r‹   r!  rå   )rL   rc  rf  rŠ   rg  s        rM   ra  z*BaseFileLock._rollback_failed_registration+  sé   € Ø/3ˆð	#à×8Ò8Ñ:Ô:Ð:Ð:øÝð 	#ð 	#ð 	#Ø"ˆNˆNˆNˆNˆNˆNøøøøð	#øøøð	Ø×,Ò,Ñ.Ô.Ð.Ð.øÝð 	ð 	ð 	Ý!Ø8Ð:LÈnÐ^lñô ð ð ð ð ð ð øøøøð	øøøð Ð%Ý!Ð"JÐL^Ð`nÑoÔoÐoÐoÐoð &Ð%s'   „ ™
/£*ª/³A Á
A.ÁA)Á)A.c                óÈ  — t          | ¦  «        5  	 |                      ¦   «          ns# t          $ rf}| j        j        �Tt          |¦  «        sEt          j        t          ¦  «        5  |                      ¦   «          d d d ¦  «         n# 1 swxY w Y   ‚ d }~ww xY w	 |  	                    ¦   «          n# |  	                    ¦   «          w xY w	 d d d ¦  «         d S # 1 swxY w Y   d S rI   )
r}  Ú_releaser‹   r1  rÏ  r  rí  r8   rî  Ú_unregister_released_descriptor)rL   rÝ   s     rM   r!  z(BaseFileLock._release_with_fork_tracking;  sp  € Ý˜dÑ#Ô#ð 	7ð 	7ð
7Ø—’‘”��øÝ ð ð ð ð ”=Ô-Ð9ÕBYÐZgÑBhÔBhÐ9Ý#Ô,­YÑ7Ô7ð (ð (ØŸš™œ˜ð(ð (ð (ñ (ô (ð (ð (ð (ð (ð (ð (øøøð (ð (ð (ð (àøøøøðøøøð  ð ×4Ò4Ñ6Ô6Ð6Ð6ø�×4Ò4Ñ6Ô6Ð6Ð6øøøÐ6ð	7ð 	7ð 	7ñ 	7ô 	7ð 	7ð 	7ð 	7ð 	7ð 	7ð 	7ð 	7øøøð 	7ð 	7ð 	7ð 	7ð 	7ð 	7sf   �C’'¦B0§
B±4BÁ%BÁ:BÂB
Â
BÂB
ÂBÂBÂB0ÂCÂ0CÃCÃCÃCc                óš   — | j         j        �<| j         j        €2t          | j         j        | j         j        ¦  «        | j         _        d S d S d S rI   )r1  rÏ  r;  Ú_register_owned_descriptorr/  rK   s    rM   r`  z)BaseFileLock._register_context_descriptorI  sO   € ØŒ=Ô%Ð1°d´mÔ6VÐ6^Ý/IØ”Ô*Ø”Ô3ñ0ô 0ˆDŒMÔ,Ð,Ð,ð 2Ð1Ð6^Ð6^rP   c                ó„   — | j         j        �1| j         j        €'t          | j         j        ¦  «        | j         _        d S d S d S rI   )r1  rÏ  r;  Ú%_register_unverified_owned_descriptorrK   s    rM   re  z4BaseFileLock._register_unverified_context_descriptorP  sD   € àŒ=Ô%Ð1°d´mÔ6VÐ6^Ý/TÐUYÔUbÔUoÑ/pÔ/pˆDŒMÔ,Ð,Ð,ð 2Ð1Ð6^Ð6^rP   c                óŒ   — | j         j        €7| j         j        x}�t          |¦  «         d | j         _        d | j         _        d S d S rI   )r1  rÏ  r;  Ú_unregister_owned_descriptorr/  )rL   Útokens     rM   rk  z,BaseFileLock._unregister_released_descriptorU  sM   € ØŒ=Ô%Ð-ØœÔ9Ð9�ÐFÝ,¨UÑ3Ô3Ð3Ø/3ˆDŒMÔ,Ø26ˆDŒMÔ/Ð/Ð/ð	 .Ð-rP   c                ó¸   — t          d| j        j        dz
  ¦  «        | j        _        | j        j        dk    r"|                      ¦   «          d| j        _        dS dS )zfRoll back the counter after a failed acquire, dropping the registry entry once nothing holds the path.r   r™   N)r  r1  rÒ  Ú_drop_registry_entryr¹  rK   s    rM   rW  zBaseFileLock._undo_acquire\  sZ   € å%(¨¨D¬MÔ,FÈÑ,JÑ%KÔ%KˆŒÔ"ØŒ=Ô%¨Ò*Ð*Ø×%Ò%Ñ'Ô'Ð'Ø'+ˆDŒMÔ$Ð$Ð$ð +Ð*rP   c                ó`   — |                      t          j        ¦  «        rd n|| j        _        d S rI   )Úendswithrë   Úsepr1  r¹  rX  s     rM   r	  zBaseFileLock._pin_lock_pathc  s-   € ð ,5×+=Ò+=½b¼fÑ+EÔ+EÐ#T 4 4È9ˆŒÔ Ð Ð rP   c                ó¸   — | j         j        €M|                      |¦  «        }|| j         _        t          j        | j         _        | j        t          j        |<   dS dS )zeRecord this instance as the holder once the first acquire succeeds, so peers can detect the deadlock.N)r1  r  rA  r<  rü   rø   r•  )rL   r  ræ  s      rM   r  zBaseFileLock._commit_acquireh  sV   € ð Œ=Ô+Ð3Ø×$Ò$ YÑ/Ô/ˆCà*-ˆDŒMÔ'õ 09¬~ˆDŒMÔ,Ø"&¤/�IŒN˜3ÑÐÐð 4Ð3rP   c                ó¬   — | j         j        | j         j        }}|�!|                     |¦  «        | j        k    r||= d| j         _        d| j         _        dS )zIForget the key owned by this hold without resolving a mutable path again.N)r1  r<  r  r)  r•  )rL   ræ  Úregistrys      rM   rt  z!BaseFileLock._drop_registry_entryu  sV   € ð œÔ3°T´]Ô5UˆXˆØÐ H§L¢L°Ñ$5Ô$5¸¼Ò$HÐ$HØ˜�Ø+/ˆŒÔ(Ø&*ˆŒÔ#Ð#Ð#rP   c                ó^   — d| j         _        |                      ¦   «          d| j         _        dS )zdRecord the lock as fully released: reset the recursion counter and drop the deadlock-registry entry.r   N)r1  rÒ  rt  r¹  rK   s    rM   r"  zBaseFileLock._commit_release  s.   € à%&ˆŒÔ"Ø×!Ò!Ñ#Ô#Ð#Ø#'ˆŒÔ Ð Ð rP   c                ó   — dS )z`Remove the lock file once it is older than :attr:`lifetime`; only an existence lock accepts one.NrJ   rK   s    rM   rI  z$BaseFileLock._try_break_expired_lock…  rO   rP   c               óN  — t          | ¦  «        | j        }}|du rt                               d||¦  «         dS |�( |¦   «         rt                               d||¦  «         dS d|cxk    rt	          j        ¦   «         |z
  k     r!n nt                               d||¦  «         dS dS )NFz+Failed to immediately acquire lock %s on %sTz(Cancellation requested for lock %s on %sr   z"Timeout on acquiring lock %s on %s)rª   r  rj   r   r  r  )rL   ry   rö  rt   rü  rO  rP  s          rM   rK  zBaseFileLock._check_give_upˆ  s»   € õ "$ D¡¤¨4¬>�ˆØ�uÐÐÝ�MŠMÐGÈÐR_Ñ`Ô`Ð`Ø�4ØÐ#¨¨©¬Ð#Ý�MŠMÐDÀgÈ}Ñ]Ô]Ð]Ø�4Ø�Ð:Ð:Ò:Ð:�$Ô+Ñ-Ô-°
Ñ:Ò:Ð:Ð:Ð:Ð:Ý�MŠMÐ>ÀÈÑWÔWÐWØ�4ØˆurP   c                ó   — d S rI   rJ   rK   s    rM   rL  z BaseFileLock._unprobeable_holderœ  s   € ØˆtrP   c                ó   — t           ‚)zjIf the file lock could be acquired, self._context.lock_file_fd holds the file descriptor of the lock file.©ÚNotImplementedErrorrK   s    rM   r^  zBaseFileLock._acquireŸ  ó
   € õ "Ð!rP   c                ó   — t           ‚)z>Releases the lock and sets self._context.lock_file_fd to None.r€  rK   s    rM   rj  zBaseFileLock._release¤  r‚  rP   )r  rp   rF   rG   rQ   )r  ré   rt   rs   rv   ru   rx   rw   ry   rw   rz   rw   r{   rs   r}   r|   r   r~   r�   r€   r‚   rw   rƒ   rw   r…   r„   rF   rG   )r£  r¤  rF   r¥  )rF   rw   )rF   r~   )rF   r€   )r¬  ru   r­  rw   rF   rG   )r­  rw   rF   rw   )rF   r„   rÓ   )rF   rs   )rL  r»  rF   rG   )rL  rw   rF   rG   )rL  rs   rF   rG   )rF   r|   )rL  r|   rF   rG   )rF   ru   )rF   rh   ©rÖ  r×  rØ  rÀ   rÙ  rÚ  rF   rG   )rÜ   rÀ   rF   rG   )NN)rt   r|   r{   r|   rõ  r|   ry   r÷  rö  rø  rF   rù  )ry   rw   rö  rø  rt   rs   r{   rs   rü  rs   rF   r  )F)rê  rw   rF   rG   )rF   rŸ  )rì  rw   rF   rG   rI   )r¬  ru   r,  r-  rF   rG   rZ   )r  r“   rt   rs   ry   rw   rF   rG   )r  r“   rF   r   )rF   rF  )ry   rw   rö  rø  rt   rs   r{   rs   rü  rs   rF   rG   )r{   rs   rQ  ru   rF   rs   )r  r“   rF   rG   )rb  r‹   rF   rG   )rc  r‹   rF   rG   )
ry   rw   rö  rø  rt   rs   rü  rs   rF   rw   )rF   rŒ  )ZrR   rS   rT   r‡   rˆ   r‰  rB  rE  rD  r  r%  r'  r‹  r.  rŽ  Úclassmethodr^   r/   r÷   r4  r/  rÔ   rz   r   r�   r²  r±  r‚   rƒ   r…   r  r*  rt   Úsetterry   r{   r}   rv   rË  rÍ  rÐ  rÒ  rÕ  rÝ  rÜ  rç  rå  rä  rÔ  rí  r   r  rß  r  r  r  rï  r   r3  r5  r7  rN   rY   r  rA  ÚstaticmethodrD  r
  rM  r  r\  rJ  r_  ra  r!  r`  re  rk  rW  r	  r  rt  r"  rI  rK  rL  r   r^  rj  rú   rû   s   @rM   rþ   rþ   š  s–  ø€ € € € € € ðð ð 7Ð6Ð6Ñ6ØÐÐÑØ+Ð+Ð+Ñ+ð "DÐÐCÐCÐCÑCð !&ÐÐ%Ð%Ð%Ñ%ð 6:ÐÐ9Ð9Ð9Ñ9ð )_Ð Ð^Ð^Ð^Ñ^ð 56Ð,Ð5Ð5Ð5Ñ5ð +/Ð!Ð.Ð.Ð.Ñ.ð $(ÐÐ'Ð'Ð'Ñ'ð  #ÐÐ"Ð"Ð"Ñ"ð "&€NÐ%Ð%Ð%Ñ%ð"ð "ð "ð "ð "ð "ð ð2ð 2ð 2ñ „[ð2ð Ø$Ø!ðh$ð Ø"Ø#Ø!%Ø3:Ø/8Ø!%Ø#(Ø48ðh$ð h$ð h$ð h$ð h$ð h$ðTð ð ð ð%ð %ð %ð %ð ð"ð "ð "ñ „Xð"ð ð*ð *ð *ñ „Xð*ð ð(ð (ð (ñ „Xð(ðð ð ð ðxð xð xð xð ð
&ð 
&ð 
&ñ „Xð
&ð ð
(ð 
(ð 
(ñ „Xð
(ð ð
!ð 
!ð 
!ñ „Xð
!ð ð'ð 'ð 'ñ „Xð'ð ðCð Cð Cñ „XðCð
 ð%ð %ð %ñ „Xð%ð „^ð;ð ;ð ;ñ „^ð;ð. ð&ð &ð &ñ „Xð&ð „_ð
'ð 
'ð 
'ñ „_ð
'ð ð+ð +ð +ñ „Xð+ð Ôð
Dð 
Dð 
Dñ Ôð
Dð ð
&ð 
&ð 
&ñ „Xð
&ð „_ð
Tð 
Tð 
Tñ „_ð
Tð ð	Wð 	Wð 	Wñ „Xð	Wð ð6ð 6ð 6ñ „Xð6ðWð Wð Wð Wð ð
6ð 
6ð 
6ñ „Xð
6ð ð*ð *ð *ñ „Xð*ð
ð ð ð ð,ð ,ð ,ð ,ð?ð ?ð ?ð ?ð
,ð 
,ð 
,ð 
,ð:ð :ð :ð :ðrð rð rð rð !%Ø&*ðf1ð
 (,Ø $Ø26ðf1ð f1ð f1ð f1ð f1ð f1ðP Ôð,ð ,ð ,ñ Ôð,ð>9ð 9ð 9ð 9ð 9ð<Nð Nð Nð NðB,ð ,ð ,ð ,ðmð mð mð mð*ð *ð *ð *ð$ð $ð $ð $ð
	Dð 	Dð 	Dð 	Dð 	DðFð Fð Fð Fð Fð4ð 4ð 4ð 4ð0ð 0ð 0ð 0ð&"ð "ð "ð "ð$ð $ð $ð $ð ^ð ^ð ^ð ^ð ðð ð ñ „\ðð*+ð *+ð *+ð *+ðX^ð ^ð ^ð ^ð!ð !ð !ð !ðð ð ð ð'ð 'ð 'ð 'ðð ð ð ð:pð pð pð pð 7ð 7ð 7ð 7ðð ð ð ðqð qð qð qð
7ð 7ð 7ð 7ð,ð ,ð ,ð ,ðUð Uð Uð Uð
2ð 2ð 2ð 2ð+ð +ð +ð +ð(ð (ð (ð (ðoð oð oð oðð ð ð ð(ð ð ð ð ð"ð "ð "ñ „^ð"ð ð"ð "ð "ñ „^ð"ð "ð "ð "ð "rP   )Ú	metaclassc               ól   — t          | |¬¦  «        x} dk     r| dk    r|rd| ›�}t          |¦  «        ‚| S )zjValidate a read-write lock's acquire ``timeout``: ``-1`` or a non-negative number, ``inf`` meaning ``-1``.rû  r   r.   z1timeout must be a non-negative number or -1, not )r  r5  ©rt   ry   r9  s      rM   Ú_resolve_read_write_timeoutr‹  ª  sK   € å# G°hÐ?Ñ?Ô?Ð?ˆÀ1ÒDÐDÈÐTVÊÈÐ[cÈØMÀ'ÐMÐMˆÝ˜‰oŒoÐØ€NrP   rÿ  r<   rö  rø  c          
     ón  — |s|                       d¬¦  «        S |€C|dk    r|                       ¦   «         n(|                       t          |t          ¦  «        ¬¦  «        S |dk    rdnt          j        ¦   «         |z   }|                       |€|n1t          |t          |t          j        ¦   «         z
  d¦  «        ¦  «        ¬¦  «        so |¦   «         s|�t          j        ¦   «         |k    rdS |                       |€|n1t          |t          |t          j        ¦   «         z
  d¦  «        ¦  «        ¬¦  «        ¯odS )zjTake a read-write lock's in-process lock; with *cancel_check*, ask it every *poll_interval* while waiting.Frû  Nr.   r  r   T)rÔ  r  r   r  r  r  )rÿ  ry   rt   r{   rö  r  s         rM   Ú_acquire_thread_lockr�  ²  sD  € ð ð ,Ø�|Š| Uˆ|Ñ+Ô+Ð+ØÐà!(¨B¢ ˆt�|Š|‰~Œ~ˆ~°D·L²LÍÈWÕVaÑIbÔIb°LÑ4cÔ4cÐcØ "’}�}ˆtˆt­$Ô*;Ñ*=Ô*=ÀÑ*G€HØ�lŠlØ!)Ð!1��µs¸=Í#ÈhÕY]ÔYjÑYlÔYlÑNlÐnoÑJpÔJpÑ7qÔ7qð ñ ô ð ð ˆ<‰>Œ>ð 	˜hÐ2µtÔ7HÑ7JÔ7JÈhÒ7VÐ7VØ�5ð	 �lŠlØ!)Ð!1��µs¸=Í#ÈhÕY]ÔYjÑYlÔYlÑNlÐnoÑJpÔJpÑ7qÔ7qð ñ ô ð ð
 ˆ4rP   c               ó˜   — t          j        t          d| ¦  «        x} ¦  «        r|rd}t          |¦  «        ‚| t           j        k    rdn| S )zLValidate an acquire ``timeout``; every negative value waits without a limit.rt   z,timeout must be a number of seconds, not nanr.   )r   rm  r   r5  rn  rŠ  s      rM   r  r  Ä  sQ   € å„z�X i°Ñ9Ô9Ð9�'Ñ:Ô:ð ¸xð Ø<ˆÝ˜‰oŒoÐà�DœHÒ$Ð$ˆ2ˆ2¨'Ð1rP   )ÚslotsÚweakref_slotc                  ó   — e Zd ZU dZded<   dS )rñ  zVA finalized lock's state, held for the release that runs once the lock is unreachable.zdict[str, object] | Noner#  Nr†   rJ   rP   rM   rñ  rñ  Í  s$   € € € € € € à`Ð`à#Ð#Ð#Ñ#Ð#Ð#rP   rñ  zFinal[set[ref[BaseFileLock]]]ró  Úholderúref[_FinalizerState]Ú	referenceúref[BaseFileLock]c                óº   — t                                |¦  «          | ¦   «         x}�	|j        x}€d S d |_        t                               |¦  «        }||_        ~d S rI   )ró  r-  r#  ÚobjectÚ__new__Ú__dict__)r’  r  r”  Úfinalizer_stater#  Ústand_ins         rM   rô  rô  Ø  sc   € Ý×Ò˜yÑ)Ô)Ð)Ø!˜6™8œ8Ð#ˆÐ,¸/Ô:OÐ1O°Ð0XØˆà €OÔõ �~Š~˜cÑ"Ô"€HØ€HÔØˆˆrP   c           	     óÆ   — t          | ¦  «        r5t          t          t          t	          d| ¦  «        j        ¦  «        ¦  «        S t          | t          ¦  «        o| j        d uS rÛ   )	r�   ÚallÚmapr  r'   r²   r�   r°  Úerrnor�   s    rM   r  r  å  sW   € å˜5Ñ!Ô!ð dÝ•3Õ.µÐ5NÐPUÑ0VÔ0VÔ0aÑbÔbÑcÔcÐcÝ�e�WÑ%Ô%ÐA¨%¬+¸TÐ*AÐArP   ÚframeúFrameType | Nonec                ó^   — | €dS t          j        ¦   «         }|�|| ur|j        }|�|| u°|d uS )NF)r   r  Úf_back)r   Úcallers     rM   r  r  ì  sN   € Ø€}ØˆuÝÔ!Ñ#Ô#€FØ
Ð
 ¨uÐ!4Ð!4Ø”ˆð Ð
 ¨uÐ!4Ð!4à˜ÐÐrP   c                  ó*   — e Zd ZdZdd„Zdd„Zdd„ZdS )r  zDA context-aware object that will release the lock file when exiting.rÿ  r   rF   rG   c                ó   — || _         d S rI   rþ  )rL   rÿ  s     rM   r÷   zAcquireReturnProxy.__init__ú  s   € Ø ˆŒ	ˆ	ˆ	rP   c                ó   — | j         S rI   rþ  rK   s    rM   rÕ  zAcquireReturnProxy.__enter__ý  s
   € ØŒyÐrP   rÖ  r×  rØ  rÀ   rÙ  rÚ  c                ó°   — t          d| j        ¦  «        }t          |t          ¦  «        r|                     |¦  «         d S |                     ¦   «          d S )Nr  )r'   rÿ  r�   rþ   rÜ  rß  )rL   rÖ  rØ  rÙ  rÿ  s        rM   rÝ  zAcquireReturnProxy.__exit__   sS   € õ ÐMÈtÌyÑYÔYˆÝ�d�LÑ)Ô)ð 	Ø×$Ò$ YÑ/Ô/Ð/Ð/Ð/à�LŠL‰NŒNˆNˆNˆNrP   N)rÿ  r   rF   rG   )rF   r   r„  )rR   rS   rT   r‡   r÷   rÕ  rÝ  rJ   rP   rM   r  r  ÷  sV   € € € € € ØNÐNð!ð !ð !ð !ðð ð ð ðð ð ð ð ð rP   r  c                  ó
  — e Zd ZU dZded<   ded<   ded<   ded	<   ded
<   dZded<   dZded<   dZded<   dZded<   dZ	ded<   dZ
ded<   dZded<   dZded<   dZded<   dZded<   dZded<   dZded <   dZd!ed"<   dZd#ed$<   dS )%rŸ  z0Holds the context for a ``BaseFileLock`` object.r“   r  rs   rt   ru   rv   rw   ry   r{   Nr|   r}   ú
int | NonerÏ  r;  r-  r/  r0  r1  r   rÒ  rF  r<  zdict[Hashable, int] | Noner  rJ   ztuple[str, ...]r:  r¡  r  r  rŒ  r¹  z_LeaseClaim | NoneÚlease_claim)rR   rS   rT   r‡   rˆ   r}   rÏ  r;  r/  r0  r1  rÒ  r<  r  r:  r  r  r¹  r«  rJ   rP   rM   rŸ  rŸ    s[  € € € € € € à:Ð:ð €N€N�NØ€N€N�NØ€I€I�IØ€N€N�NØÐÐÑð "€HÐ!Ð!Ð!Ñ!ð  $€LÐ#Ð#Ð#Ñ#ð &*ÐÐ)Ð)Ð)Ñ)ð 59ÐÐ8Ð8Ð8Ñ8ð (,ÐÐ+Ð+Ð+Ñ+ð =AÐ!Ð@Ð@Ð@Ñ@ð €LÐÐÐÑð &*€MÐ)Ð)Ð)Ñ)ð 6:ÐÐ9Ð9Ð9Ñ9ð *,ÐÐ+Ð+Ð+Ñ+ð #'€IÐ&Ð&Ð&Ñ&ð #'€IÐ&Ð&Ð&Ñ&ð "€JÐ!Ð!Ð!Ñ!ð '+€KÐ*Ð*Ð*Ñ*Ð*Ð*rP   rŸ  c                  ó,   — e Zd ZU dZded<   ddœdd„ZdS )rž  a  
    A thread local version of the ``FileLockContext`` class.

    Each thread's state lives in an ordinary :class:`FileLockContext` at :attr:`current`, which the lock also keeps, so
    ``release(force=True)`` and the finalizer can unlock a hold whose thread exited.
    rŸ  rÊ   N)r}   r  r“   rt   rs   rv   ru   ry   rw   r{   r}   r|   rF   rG   c               ó:   — t          ||||||¬¦  «        | _        d S )Nr“  )rŸ  rÊ   )rL   r  rt   rv   ry   r{   r}   s          rM   r÷   zThreadLocalFileContext.__init__R  s0   € õ 'ØØØØØ'Øð
ñ 
ô 
ˆŒˆˆrP   )r  r“   rt   rs   rv   ru   ry   rw   r{   rs   r}   r|   rF   rG   )rR   rS   rT   r‡   rˆ   r÷   rJ   rP   rM   rž  rž  G  sQ   € € € € € € ðð ð ÐÐÑð "&ð
ð 
ð 
ð 
ð 
ð 
ð 
ð 
rP   rž  rÔ   c                ó0   ‡ — t          ˆ fd„ˆ fd„¦  «        S )Nc                ó.   •— t          | j        ‰¦  «        S rI   )rÎ   rÊ   )r¤   rñ   s    €rM   ú<lambda>z&_delegate_to_current.<locals>.<lambda>h  s   ø€ � ¤°Ñ6Ô6€ rP   c                ó0   •— t          | j        ‰|¦  «        S rI   )r›   rÊ   )r¤   rL  rñ   s     €rM   r°  z&_delegate_to_current.<locals>.<lambda>i  s   ø€ �w w¤¸¸eÑDÔD€ rP   )rÔ   )rñ   s   `rM   Ú_delegate_to_currentr²  f  s-   ø€ ÝØ6Ð6Ð6Ð6ØDÐDÐDÐDñô ð rP   c                  ó8   — e Zd ZU ded<   ded<   ded<   ded<   dS )Ú_OwnedDescriptorru   r¬  Úcreator_pidrª  ÚdeviceÚinodeNr‡  rJ   rP   rM   r´  r´  q  s?   € € € € € € à€G€G�GØÐÐÑØÐÐÑØÐÐÑÐÐrP   r´  c                  ó   — e Zd Zdd„Zdd„ZdS )Ú
_ForkStaterF   rG   c                ó$  — t          t          ¦   «         ¦  «        | _        t          ¦   «         | _        t          ¦   «         | _        i | _        d| _        d| _        i | _        i | _	        i | _
        i | _        t          j        ¦   «         | _        d S ©Nr   F)r   r   ÚgateÚregistry_lockr  ÚtransitionsÚactive_transitionsÚadmission_closedÚfork_owner_depthsÚpinned_objectsÚpinned_classesÚprovisional_descriptor_tokensrë   r,  ÚpidrK   s    rM   r÷   z_ForkState.__init__z  sv   € Ý�e™gœgÑ&Ô&ˆŒ	Ý"™WœWˆÔÝ%*¡W¤WˆÔ"ØNPˆÔØ"#ˆÔØ %ˆÔØ13ˆÔØLNˆÔØQSˆÔØOQˆÔ*Ý”9‘;”;ˆŒˆˆrP   c                óô   — t          t          ¦   «         ¦  «        | _        t          ¦   «         | _        t          ¦   «         | _        i | _        d| _        d| _        i | _        i | _	        i | _
        i | _        d S r»  )r   r   r¼  r½  r  r¾  r¿  rÀ  rÁ  rÂ  rÃ  rÄ  rK   s    rM   Úreset_synchronizationz _ForkState.reset_synchronization‡  sk   € Ý�e™gœgÑ&Ô&ˆŒ	Ý"™WœWˆÔÝ%*¡W¤WˆÔ"ØˆÔØ"#ˆÔØ %ˆÔØ!#ˆÔØ ˆÔØ ˆÔØ-/ˆÔ*Ð*Ð*rP   NrQ   )rR   rS   rT   r÷   rÇ  rJ   rP   rM   r¹  r¹  y  s<   € € € € € ðð ð ð ð
0ð 
0ð 
0ð 
0ð 
0ð 
0rP   r¹  z0Final[WeakValueDictionary[int, _ForkResettable]]Ú_FORK_OBJECTSz5Final[WeakValueDictionary[int, _ForkResettableClass]]Ú_FORK_CLASSESz"Final[dict[int, _OwnedDescriptor]]Ú_OWNED_DESCRIPTORSzFinal[count[int]]Ú_DESCRIPTOR_TOKENSÚ_TRANSITION_TOKENSr!   r~  zos.forkz
os.forkptyÚ_FORK_AUDIT_EVENTSÚcpython)rŠ  é   Ú_SETTRACE_SURVIVES_AUDIT_HOOKSc                 óf   — t          t          d¦  «        rt          j        t          ¦  «         d S d S )NÚLazyImportType)Úhasattrr
   r   ÚregisterÚ_resolve_lazy_importsrJ   rP   rM   r  r     s6   € å�uÐ&Ñ'Ô'ð /ÝŒÕ-Ñ.Ô.Ð.Ð.Ð.ð/ð /rP   c                 ó\  — t          t          j                             ¦   «         ¦  «        D ]\  } }| dk    s|                      d¦  «        r_t          t          |¦  «                             ¦   «         ¦  «        D ]0\  }}t          |¦  «        t          j        u rt          ||¦  «         Œ1Œ€d S )Nri   z	filelock.)
r¨   râ  Úmodulesr2  Ú
startswithrá  r¹   r
   rÒ  rÎ   )rñ   ÚmoduleÚ	attributerL  s       rM   rÕ  rÕ  ¦  s§   € õ �Sœ[×.Ò.Ñ0Ô0Ñ1Ô1ð /ð /‰ˆˆfØ�:ÒÐ §¢°Ñ!=Ô!=ÐÝ$(­¨f©¬×);Ò);Ñ)=Ô)=Ñ$>Ô$>ð /ð /Ñ �	˜5Ý˜‘;”;¥%Ô"6Ð6Ð6Ý˜F IÑ.Ô.Ð.øøð	/ð /rP   c                 óš   — t           €d S t          rt          j        t          ¦  «         t          t
          t          t          ¬¦  «         d S )Nra   )rl   rÐ  râ  ÚaddaudithookÚ_audit_fork_safetyÚ_pin_fork_objectsÚ_resume_parent_after_forkÚ_reset_child_after_forkrJ   rP   rM   Ú_register_fork_hooksrá  °  sQ   € ÝÐ ØˆÝ%ð -ÝÔÕ+Ñ,Ô,Ð,ÝÝ Ý1Ý.ðñ ô ð ð ð rP   Údescriptor_ownerú_ForkDescriptorOwner | Noner  c              #  ó~  K  — t           rt          j        ¦   «         rd V — d S t          ¦   «          t	          j        ¦   «         }t          ¦   «         }t          | |¦  «        }	 d V — t	          j        ¦   «         |k    rt          ||¦  «         d S d S # t	          j        ¦   «         |k    rt          ||¦  «         w w xY wrI   )	rm   râ  rã  r  rë   r,  r   Ú_enter_fork_transitionÚ_leave_fork_transition)râ  rµ  Ú	thread_idrr  s       rM   r}  r}  ¼  sÇ   è è € õ !ð ¥CÔ$5Ñ$7Ô$7ð ØˆˆˆØˆÝÑÔÐÝ”)‘+”+€Kå ‘{”{€IÝ)Ð*:¸IÑFÔF€Eð5ØˆˆˆåŒ9‰;Œ;˜+Ò%Ð%Ý" 5¨)Ñ4Ô4Ð4Ð4Ð4ð &Ð%ø�2Œ9‰;Œ;˜+Ò%Ð%Ý" 5¨)Ñ4Ô4Ð4Ð4ð &øøøs   Á#B Â*B<r8  c                óø   — t           sd S t          ¦   «         5  t          j        5  | t          t          | ¦  «        <   t          ¦   «          d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S rI   )rm   r}  r~  r½  rÈ  rª   Ú_refresh_owner_pins)r8  s    rM   r¢  r¢  Î  sø   € Ý ð ØˆÝ	Ñ	Ô	ð ð �[Ô6ð ð Ø&.�•b˜‘l”lÑ#ÝÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð ð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð ó4   ˜A/¥&AÁA/ÁA	ÁA/ÁA	ÁA/Á/A3Á6A3c                óø   — t           sd S t          ¦   «         5  t          j        5  | t          t          | ¦  «        <   t          ¦   «          d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S rI   )rm   r}  r~  r½  rÉ  rª   ré  r‘  s    rM   r�  r�  Ö  sø   € Ý ð ØˆÝ	Ñ	Ô	ð ð �[Ô6ð ð Ø!$�•b˜‘g”gÑÝÑÔÐðð ð ñ ô ð ð ð ð ð ð øøøð ð ð ð ð ð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð rê  r¬  r,  r-  rª  c                óÌ   — t           sd S t          ¦   «         5  |€"t          j        | ¦  «        }|j        |j        f}t          | |¦  «        cd d d ¦  «         S # 1 swxY w Y   d S rI   )rm   r}  rë   ÚfstatÚst_devÚst_inoÚ_record_owned_descriptor©r¬  r,  Ústat_results      rM   rm  rm  Þ  s¯   € Ý ð ØˆtÝ	Ñ	Ô	ð 6ð 6ØÐÝœ( 2™,œ,ˆKØ"Ô)¨;Ô+=Ð=ˆHÝ'¨¨HÑ5Ô5ð	6ð 6ð 6ð 6ñ 6ô 6ð 6ð 6ð 6ð 6ð 6ð 6øøøð 6ð 6ð 6ð 6ð 6ð 6s   ˜4AÁAÁ Ac                ó„   — t           sd S t          ¦   «         5  t          | d ¦  «        cd d d ¦  «         S # 1 swxY w Y   d S rI   )rm   r}  rð  )r¬  s    rM   ro  ro  è  sŒ   € Ý ð ØˆtÝ	Ñ	Ô	ð 2ð 2Ý'¨¨DÑ1Ô1ð2ð 2ð 2ð 2ñ 2ô 2ð 2ð 2ð 2ð 2ð 2ð 2øøøð 2ð 2ð 2ð 2ð 2ð 2s   ˜5µ9¼9c                óö   — t           j        5  t          t          ¦  «        }t	          | t          j        ¦   «         |€d n|d         |€d n|d         ¬¦  «        t          |<   d d d ¦  «         n# 1 swxY w Y   |S )Nr   r™   ©r¬  rµ  r¶  r·  )r~  r½  ÚnextrË  r´  rë   r,  rÊ  )r¬  r,  rr  s      rM   rð  rð  ï  s»   € Ý	Ô	"ð 
ð 
ÝÕ'Ñ(Ô(ˆÝ$4ØÝœ	™œØ#Ð+�4�4°¸!´Ø"Ð*�$�$°¸´ð	%
ñ %
ô %
Õ˜5Ñ!ð
ð 
ð 
ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
øøøð 
ð 
ð 
ð 
ð €Ls   �AA.Á.A2Á5A2rr  c                óü   — t          j        ¦   «         rd S t          ¦   «         5  t          j        5  t
                               | d ¦  «         d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S rI   )râ  rã  r}  r~  r½  rÊ  r©   )rr  s    rM   rq  rq  û  sû   € å
ÔÑÔð ØˆÝ	Ñ	Ô	ð ,ð ,�[Ô6ð ,ð ,Ý×Ò˜u dÑ+Ô+Ð+ð,ð ,ð ,ñ ,ô ,ð ,ð ,ð ,ð ,ð ,ð ,øøøð ,ð ,ð ,ð ,ð ,ð ,ð ,ñ ,ô ,ð ,ð ,ð ,ð ,ð ,ð ,ð ,øøøð ,ð ,ð ,ð ,ð ,ð ,s4   ¤A1±AÁA1ÁA	ÁA1Á A	Á!A1Á1A5Á8A5c            	     óº  — t          ¦   «          t          ¦   «         } g }	 t          j        5  t          j                             | d¦  «        dz   t          j        | <   dt          _        t          j        t          t          j	                             | d¦  «        ¦  «        k    rYt          j         
                    ¦   «          t          j        t          t          j	                             | d¦  «        ¦  «        k    °Yt          t          j	                             | i ¦  «                             ¦   «         ¦  «        }d d d ¦  «         n# 1 swxY w Y   t          ¦   «          d„ |D ¦   «         }|                     t          t           d„ |                     ¦   «         D ¦   «         ¦  «        ¦  «         t          j        5  t          j                             | g ¦  «                             t          |¦  «        ¦  «         t          j                             | g ¦  «                             t          t,                               ¦   «         ¦  «        ¦  «         t          j                             | g ¦  «                             t          t0                               ¦   «         ¦  «        ¦  «         d d d ¦  «         d S # 1 swxY w Y   d S # t          j        5  t          j                             | g ¦  «                             t          |¦  «        ¦  «         t          j                             | g ¦  «                             t          t,                               ¦   «         ¦  «        ¦  «         t          j                             | g ¦  «                             t          t0                               ¦   «         ¦  «        ¦  «         d d d ¦  «         w # 1 swxY w Y   w xY w)Nr   r™   TrJ   c                ó2   — i | ]}|®t          |¦  «        |“ŒS rI   )rª   )r¢   Úowners     rM   r  z%_pin_fork_objects.<locals>.<dictcomp>  s%   € ÐWÐWÐW uÀUÐEV•"�U‘)”)˜UÐEVÐEVÐEVrP   c              3  óH   K  — | ]}|                      ¦   «         D ]}|V — ŒŒd S rI   )rY   )r¢   rú  Ú
descriptors      rM   r¥   z$_pin_fork_objects.<locals>.<genexpr>  s;   è è € ÐiÐi È5×KfÒKfÑKhÔKhÐiÐi¸Z�ÐiÐiÐiÐiÐiÐiÐirP   )r  r   r~  r¼  rÁ  r)  rÀ  r¿  rº   r¾  r  r>  r‚  Ú_verify_unverified_descriptorsr±   r   Ú_snapshot_descriptor_for_forkr½  rÄ  Ú
setdefaultr¯   rÂ  rÈ  rÃ  rÉ  )rç  rÄ  Útransition_ownersÚownerss       rM   rÞ  rÞ    s  € ÝÑÔÐÝ‘”€IØ/1Ð!ðgÝÔð 	[ð 	[Ý7BÔ7T×7XÒ7XÐYbÐdeÑ7fÔ7fÐijÑ7j�KÔ)¨)Ñ4Ø+/�KÔ(ÝÔ0µ3µ{Ô7N×7RÒ7RÐS\Ð^`Ñ7aÔ7aÑ3bÔ3bÒbÐbÝÔ ×%Ò%Ñ'Ô'Ð'õ Ô0µ3µ{Ô7N×7RÒ7RÐS\Ð^`Ñ7aÔ7aÑ3bÔ3bÒbÐbå %¥kÔ&=×&AÒ&AÀ)ÈRÑ&PÔ&P×&WÒ&WÑ&YÔ&YÑ ZÔ ZÐð	[ð 	[ð 	[ñ 	[ô 	[ð 	[ð 	[ð 	[ð 	[ð 	[ð 	[øøøð 	[ð 	[ð 	[ð 	[õ 	'Ñ(Ô(Ð(ØWÐWÐ0AÐWÑWÔWˆØ%×,Ò,ÝÝ-ØiÐi¨¯ª©¬ÐiÑiÔiñô ñ	
ô 	
ð 	
õ Ô&ð 	gð 	gÝÔ5×@Ò@ÀÈBÑOÔO×VÒVÝÐ3Ñ4Ô4ñô ð õ Ô&×1Ò1°)¸RÑ@Ô@×GÒGÍÍm×NbÒNbÑNdÔNdÑHeÔHeÑfÔfÐfÝÔ&×1Ò1°)¸RÑ@Ô@×GÒGÍÍm×NbÒNbÑNdÔNdÑHeÔHeÑfÔfÐfð	gð 	gð 	gñ 	gô 	gð 	gð 	gð 	gð 	gð 	gð 	gð 	gøøøð 	gð 	gð 	gð 	gð 	gð 	gø�[Ô&ð 	gð 	gÝÔ5×@Ò@ÀÈBÑOÔO×VÒVÝÐ3Ñ4Ô4ñô ð õ Ô&×1Ò1°)¸RÑ@Ô@×GÒGÍÍm×NbÒNbÑNdÔNdÑHeÔHeÑfÔfÐfÝÔ&×1Ò1°)¸RÑ@Ô@×GÒGÍÍm×NbÒNbÑNdÔNdÑHeÔHeÑfÔfÐfð	gð 	gð 	gñ 	gô 	gð 	gð 	gð 	gð 	gð 	gð 	gøøøð 	gð 	gð 	gð 	gð 	gøøøsh    K ¬DEÄ<K ÅEÅK ÅEÅA!K Æ=C/J9Ê9J=Ë J=ËOËC/OÏOÏOÏOÏOÏOc                 óö  — t          ¦   «         } 	 t          j        5  t          j        |                               ¦   «         D ]}t
                               |d ¦  «         Œt          j        |                               ¦   «          t          j        |                               ¦   «          t          j        |          s't          j        | = t          j        | = t          j        | = d d d ¦  «         n# 1 swxY w Y   t          j        5  t          j	         
                    | d¦  «        x}dk    r!t          j	                             | d ¦  «         n|dz
  t          j	        | <   t          t          j	        ¦  «        t          _        t          j                             ¦   «          d d d ¦  «         d S # 1 swxY w Y   d S # t          j        5  t          j	         
                    | d¦  «        x}dk    r!t          j	                             | d ¦  «         n|dz
  t          j	        | <   t          t          j	        ¦  «        t          _        t          j                             ¦   «          d d d ¦  «         w # 1 swxY w Y   w xY w©Nr™   )r   r~  r½  rÄ  r©   rÊ  rÂ  rÃ  r¼  rÁ  r)  rw   rÀ  Ú
notify_all)rç  rr  Údepths      rM   rß  rß  !  sÔ  € Ý‘”€Ið*ÝÔ&ð 	:ð 	:Ý$ÔBÀ9ÔM×QÒQÑSÔSð 4ð 4�Ý"×&Ò& u¨dÑ3Ô3Ð3Ð3ÝÔ& yÔ1×5Ò5Ñ7Ô7Ð7ÝÔ& yÔ1×5Ò5Ñ7Ô7Ð7ÝÔ<¸YÔGð :ÝÔ=¸iÐHÝÔ.¨yÐ9ÝÔ.¨yÐ9ð	:ð 	:ð 	:ñ 	:ô 	:ð 	:ð 	:ð 	:ð 	:ð 	:ð 	:øøøð 	:ð 	:ð 	:ð 	:õ Ôð 	*ð 	*å$Ô6×:Ò:¸9ÀaÑHÔHÐH�ÈQÒNÐNÝÔ-×1Ò1°)¸TÑBÔBÐBÐBà;@À1¹9•Ô-¨iÑ8Ý+/µÔ0MÑ+NÔ+N�KÔ(ÝÔ×'Ò'Ñ)Ô)Ð)ð	*ð 	*ð 	*ñ 	*ô 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*øøøð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ø�[Ôð 	*ð 	*å$Ô6×:Ò:¸9ÀaÑHÔHÐH�ÈQÒNÐNÝÔ-×1Ò1°)¸TÑBÔBÐBÐBà;@À1¹9•Ô-¨iÑ8Ý+/µÔ0MÑ+NÔ+N�KÔ(ÝÔ×'Ò'Ñ)Ô)Ð)ð	*ð 	*ð 	*ñ 	*ô 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*øøøð 	*ð 	*ð 	*ð 	*ð 	*øøøsg   �F8 œCC,Ã F8 Ã,C0Ã0F8 Ã3C0Ã4F8 ÄBF+Æ+F/Æ2F/Æ8I8ÇBI,É I8É,I0É0I8É3I0É4I8c                 ó"   — t          ¦   «          d S rI   )rà  rJ   rP   rM   r  r  9  s   € ÝÑÔÐÐÐrP   c                 ór  — t          j        ¦   «         x} t          j        k    rd S t	          ¦   «         }t          j                             |dg¦  «        d         }t          j                             |dg¦  «        d         }g }t          t           
                    ¦   «         ¦  «        D ]=\  }}|j        | k    r-|                     t                               |¦  «        ¦  «         Œ>t                               ¦   «          | t          _        t                               ¦   «          t#          |||¦  «         d S )NrJ   r.   )rë   r,  r~  rÅ  r   rÂ  r)  rÃ  r>  rÊ  r2  rµ  r¯   r©   rÇ  rp  r9  Ú_detach_child_state)rÅ  rç  rÂ  rÃ  r?  rr  rü  s          rM   rà  rà  =  s	  € ÝŒy‰{Œ{Ðˆ�{œÒ.Ð.ØˆÝ‘”€IÝ Ô/×3Ò3°IÀ¸tÑDÔDÀRÔH€NÝ Ô/×3Ò3°IÀ¸tÑDÔDÀRÔH€NØ*,€KÝ"Õ#5×#;Ò#;Ñ#=Ô#=Ñ>Ô>ð >ð >ÑˆˆzØÔ! SÒ(Ð(Ø×ÒÕ1×5Ò5°eÑ<Ô<Ñ=Ô=Ð=øÝ×%Ò%Ñ'Ô'Ð'Ø…K„OÝ× Ò Ñ"Ô"Ð"Ý˜ ^°^ÑDÔDÐDÐDÐDrP   rç  c                óÂ  — t           j        5  t           j        rb|t           j        vrT|t           j        vrFt           j                             ¦   «          t           j        r|t           j        vr|t           j        v°Ft          t          ¦  «        }| t           j                             |i ¦  «        |<   t           xj	        dz  c_	        d d d ¦  «         n# 1 swxY w Y   |S r  )
r~  r¼  rÀ  rÁ  r¾  r  rö  rÌ  rÿ  r¿  )râ  rç  rr  s      rM   rå  rå  M  s  € Ý	Ô	ð 	,ð 	,åÔ(ð	$à¥Ô!>Ð>Ð>Ø¥Ô!8Ð8Ð8åÔ×!Ò!Ñ#Ô#Ð#õ	 Ô(ð	$à¥Ô!>Ð>Ð>Ø¥Ô!8Ð8Ð8õ Õ'Ñ(Ô(ˆØCS�Ô×*Ò*¨9°bÑ9Ô9¸%Ñ@ÝÐ&Ô&¨!Ñ+Ð&Ô&ð	,ð 	,ð 	,ñ 	,ô 	,ð 	,ð 	,ð 	,ð 	,ð 	,ð 	,øøøð 	,ð 	,ð 	,ð 	,ð €Ls   �B;CÃCÃCc                óþ   — t           j        5  t           j        |         }|| = |st           j        |= t           xj        dz  c_        t           j                             ¦   «          d d d ¦  «         d S # 1 swxY w Y   d S r  )r~  r¼  r¾  r¿  r  )rr  rç  Úowneds      rM   ræ  ræ  [  s¿   € Ý	Ô	ð &ð &Ý"Ô.¨yÔ9ˆØ�%ˆLØð 	3ÝÔ'¨	Ð2ÝÐ&Ô&¨!Ñ+Ð&Ô&ÝÔ×#Ò#Ñ%Ô%Ð%ð&ð &ð &ñ &ô &ð &ð &ð &ð &ð &ð &ð &øøøð &ð &ð &ð &ð &ð &s   �AA2Á2A6Á9A6c                 ó¦  — t           j        5  t          t                               ¦   «         ¦  «        D ]ƒ\  } }|j        t          j        ¦   «         k    s|j        �Œ)	 t          j	        |j
        ¦  «        }n# t          $ r Y ŒPw xY wt          |j
        |j        |j        |j        ¬¦  «        t          | <   Œ„	 d d d ¦  «         d S # 1 swxY w Y   d S )Nrõ  )r~  r½  r>  rÊ  r2  rµ  rë   r,  r¶  rí  r¬  r°  r´  rî  rï  )rr  rü  rò  s      rM   rý  rý  e  s(  € Ý	Ô	"ð ð Ý!&Õ'9×'?Ò'?Ñ'AÔ'AÑ!BÔ!Bð 	ð 	ÑˆE�:ØÔ%­¬©¬Ò4Ð4¸
Ô8IÐ8UØðÝ œh z¤}Ñ5Ô5��øÝð ð ð Ø�ðøøøå(8Ø”=Ø&Ô2Ø"Ô)Ø!Ô(ð	)ñ )ô )Õ˜uÑ%Ð%ð	ðð ð ñ ô ð ð ð ð ð ð ð øøøð ð ð ð ð ð s6   �ACÁA8Á7CÁ8
BÂCÂBÂ3CÃC
ÃC
c                óŽ   — |€4	 t          j        | ¦  «        }|j        |j        f}n# t          $ r Y nw xY wt          | |¦  «        S rI   )rë   rí  rî  rï  r°  rð  rñ  s      rM   rþ  rþ  v  sb   € ØÐð	>Ýœ( 2™,œ,ˆKð #Ô)¨;Ô+=Ð=ˆHˆHøõ ð 	ð 	ð 	ØˆDð	øøøõ $ B¨Ñ1Ô1Ð1s   „' §
4³4r?  úlist[_OwnedDescriptor]rÂ  útuple[_ForkResettable, ...]rÃ  ú tuple[_ForkResettableClass, ...]c                óè  — | D ]ž}|j         €Œ
	 t          j        |j        ¦  «        }n# t          $ r Y Œ1w xY w|j        |j        f|j         |j        fk    rŒTt          j	        t          ¦  «        5  t          j
        |j        ¦  «         d d d ¦  «         n# 1 swxY w Y   ŒŸ|D ]}|                     ¦   «          Œ|D ]}|                     ¦   «          Œt          j                             ¦   «          d S rI   )r¶  rë   rí  r¬  r°  rî  rï  r·  rí  r8   r¯  rN   r^   rü   rø   r9  )r?  rÂ  rÃ  rü  rò  r8  r  s          rM   r  r  �  sV  € ð
 "ð 
$ð 
$ˆ
ØÔÐ$Øð	Ýœ( :¤=Ñ1Ô1ˆKˆKøÝð 	ð 	ð 	ØˆHð	øøøàÔ Ô 2Ð3¸
Ô8IÈ:ÔK[Ð7\Ò\Ð\ØÝÔ ¥Ñ)Ô)ð 	$ð 	$ÝŒH�Z”]Ñ#Ô#Ð#ð	$ð 	$ð 	$ñ 	$ô 	$ð 	$ð 	$ð 	$ð 	$ð 	$ð 	$øøøð 	$ð 	$ð 	$ð 	$øà"ð .ð .ˆØ×+Ò+Ñ-Ô-Ð-Ð-Øð &ð &ˆØ×#Ò#Ñ%Ô%Ð%Ð%Ý„N×ÒÑÔÐÐÐs   Ž(¨
5´5Á0BÂB	ÂB	c                 ó  — t           j        5  t          t           j        ¦  «        } d d d ¦  «         n# 1 swxY w Y   t	          ¦   «         | vrd S t          t
                               ¦   «         ¦  «        }t          t                               ¦   «         ¦  «        }| D ]c}t           j         	                    |¦  «        x}r@|gt          |¦  «        z  |d d …<   |gt          |¦  «        z  t           j        |         d d …<   Œdd S rI   )r~  r¼  r>  rÁ  r   rÈ  r‚  rÉ  rÂ  r)  rº   rÃ  )Úfork_owner_thread_idsÚobjectsÚclassesrç  Úobject_snapshotss        rM   ré  ré  ˜  sL  € Ý	Ô	ð Eð EÝ %¥kÔ&CÑ DÔ DÐðEð Eð Eñ Eô Eð Eð Eð Eð Eð Eð Eøøøð Eð Eð Eð Eå�{„{Ð/Ð/Ð/ØˆÝ•M×(Ò(Ñ*Ô*Ñ+Ô+€GÝ•M×(Ò(Ñ*Ô*Ñ+Ô+€GØ*ð Yð Yˆ	Ý*Ô9×=Ò=¸iÑHÔHÐHÐð 	YØ#* )­cÐ2BÑ.CÔ.CÑ"CÐ˜Q˜Q˜QÑØ8?°yÅ3ÐGWÑCXÔCXÑ7X�KÔ& yÔ1°!°!°!Ñ4øðYð Ys   �3³7º7)Ú_fork_eventsÚ_stateÚ
_get_identÚeventÚ_argsr@   r  r†  r  r  úCallable[[], int]c               ó¾   — | |v r. |¦   «         |j         v s|j        r| › d�}t          |¦  «        ‚d S | dk    r" |¦   «         |j         v rd}t          |¦  «        ‚d S d S )Nz: is unsafe while filelock is changing descriptor ownershipz_posixsubprocess.fork_execzCfork_exec is unsafe while filelock is changing descriptor ownership)r¾  rÁ  r+  )r  r  r  r  r  r9  s         rM   rÝ  rÝ  §  s‘   € ð �ÐÐØˆ:‰<Œ<˜6Ô-Ð-Ð-°Ô1IÐ-ØÐVÐVÐVˆCÝ˜sÑ#Ô#Ð#ð .Ð-ð 
Ð.Ò	.Ð	.°:°:±<´<À6ÔCUÐ3UÐ3UØSˆÝ˜3ÑÔÐð 
/Ð	.Ð3UÐ3UrP   )r/   r  rþ   r€   r~   rŸ  r  rr   rž  r�  rÇ   rò   rI  r²  r  r}  rÏ   rà   rÙ   rå   r�   r�  r¢  rm  r  r‹  r  r   r0  rq  )rŠ   r‹   rF   rw   )r’   r“   r”   r‹   r•   r‹   r–   r‹   r‘   r—   rF   r$   )rœ   rž   rF   rG   )rµ   r‹   r¶   r‹   rF   rw   )rŠ   r‹   r¿   rÀ   rF   rw   )rŠ   r‹   r¤   r‹   rF   rG   )rŠ   r‹   r¿   r‹   rF   rw   )rŠ   r‹   r’   r“   r‘   rË   rF   rÌ   rI   )r”   r‹   r•   rÀ   rF   r$   )rŠ   r‹   r¿   r‹   rF   rG   )rÜ   r‹   rÝ   r‹   rF   r$   )r’   r“   rá   r‹   râ   rÀ   rF   r$   )rè   ré   rF   r“   )r}   r|   r  r?  r  ru   rF   r|   )r{   rs   rF   rs   )ry   rw   rF   rG   )rñ   r“   rL  rs   rF   rs   )rv   ru   r  r“   rF   rG   )rX  r“   rF   r~   )rX  r“   rF   r€   )r  rw   r  rw   r  r“   rF   rw   )r…   r„   r  rw   r  r“   rF   r„   )r  r?  r6  r_  rF   r_  )rt   rs   r  rw   rF   rk  )rñ   r“   rL  rs   rF   rG   )r  r?  rF   rq  )rt   rs   ry   rw   rF   rs   )rÿ  r<   ry   rw   rt   rs   r{   rs   rö  rø  rF   rw   )r’  r“  r  r?  r”  r•  rF   rG   )r   r¡  rF   rw   )rñ   r“   rF   rÔ   rQ   )râ  rã  rF   r  )r8  rE   rF   rG   )r  r\   rF   rG   )r¬  ru   r,  r-  rF   rª  )r¬  ru   rF   rª  )r¬  ru   r,  r-  rF   ru   )rr  ru   rF   rG   )râ  rã  rç  ru   rF   ru   )rr  ru   rç  ru   rF   rG   )r?  r  rÂ  r  rÃ  r  rF   rG   )r  r“   r  r@   r  r†  r  r¹  r  r  rF   rG   )ÅÚ
__future__r   Ú__lazy_modules__r   rí  r   Úloggingr   rë   r	   rU  râ  r  r
   r   Úabcr   r   Úcollections.abcr   r   r   Údataclassesr   r   r   r   Ú	functoolsr   r   Ú	itertoolsr   r   r   r   Ú	threadingr   r   r   r   r   r   r   Útypingr    r!   r"   r#   r$   r%   r&   r'   Úweakrefr(   r)   r*   Úfilelock._errorr+   r,   Úfilelock._utilr-   r/   rˆ   ÚS_IRWXUÚS_IRWXGÚS_IRWXOr0   r2   r~   rƒ  r5   r€   r9   r:   r;   r<   r=   r>   r?   Ú	_typeshedr@   Úfilelock._leaserA   Úfilelock._read_writerB   Úfilelock._soft_rwrC   rE   rV   r\   r`   rh   Ú	getLoggerrj   rÎ   rl   rm   rn   ro   rp   rs   ru   rw   r“   Ú_LockInitValuerr   r�   r�   rš   r­   r¡   rÇ   rÄ   rÏ   r¦   rÙ   rÖ   rà   rå   Úplatformrè   ÚabspathÚrealpathrç   rò   rô   rü   rý   r   r  r  r  r  r   r!  r"  r#  r$  r&  r(  r0  rI  rp  rg  rq  ÚContextDecoratorrþ   r‹  r�  r  rñ  r§   ró  rô  r  r  r  rŸ  rž  r²  Ú_fieldr›   rñ   r´  r¹  rÈ  rÉ  rÊ  rË  rÌ  r~  rÍ  ÚimplementationÚversion_inforÐ  r  rÕ  rá  r}  r¢  r�  rm  ro  rð  rq  rÞ  rß  r  rà  rå  ræ  rý  rþ  r  ré  rÝ  Ú__all__rJ   rP   rM   ú<module>r<     s  ðØ "Ð "Ð "Ð "Ð "Ð "Ð "ðð ð Ð ð €€€Ø Ð Ð Ð Ø €€€Ø €€€Ø €€€Ø 	€	€	€	Ø €€€Ø €€€Ø 
€
€
€
Ø €€€Ø €€€Ø €€€Ø 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ø .Ð .Ð .Ð .Ð .Ð .Ð .Ð .Ø %Ð %Ð %Ð %Ð %Ð %Ø )Ð )Ð )Ð )Ð )Ð )Ð )Ð )Ø Ð Ð Ð Ð Ð Ø $Ð $Ð $Ð $Ð $Ð $Ð $Ð $Ø $Ð $Ð $Ð $Ð $Ð $Ð $Ð $Ø Ð Ð Ð Ð Ð Ø ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ø ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ð ]Ø ?Ð ?Ð ?Ð ?Ð ?Ð ?Ð ?Ð ?Ð ?Ð ?à @Ð @Ð @Ð @Ð @Ð @Ð @Ð @Ø 2Ð 2Ð 2Ð 2Ð 2Ð 2ð  "Ð Ð !Ð !Ð !Ñ !à#œ|¨d¬lÑ:¸T¼\ÑIÐ Ð IÐ IÐ IÑ Ið %'Ð Ð &Ð &Ð &Ñ &ð Ð-Ô.Ð Ø1:°¸GÀWÐ;MÑ1NÔ1NÐ Ð NÐ NÐ NÑ Nð Ð9Ô:Ð Ø/8¨yÐ9YÐ9YÐ9YÑ/ZÔ/ZÐ Ð ZÐ ZÐ ZÑ Zàð  Ø2Ð2Ð2Ð2Ð2Ð2Ð2Ð2ØÐÐÐÐÐØ.Ð.Ð.Ð.Ð.Ð.Ð.Ð.ØÐÐÐÐÐà Ð Ð Ð Ð Ð à+Ð+Ð+Ð+Ð+Ð+Ø2Ð2Ð2Ð2Ð2Ð2Ø3Ð3Ð3Ð3Ð3Ð3ð:ð :ð :ð :ð :˜(ñ :ô :ð :ð_ð _ð _ð _ð _˜xñ _ô _ð _ð
7ð 7ð 7ð 7ð 7˜xñ 7ô 7ð 7ðð ð ð ð ˜(ñ ô ð ð ÐÐÐÐÐà!2 Ô!2°:Ñ!>Ô!>€Ð >Ð >Ð >Ñ >Ø37°4Ð8PÐRYÐRYÐZ\Ð^pÐrvÑRwÔRwÑ3xÔ3xÐ Ð xÐ xÐ xÑ xØ%6¸dÐ%BÐ Ð BÐ BÐ BÑ Bàˆg�mÑ$Ô$€Øˆw�~Ñ&Ô&€Ø�Ð)Ñ*Ô*€Ø˜‘˜tÑ# cÑ)¨DÑ0°8¸S¸EÀ4¸KÔ3HÑH€ð.ð .ð .ð .ð .�) 5ð .ñ .ô .ð .ñ"1ð 1ð 1ð 1ð /3ðð ñ ð ð ð ñNð Nð Nð Nñ,ð ð ð ñ0ð ð ð ñ"ð ð ð ñ ð ð ð ñ&sð sð sð sð ð ?ð?ð ?ð ?ð ?ð ? (ñ ?ô ?ð ?ññ ð ð ð ñ0Pð Pð Pð Pñ$Zð Zð Zð Zñ	ð 	ð 	ð 	ð @C¼|ÈwÒ?VÐ?V¨B¬G¬O¨OÐ\^Ô\cÔ\l€Ð lÐ lÐ lÑ lñAð Að Að Að,ð ,ð ,ð ,ð ,˜5ñ ,ô ,ð ,ð *>Ð)=Ñ)?Ô)?€	Ð ?Ð ?Ð ?Ñ ?ð €WˆT˜Ð(Ñ(Ô(€Ø	ˆ�Ð!SÐ	TÑ	TÔ	T€ðð ð ð ð �7ñ ô ð ñD!ð !ð !ð !ñHð ð ð ñð ð ð ñEð Eð Eð Eñ"ð ð ð ñ".ð .ð .ð .ñ,ð ,ð ,ð ,ñð ð ð ñ
ð 
ð 
ð 
ñ\ð \ð \ð \ñ"Vð Vð Vð Vñð ð ð ð ]nÐ\mÑ\oÔ\oÐ Ð oÐ oÐ oÑ oñð ð ð ð, €�$ÐÑÔð1ð 1ð 1ð 1ð 1ñ 1ô 1ñ Ôð1ðM"ð M"ð M"ð M"ð M"�:Ô.¸,ð M"ñ M"ô M"ð M"ñ` ð ð ð ñð ð ð ñ$2ð 2ð 2ð 2ð €� DÐ)Ñ)Ô)ð$ð $ð $ð $ð $ñ $ô $ñ *Ô)ð$ð 58°C±E´EÐ Ð 9Ð 9Ð 9Ñ 9ñ
ð 
ð 
ð 
ñBð Bð Bð Bñð ð ð ðð ð ð ð ˜ œñ ô ð ð. ð5+ð 5+ð 5+ð 5+ð 5+ñ 5+ô 5+ñ „ð5+ðp
ð 
ð 
ð 
ð 
˜_¨eñ 
ô 
ð 
ñ>ð ð ð ð ˆf�_Ñ%Ô%ð Tð T€FØ€GÐ" F¤KÐ1EÐ1EÀfÄkÑ1RÔ1RÑSÔSÐSÐSð €�$ÐÑÔðð ð ð ð ñ ô ñ Ôðð0ð 0ð 0ð 0ð 0ñ 0ô 0ð 0ð6 CVÐBUÑBWÔBW€Ð WÐ WÐ WÑ WØGZÐGZÑG\ÔG\€Ð \Ð \Ð \Ñ \Ø9;Ð Ð ;Ð ;Ð ;Ñ ;Ø(-¨©¬Ð Ð /Ð /Ð /Ñ /Ø(-¨©¬Ð Ð /Ð /Ð /Ñ /Ø�Z‘\”\€Ð !Ð !Ð !Ñ !Ø,5¨I°yÀ,Ð6OÑ,PÔ,PÐ Ð PÐ PÐ PÑ Pð /2Ô.@Ô.EÈÒ.RÐ.qÐVYÔVfÐjqÒVqÐ Ð qÐ qÐ qÑ qð ñ/ð /ð /ñ „ð/ñ
/ð /ð /ð /ñ	ð 	ð 	ð 	ð ñ5ñ 5ð 5ð 5ñ „ð5ñ"ð ð ð ñð ð ð ñ6ñ 6ð 6ð 6ð 6ñ2ð 2ð 2ð 2ñ	ð 	ð 	ð 	ñ,ð ,ð ,ð ,ñgð gð gð gñ<*ð *ð *ð *ñ0ð ð ð ñEð Eð Eð Eñ ð ð ð ñ&ð &ð &ð &ñð ð ð ñ"2ð 2ð 2ð 2ñð ð ð ñ.
Yð 
Yð 
Yð 
Yð& $6Ø$Ø$-ð ð  ñ  ñ  ð  ð  ð" Ð Ñ Ô Ð ðñ ð €€€rP   