o i @sZdZddlZddlZddlZddlZddlZddlZeeZ ej j Z Gddde ZdS)z[Provides a mechanism for not competing with other processes interacting with an MSAL cache.Nc@s0eZdZdZddZddZddZdd Zd S) CrossPlatLockzOffers a mechanism for waiting until another process is finished interacting with a shared resource. This is specifically written to interact with a class of the same name in the .NET extensions library. cCs&||_tj|dtjtjBdd|_dS)Nzwb+r)modeflags buffering) _lockpath portalockerLockLOCK_EXLOCK_NB_lock)selfZ lockfile_pathr Q/home/app/Keep/.python/lib/python3.10/site-packages/msal_extensions/cache_lock.py__init__s  zCrossPlatLock.__init__cCsd}d}ttdtj}||}t}||kr]zt|jd  WdWdS1s.wYWn#tyCtdYdSt yWt d||t |Ynw||ksdS) Ng? monotonicxTz1Python 2 does not support atomic creation of fileFz?Process %d found existing lock file, will retry after %f second) getattrtimeosgetpidopenr ValueErrorloggerwarningFileExistsErrordebugsleep)r timeoutZcheck_interval current_timeZ timeout_endpidr r r_try_to_create_lock_file%s,  &     z&CrossPlatLock._try_to_create_lock_filecCsHt}|std||j}|d|t j d d|S)Nz%Process %d failed to create lock filez{} {}rzutf-8) rrr!rrr __enter__writeformatsysargvencode)r r Z file_handler r rr"9s   zCrossPlatLock.__enter__c GsZ|jj|z t|jWdSty,}z|jtjtjfvr!WYd}~dSd}~ww)N) r __exit__rremoverOSErrorerrnoENOENTEACCES)r argsexr r rr(As zCrossPlatLock.__exit__N)__name__ __module__ __qualname____doc__rr!r"r(r r r rrs  r)r3rr%r+rloggingr getLoggerr0r exceptionsZ LockExceptionZ LockErrorobjectrr r r rs