ó [³XMc@sÓdZddlZddlZddlmZddlmZddlmZdZ ej ƒry ddl m Z ddlZWqek r™dZ qXndejfd „ƒYZd ejfd „ƒYZdS( s' Tests for L{twisted.python.lockfile}. iÿÿÿÿN(tunittest(tlockfile(tplatform(t OpenProcesssZOn windows, lockfile.kill is not implemented in the absence of win32api and/or pywintypes.t UtilTestscBseZdZd„Zd„Zejƒs6de_nd„Zd„Z ejƒs`de _nd„Z e e _d„Z e e _d „Z RS( sM Tests for the helper functions used to implement L{FilesystemLock}. cCsQ|jƒ}tjd|ƒ|jttjd|ƒ}|j|jtjƒdS(s  L{lockfile.symlink} raises L{OSError} with C{errno} set to L{EEXIST} when an attempt is made to create a symlink which already exists. tfooN(tmktempRtsymlinkt assertRaisestOSErrort assertEqualterrnotEEXIST(tselftnametexc((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_symlinkEEXISTs cCs]|jƒ}d„}|jtd|ƒ|jttj|dƒ}|j|jtjƒdS(s< L{lockfile.symlink} raises L{OSError} with C{errno} set to L{EIO} when the underlying L{rename} call fails with L{EIO}. Renaming a file on Windows may fail if the target of the rename is in the process of being deleted (directory deletion appears not to be atomic). cSsttjdƒ‚dS(N(tIOErrorR tEIOtNone(tsrctdst((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt fakeRename1strenameRN( RtpatchRRRRR R R(R RRR((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_symlinkEIOWindows's  sBspecial rename EIO handling only necessary and correct on Windows.cCs>|jƒ}|jttj|ƒ}|j|jtjƒdS(sŸ L{lockfile.readlink} raises L{OSError} with C{errno} set to L{ENOENT} when an attempt is made to read a symlink which does not exist. N(RRR RtreadlinkR R tENOENT(R RR((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_readlinkENOENT<s cCsZ|jƒ}d„}|jtd|ƒ|jttj|ƒ}|j|jtjƒdS(s\ L{lockfile.readlink} raises L{OSError} with C{errno} set to L{EACCES} on Windows when the underlying file open attempt fails with C{EACCES}. Opening a file on Windows may fail if the path is inside a directory which is in the process of being deleted (directory deletion appears not to be atomic). cSsttjdƒ‚dS(N(RR tEACCESR(tpathtmode((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pytfakeOpenPst_openN( RRRRRRR R R(R RR R((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_readlinkEACCESWindowsFs  sGspecial readlink EACCES handling only necessary and correct on Windows.cCstjtjƒdƒdS(s} L{lockfile.kill} returns without error if passed the PID of a process which exists and signal C{0}. iN(Rtkilltostgetpid(R ((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt test_kill[scCs5|jttjddƒ}|j|jtjƒdS(s L{lockfile.kill} raises L{OSError} with errno of L{ESRCH} if passed a PID which does not correspond to any process. iiiiNllÿÿ(RR RR#R R tESRCH(R R((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_killESRCHdscCsI|jtddƒtj|jƒƒ}|jƒ|j|jƒƒdS(sµ Verify that when L{lockfile.kill} does end up as None (e.g. on Windows without pywin32), it doesn't end up being called and raising a L{TypeError}. R#N(RRRtFilesystemLockRtlockt assertFalse(R tfl((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_noKillCallos (t__name__t __module__t__doc__RRRt isWindowstskipRR"R&tskipKillR(R-(((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRs          tLockingTestCasecBs eZd„Zd„Zd„Zejƒr9de_nd„Zd„Z d„Z d„Z d„Z d „Z ejƒs‡d e _nd „Zejƒs¨d e_nd „Zd„Zd„ZejƒrÛde_nd„Zd„Zd„Zd„Zd„ZRS(csi‡fd†}|jtd|ƒ|jƒ}tj|ƒ}|jt|jƒ}|j|jˆƒdS(Ncstˆdƒ‚dS(N(R R(tsourcetdest(R (s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt fakeSymlink~sR( RRRR)RR R*R R (R R R7tlockfR*R((R s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt_symlinkErrorTest}s  cCs|jtjƒdS(s† An exception raised by C{symlink} other than C{EEXIST} is passed up to the caller of L{FilesystemLock.lock}. N(R9R tENOSYS(R ((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_symlinkErrorˆscCs$|jtjƒ|jtjƒdS(s  An L{OSError} raised by C{symlink} on a POSIX platform with an errno of C{EACCES} or C{EIO} is passed to the caller of L{FilesystemLock.lock}. On POSIX, unlike on Windows, these are unexpected errors which cannot be handled by L{FilesystemLock}. N(R9R RR(R ((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_symlinkErrorPOSIXss9POSIX-specific error propagation not expected on Windows.cCsR|jƒ}tj|ƒ}|j|jƒƒ|j|jƒ|j|jƒdS(s‹ If the lock has never been held, it can be acquired and the C{clean} and C{locked} attributes are set to C{True}. N(RRR)t assertTrueR*tcleantlocked(R R8R*((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_cleanlyAcquireŸs  cCsŽ|jƒ}tj|ƒ}|j|jƒƒ|jƒ|j|jƒtj|ƒ}|j|jƒƒ|j|jƒ|j|jƒdS(sŒ If a lock is released cleanly, it can be re-acquired and the C{clean} and C{locked} attributes are set to C{True}. N( RRR)R=R*tunlockR+R?R>(R R8R*((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_cleanlyRelease«s  cCsd|jƒ}tj|ƒ}|j|jƒƒtj|ƒ}|j|jƒƒ|j|jƒdS(sK If a lock is currently locked, it cannot be locked again. N(RRR)R=R*R+R?(R R8t firstLockt secondLock((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_cannotLockLocked¼s  csµd‰‡fd†}|jƒ}|jtd|ƒtjtˆƒ|ƒtj|ƒ}|j|jƒƒ|j|j ƒ|j|j ƒ|j tj |ƒtt jƒƒƒdS(sÇ If a lock was held by a process which no longer exists, it can be acquired, the C{clean} attribute is set to C{False}, and the C{locked} attribute is set to C{True}. i90csF|dkr!ttjdƒ‚n|ˆkrBttjdƒ‚ndS(Ni(R R tEPERMRR'(tpidtsignal(towner(s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pytfakeKillÑs  R#N(RRRRtstrR)R=R*R+R>R?R RR$R%(R RJR8R*((RIs>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_uncleanlyAcquireÉs cs«‡‡fd†}|jtd|ƒ‰d„}|jtd|ƒ|jƒ‰tjˆƒ}tjtdƒˆƒ|j|jƒƒ|j|jƒ|j|j ƒdS(sð If the lock is initially held but then released before it can be examined to determine if the process which held it still exists, it is acquired and the C{clean} and C{locked} attributes are set to C{True}. cs$tjˆƒˆjƒtj|ƒS(N(RtrmlinktrestoreR(R(R8t readlinkPatch(s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt fakeReadlinkés  RcSsF|dkr!ttjdƒ‚n|dkrBttjdƒ‚ndS(Niiu¨(R R RFRR'(RGRH((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRJñs  R#iu¨N( RRRR)RRKR=R*R>R?(R RPRJR*((R8ROs>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_lockReleasedBeforeCheckãs  cCs^d„}|jtd|ƒ|jƒ}tj|ƒ}|j|jƒƒ|j|jƒdS(s“ If the lock is released while an attempt is made to acquire it, the lock attempt fails and C{FilesystemLock.lock} returns C{False}. This can happen on Windows when L{lockfile.symlink} fails with L{IOError} of C{EIO} because another process is in the middle of a call to L{os.rmdir} (implemented in terms of RemoveDirectory) which is not atomic. cSsttjdƒ‚dS(N(R R RR(RR((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyR7 sRN(RRRR)R+R*R?(R R7R8R*((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt%test_lockReleasedDuringAcquireSymlinks  sBspecial rename EIO handling only necessary and correct on Windows.cCsvd„}|jtd|ƒ}|jƒ}tj|ƒ}tjtdƒ|ƒ|j|jƒƒ|j|jƒdS(s» If the lock is initially held but is released while an attempt is made to acquire it, the lock attempt fails and L{FilesystemLock.lock} returns C{False}. cSsttjdƒ‚dS(N(RR RR(R((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRP sRiu¨N( RRRR)RRKR+R*R?(R RPROR8R*((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt&test_lockReleasedDuringAcquireReadlinks  sGspecial readlink EACCES handling only necessary and correct on Windows.cs’‡‡fd†}|jtd|ƒ|jƒ}tjtdƒ|ƒtj|ƒ}|jˆ|jƒ}|j|j ˆƒ|j |j ƒdS(Ncsˆˆdƒ‚dS(N(R(R(R t exceptionType(s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRP3sRiu¨( RRRRRKR)RR*R R R+R?(R RTR RPR8R*R((R RTs>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt_readlinkErrorTest2s cCs*|jttjƒ|jttjƒdS(s‡ An exception raised by C{readlink} other than C{ENOENT} is passed up to the caller of L{FilesystemLock.lock}. N(RUR R R:R(R ((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_readlinkErrorBscCs*|jttjƒ|jttjƒdS(sú Any L{IOError} raised by C{readlink} on a POSIX platform passed to the caller of L{FilesystemLock.lock}. On POSIX, unlike on Windows, these are unexpected errors which cannot be handled by L{FilesystemLock}. N(RURR R:R(R ((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_readlinkErrorPOSIXKscs«‡‡fd†}|jtd|ƒ‰d„}|jtd|ƒ|jƒ‰tjˆƒ}tjtdƒˆƒ|j|jƒƒ|j|jƒ|j|j ƒdS(s× If a second process cleans up the lock after a first one checks the lock and finds that no process is holding it, the first process does not fail when it tries to clean up the lock. cs$ˆjƒtjˆƒtj|ƒS(N(RNRRM(R(t rmlinkPatchR8(s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt fakeRmlink`s  RMcSsF|dkr!ttjdƒ‚n|dkrBttjdƒ‚ndS(Niiu¨(R R RFRR'(RGRH((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRJhs  R#iu¨N( RRRR)RRKR=R*R>R?(R RYRJR*((R8RXs>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_lockCleanedUpConcurrentlyZs  cCs¨d„}|jtd|ƒd„}|jtd|ƒ|jƒ}tjtdƒ|ƒtj|ƒ}|jt|jƒ}|j |j t j ƒ|j |j ƒdS(s… An exception raised by L{rmlink} other than C{ENOENT} is passed up to the caller of L{FilesystemLock.lock}. cSsttjdƒ‚dS(N(R R R:R(R((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRY|sRMcSsF|dkr!ttjdƒ‚n|dkrBttjdƒ‚ndS(Niiu¨(R R RFRR'(RGRH((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRJ€s  R#iu¨N(RRRRRKR)RR R*R R R:R+R?(R RYRJR8R*R((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_rmlinkErrorws   cCsŒd„}|jtd|ƒ|jƒ}tjtdƒ|ƒtj|ƒ}|jt|jƒ}|j |j t j ƒ|j |j ƒdS(s¶ If L{kill} raises an exception other than L{OSError} with errno set to C{ESRCH}, the exception is passed up to the caller of L{FilesystemLock.lock}. cSsttjdƒ‚dS(N(R R RFR(RGRH((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyRJ˜sR#iu¨N(RRRRRKR)RR R*R R RFR+R?(R RJR8R*R((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_killError’s  cCsR|jƒ}tjttjƒdƒ|ƒtj|ƒ}|jt|j ƒdS(s‚ L{FilesystemLock.unlock} raises L{ValueError} if called for a lock which is held by a different process. iN( RRRRKR$R%R)Rt ValueErrorRA(R R8R*((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyttest_unlockOther§s  cCs~|jƒ}|jtj|ƒƒtj|ƒ}|j|jƒƒ|jtj|ƒƒ|jƒ|jtj|ƒƒdS(sp L{isLocked} returns C{True} if the named lock is currently locked, C{False} otherwise. N(RR+RtisLockedR)R=R*RA(R R8R*((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyt test_isLocked²s  (R.R/R9R;R<RR1R2R@RBRERLRQRRRSRURVRWRZR[R\R^R`(((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyR4|s4                   (R0R$R t twisted.trialRttwisted.pythonRttwisted.python.runtimeRRR3R1twin32apiRt pywintypest ImportErrortTestCaseRR4(((s>/usr/lib/python2.7/dist-packages/twisted/test/test_lockfile.pyts   d