ó [³XMc@sCdZeZddlZddlZddlmZd„ZddlmZyJddlm Z ddlm Z ddlm Z dd lm Z eZWn}eZy dd lmZddlZWnek rÜdZ nXd Zd Zd „Z eZd„Z d„Z d„Z nXddd„ƒYZd„ZddgZdS(s& Filesystem-based interprocess mutex. iÿÿÿÿN(ttimecCstttƒdƒƒS(Niè(tstrtlongt _uniquefloat(((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pytuniques(trename(tkill(tsymlink(treadlink(tremove(t OpenProcessiiWcCsytdd|ƒWnXtjk rn}|jdtkr@dS|jdtkrhttjdƒ‚n‚n Xt dƒ‚dS(Nis OpenProcess is required to fail.( R t pywintypesterrortargstERROR_ACCESS_DENIEDtERROR_INVALID_PARAMETERtOSErrorterrnotESRCHtNonet RuntimeError(tpidtsignalte((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pyR&scCs£|dtƒd}tjj|dƒ}tj|ƒt|dƒ}|j|ƒ|jƒ|jƒyt ||ƒWn$tj |ƒtj |ƒ‚nXdS(Nt.s.newlinkRtwcb( Rtostpathtjointmkdirt_opentwritetflushtcloseRR trmdir(tvaluetfilenamet newlinknamet newvalnametf((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pyR5s      cCs’y"ttjj|dƒdƒ}WnOtk rs}|jtjksX|jtjkrmt|jdƒ‚n‚nX|j ƒ}|j ƒ|SdS(NRtrb( RRRRtIOErrorRtENOENTtEIORRtreadR!(R$tfObjRtresult((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pyRDs"$  cCs-tjtjj|dƒƒtj|ƒdS(NR(RR RRR"(R$((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pytrmlinkPstFilesystemLockcBs5eZdZdZeZd„Zd„Zd„Z RS(s 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. cCs ||_dS(N(tname(tselfR1((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pyt__init__lscCs²t}x¥tr­y tttjƒƒ|jƒWnetk r–}trf|jtj tj fkrft S|jtj kryt |jƒ}Wn_tk r»}|jtjkrµq n‚n2tk rì}træ|jtj kræt S‚nXy&tdk rtt|ƒdƒnWnvtk r‹}|jtjkr…yt|jƒWn.tk rx}|jtjkrrq n‚nXt }q n‚nXt S‚nXt|_||_tSWdS(sÏ 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. iN(tTrueRRRtgetpidR1Rt_windowsRtEACCESR+tFalsetEEXISTRR*R)RRtintRR/tlockedtclean(R2R<RR((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pytlockpsJ   !   cCsZt|jƒ}t|ƒtjƒkr@td|jfƒ‚nt|jƒt|_dS(sÕ 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. s!Lock %r not owned by this processN( RR1R:RR5t ValueErrorR/R8R;(R2R((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pytunlock°s  N( t__name__t __module__t__doc__RR<R8R;R3R=R?(((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pyR0Vs   @cCs>t|ƒ}d}z|jƒ}Wd|r8|jƒnX| S(sÚ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(R0RR=R?(R1tlR.((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pytisLockedÀs RD((RBttypet __metaclass__RRRRRRRRRR R/R8R6R4twin32apiR R t ImportErrorRRRtfileRR0RDt__all__(((s;/usr/lib/python2.7/dist-packages/twisted/python/lockfile.pyts8       j