a )(bZ@sdZddlZddlZddlmZddlmZddZddlmZe sfddlm Z m Z m Z mZd Zn`d ZzddlZdd lmZWneydZ Yn0d Zd ZddZ eZddZddZ ddZ GdddZddZddgZdS)z& Filesystem-based interprocess mutex. N)time)platformcCstttdS)Ni)strint _uniquefloatrr6lib/python3.9/site-packages/twisted/python/lockfile.pyuniquesr )rename)killreadlinkremovesymlinkFT) OpenProcessWc Cs|ztdd|Wn^tjyn}zD|jdtkr>WYd}~dS|jdtkrXttjdWYd}~nd}~00t ddS)Nrz OpenProcess is required to fail.) r pywintypeserrorargsERROR_ACCESS_DENIEDERROR_INVALID_PARAMETEROSErrorerrnoESRCH RuntimeError)pidsignalerrrr 4s r cCs|dtd}tj|d}t|d}t||"}|||Wdn1s`0Yzt||Wn(t yt |t |Yn0dS)z Write a file at C{filename} with the contents of C{value}. See the above comment block as to why this is needed. .z.newlinkrwN) r ospathjoinmkdir_openwriteflushr BaseExceptionr rmdir)valuefilenameZ newlinknameZ newvalnamemodefrrrrEs   &   rc Cszttj|dd}WnJtyb}z2|jtjks@|jtjkrLt|jdWYd}~n:d}~00||}Wdn1s0Y|SdS)zq Read the contents of C{filename}. See the above comment block as to why this is needed. rrN) r$r r!r"rrENOENTEIOread)r*ZfObjrresultrrrr `s &r cCs"ttj|dt|dS)Nr)r r r!r"r()r*rrrrmlinkrsr2c@s0eZdZdZdZdZddZddZdd ZdS) FilesystemLocka A mutex. This relies on the filesystem property that creating a symlink is an atomic operation and that it will fail if the symlink already exists. Deleting the symlink will release the lock. @ivar name: The name of the file associated with this lock. @ivar clean: Indicates whether this lock was released cleanly by its last owner. Only meaningful after C{lock} has been called and returns True. @ivar locked: Indicates whether the lock is currently held by this object. NFcCs ||_dS)N)name)selfr4rrr__init__szFilesystemLock.__init__cCsd}zttt|jWnty}ztrV|jtjtj fvrVWYd}~dS|jtj krzt |j}Wnrty}zZ|jtj krWYd}~WYd}~qn(tr|jtjkrWYd}~WYd}~dSWYd}~n d}~00zt durt t|dWnty}z|jtjkrzt|jWnVty}z<|jtj krnWYd}~WYd}~WYd}~qWYd}~n d}~00d}WYd}~WYd}~qWYd}~n d}~00WYd}~dSWYd}~n d}~00d|_||_dS)z Acquire this lock. @rtype: C{bool} @return: True if the lock is acquired, false otherwise. @raise OSError: Any exception L{os.symlink()} may raise, other than L{errno.EEXIST}. TNFr)rrr getpidr4r_windowsrZEACCESr/ZEEXISTr r.r rrr2lockedclean)r5r:rrrrrlocksD   zFilesystemLock.lockcCs@t|j}t|tkr,td|jdt|jd|_dS)z Release this lock. This deletes the directory with the given name. @raise OSError: Any exception L{os.readlink()} may raise. @raise ValueError: If the lock is not owned by this process. zLock z not owned by this processFN)r r4rr r7 ValueErrorr2r9)r5rrrrunlocks  zFilesystemLock.unlock) __name__ __module__ __qualname____doc__r:r9r6r;r=rrrrr3ws =r3cCs:t|}d}z|}W|r4|n|r2|0| S)z Determine if the lock of the given name is held or not. @type name: C{str} @param name: The filesystem path to the lock to test @rtype: C{bool} @return: True if the lock is held, False otherwise. N)r3r;r=)r4lr1rrrisLockeds    rC)rArr rrZtwisted.python.runtimerr r Z isWindowsr r r r2rr8rZwin32apir ImportErrorrropenr$r3rC__all__rrrrs2       f