B nôb\i$ã@s dZeZddlZddlZddlmZddlZddlm Z ddl m Z m Z dd„Z ddlmZejd ksœdd lmZdd lmZdd lmZdd lmZdZnLdZddlZddlmZdZdZdd„Zdd„ZeZdd„Zdd„Zdd„ZGdd„dƒZdd „Zdd gZdS)!aŽ Filesystem-based interprocess mutex. Taken from the Twisted project. Distributed under the MIT (Expat) license. Changes by the Spyder Team to the original module: * Rewrite kill Windows function to make it more reliable. * Detect if the process that owns the lock is an Spyder one. Adapted from src/twisted/python/lockfile.py of the `Twisted project `_. éN)Útime)Úrunning_under_pytest)ÚPY2Úto_binary_stringcCs,trtttƒdƒƒStttƒdƒƒSdS)Niè)rÚstrZlongÚ _uniquefloatÚint©r r ú=lib/python3.7/site-packages/spyder/utils/external/lockfile.pyÚunique"sr )ÚrenameÚnt)Úkill)Úsymlink)Úreadlink)ÚremoveFT)ÚwintypesiicCs\tjj}| td|¡}|dkr"dSt ¡}| |t |¡¡}|dk}|  |¡|pZ|j t kS)z/Taken from https://www.madebuild.org/blog/?p=30rF) ÚctypesZwindllÚkernel32Z OpenProcessÚPROCESS_QUERY_INFORMATIONrZDWORDZGetExitCodeProcessZbyrefZ CloseHandleÚvalueÚ STILL_ACTIVE)ÚpidrZhandleZ exit_codeZretvalZ is_runningr r r Ú_is_pid_running<s  rcCst|ƒsttjdƒ‚ndSdS)N)rÚOSErrorÚerrnoÚESRCH)rÚsignalr r r rOsrc Cs¦|dtƒd}tj |d¡}t |¡t|dƒ}| t|ƒ¡| ¡|  ¡yt ||ƒWn@yt  |¡t  |¡Wnt tfk r˜YnX‚YnXdS)NÚ.z.newlinkrÚwb)r ÚosÚpathÚjoinÚmkdirÚ_openÚwriterÚflushÚcloser rÚrmdirÚIOErrorr)rÚfilenameZ newlinknameZ newvalnameÚfr r r rXs    rc Cs~yttj |d¡dƒ}WnHtk r`}z*|jtjksB|jtjkrNt|jdƒ‚‚Wdd}~XYnX|  ¡  ¡}|  ¡|SdS)NrÚrb) r$r r!r"r)rÚENOENTÚEIOrÚreadÚdecoder')r*ZfObjÚeÚresultr r r rjs  rcCs"t tj |d¡¡t |¡dS)Nr)r rr!r"r()r*r r r Úrmlinkvsr3c@s0eZdZdZdZdZdd„Zdd„Zdd „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)Úselfr5r r r Ú__init__’szFilesystemLock.__init__cCsd}xyttt ¡ƒ|jƒWnÚtk rü}z¸trR|jtjtj fkrRdS|jtj krêyt |jƒ}Wnhtk r }z|jtj krŽw‚Wdd}~XYn8t k rÖ}ztrÄ|jtjkrÄdS‚Wdd}~XYnXyŒtdk rðtt|ƒdƒt t|ƒ¡}tddddd d gƒ}tƒr$| d ¡td d „| ¡dd…Dƒƒ}||@g}t|ƒsbttjdƒ‚Wn€tk rä}z`|jtjkrÒyt|jƒWn6tk rÊ}z|jtj kr¸w‚Wdd}~XYnXd}w‚Wdd}~XYnXdS‚Wdd}~XYnXd|_||_dSdS)zÏ Acquire this lock. @rtype: C{bool} @return: True if the lock is acquired, false otherwise. @raise: Any exception os.symlink() may raise, other than EEXIST. TFNrZspyderZspyder3z spyder.exez spyder3.exez bootstrap.pyzspyder-script.pyz runtests.pycss|]}tj |¡VqdS)N)r r!Úbasename)Ú.0Úargr r r ú Êsz&FilesystemLock.lock..ézNo such process)rrr Úgetpidr5rÚ_windowsrZEACCESr.ZEEXISTrr-r)rrÚpsutilZProcessÚsetrÚaddZcmdlineÚanyrr3ÚlockedÚclean)r6rDr1rÚpÚnamesZ argumentsZ conditionsr r r Úlock•s`     zFilesystemLock.lockcCs>t|jƒ}t|ƒt ¡kr*td|jfƒ‚t|jƒd|_dS)zÕ Release this lock. This deletes the directory with the given name. @raise: Any exception os.readlink() may raise, or ValueError if the lock is not owned by this process. z!Lock %r not owned by this processFN)rr5rr r=Ú ValueErrorr3rC)r6rr r r Úunlockås  zFilesystemLock.unlock) Ú__name__Ú __module__Ú __qualname__Ú__doc__rDrCr7rGrIr r r r r4|s Pr4cCs.t|ƒ}d}z | ¡}Wd|r&| ¡X| 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)r4rGrI)r5Úlr2r r r ÚisLockedõs   rO) rMÚtypeZ __metaclass__rr rrr?Zspyder.config.baserZspyder.py3compatrrr r r5rrrrr3r>rrrrrÚopenr$r4rOÚ__all__r r r r Ús8          y