Yf1>dZddlmZddlZddlZddlmZmZddlm Z ddl m Z ddl m Z ddlmZdd lmZd Zd Zejre d e d dZdZGddeZGddeZdS)z' Tests for L{twisted.python.lockfile}. ) annotationsN)skipIf skipUnless)NoReturn)lockfile) requireModule)platform)TestCaseFzwin32api.OpenProcess pywintypesTzZOn windows, lockfile.kill is not implemented in the absence of win32api and/or pywintypes.ceZdZdZddZeejdddZddZ eejddd Z e e e dd Ze e e dd Zdd Zd S) UtilTestszM Tests for the helper functions used to implement L{FilesystemLock}. returnNonec|}tjd||ttjd|}||jt jdS)z 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. fooN)mktemprsymlink assertRaisesOSError assertEqualerrnoEEXISTselfnameexcs L/var/www/html/env/lib/python3.11/site-packages/twisted/test/test_lockfile.pytest_symlinkEEXISTzUtilTests.test_symlinkEEXIST(s` {{}}%%%)95$GG EL11111Bspecial rename EIO handling only necessary and correct on Windows.c|}d d}|td||ttj|d}||jtjd S) a< 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). srcstrdstrrc6ttjdNrrEIOr#r%s r fakeRenamez4UtilTests.test_symlinkEIOWindows..fakeRenameAs%)T** *r renamerNr#r$r%r$rr) rpatchrrIOErrorrrrr))rrr+rs rtest_symlinkEIOWindowsz UtilTests.test_symlinkEIOWindows2sy{{}} + + + + 8Xz222)94GG EI.....r c|}|ttj|}||jt jdS)z 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)rrrrreadlinkrrENOENTrs rtest_readlinkENOENTzUtilTests.test_readlinkENOENTHsK {{}}):DAA EL11111r Gspecial readlink EACCES handling only necessary and correct on Windows.c|}d d}|td||ttj|}||jtjdS) a\ 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). pathr$moderrc6ttjdr'rrEACCES)r7r8s rfakeOpenz6UtilTests.test_readlinkEACCESWindows..fakeOpen`%,-- -r _openN)r7r$r8r$rr) rr.rrr/r2rrr;)rrr<rs rtest_readlinkEACCESWindowsz$UtilTests.test_readlinkEACCESWindowsQsw{{}} . . . . 8Wh///):DAA EL11111r cRtjtjddS)z} L{lockfile.kill} returns without error if passed the PID of a process which exists and signal C{0}. rN)rkillosgetpidrs r test_killzUtilTests.test_killgs"  bikk1%%%%%r c|ttjdd}||jt jdS)z L{lockfile.kill} raises L{OSError} with errno of L{ESRCH} if passed a PID which does not correspond to any process. irN)rrrrArrESRCH)rrs rtest_killESRCHzUtilTests.test_killESRCHos? 1EE EK00000r c|tddtj|}|||dS)z 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}. rAN)r.rFilesystemLockrlock assertFalse)rfls rtest_noKillCallzUtilTests.test_noKillCallysa 8VT***  $T[[]] 3 3   #####r Nrr)__name__ __module__ __qualname____doc__rrr isWindowsr0r4r?rskipKillskipKillReasonrErHrNr rrr#s42222ZO/// /$2222ZT222 2$ VHn%%&&&&%& VHn%%111&%1 $ $ $ $ $ $r rceZdZddZddZeejdddZdd Z dd Z dd Z dd Z dd Z eejdddZeejdddZddZddZeejdddZddZddZddZddZddZdS) LockingTestsrintrrcdfd }|td||}tj|}|t |j}||jdS) Nsourcer$destrrc$tdr')r)r\r]rs r fakeSymlinkz3LockingTests._symlinkErrorTest..fakeSymlinks%&& &r r)r\r$r]r$rr) r.rrrJrrrKrr)rrr_lockfrKrs ` r_symlinkErrorTestzLockingTests._symlinkErrorTests ' ' ' ' ' ' 8Y 444 &u--33 E*****r cD|tjdS)z An exception raised by C{symlink} other than C{EEXIST} is passed up to the caller of L{FilesystemLock.lock}. N)rarENOSYSrDs rtest_symlinkErrorzLockingTests.test_symlinkErrors u|,,,,,r z9POSIX-specific error propagation not expected on Windows.c|tj|tjdS)a  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)rarr;r)rDs rtest_symlinkErrorPOSIXz#LockingTests.test_symlinkErrorPOSIXs6 u|,,, uy)))))r c |}tj|}||||j||jdS)z 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)rrrJ assertTruerKcleanlockedrr`rKs rtest_cleanlyAcquirez LockingTests.test_cleanlyAcquiresi  &u--  $$$  ###  $$$$$r c|}tj|}|||||jtj|}||||j||jdS)z 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) rrrJrhrKunlockrLrjrirks rtest_cleanlyReleasez LockingTests.test_cleanlyReleases  &u--  $$$  %%%&u--  $$$  ###  $$$$$r cN|}tj|}||tj|}||||jdS)zK If a lock is currently locked, it cannot be locked again. N)rrrJrhrKrLrj)rr` firstLock secondLocks rtest_cannotLockLockedz"LockingTests.test_cannotLockLockeds +E22   (())),U33  **+++ *+++++r c&dd fd }|}|td|tjt |tj|}||||j ||j | tj |t tjd S) z 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}. i90pidrZsignalrrc|dkrttjd|krttjddS)NrrrEPERMrG)rurvowners rfakeKillz4LockingTests.test_uncleanlyAcquire..fakeKills@{{ek4000e||ek4000|r rANrurZrvrZrr)rr.rrr$rJrhrKrLrirjrr2rBrC)rr{r`rKrzs @rtest_uncleanlyAcquirez"LockingTests.test_uncleanlyAcquires  1 1 1 1 1 1   8VX...UU+++&u--  $$$ $$$  $$$ *5113ry{{3C3CDDDDDr cdfd }|td|dd }|td ||tj}tjt d ||||j||j d S)z 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}. rr$rc|tjtj|Sr')rrmlinkrestorer2)rr` readlinkPatchs r fakeReadlinkz?LockingTests.test_lockReleasedBeforeCheck..fakeReadlinks6 OE " " "  ! ! # # #$T** *r r2rurZrvrc|dkrttjd|dkrttjddSNrurxrurvs rr{z;LockingTests.test_lockReleasedBeforeCheck..fakeKill?{{ek4000e||ek4000|r rArN)rr$rr$r| r.rrrJrr$rhrKrirj)rrr{rKr`rs @@rtest_lockReleasedBeforeCheckz)LockingTests.test_lockReleasedBeforeChecks + + + + + + + 8ZFF  1 1 1 1 8VX... &u--UU+++  $$$  ###  $$$$$r r!cd d}|td||}tj|}||||jdS) a 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. r#r$r%rrc6ttjdr'r(r*s rr_zGLockingTests.test_lockReleasedDuringAcquireSymlink..fakeSymlinks%)T** *r rNr-)r.rrrJrLrKrj)rr_r`rKs r%test_lockReleasedDuringAcquireSymlinkz2LockingTests.test_lockReleasedDuringAcquireSymlinks + + + + 8Y 444 &u-- %%% %%%%%r r5c\d d}|td||}tj|}tjt d|||||jdS) z 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}. rr$rrc6ttjdr'r:rs rrzILockingTests.test_lockReleasedDuringAcquireReadlink..fakeReadlink+s%,-- -r r2rNrr$rr) r.rrrJrr$rLrKrj)rrr`rKs r&test_lockReleasedDuringAcquireReadlinkz3LockingTests.test_lockReleasedDuringAcquireReadlink s . . . . 8Z666 &u--UU+++ %%% %%%%%r exceptionTypetype[OSError] | type[IOError]cdfd }|td||}tjt d|tj|}||j}||j | |j dS) Nrr$rrcdr'rW)rrrs rrz5LockingTests._readlinkErrorTest..fakeReadlink<s-t,, ,r r2rr) r.rrrr$rJrrKrrrLrj)rrrrr`rKrs `` r_readlinkErrorTestzLockingTests._readlinkErrorTest9s - - - - - - - 8Z666  UU+++&u-- ty99 E*** %%%%%r c|ttj|ttjdS)z An exception raised by C{readlink} other than C{ENOENT} is passed up to the caller of L{FilesystemLock.lock}. N)rrrrcr/rDs rtest_readlinkErrorzLockingTests.test_readlinkErrorKs: 666 66666r c|ttj|ttjdS)z 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)rr/rrcr;rDs rtest_readlinkErrorPOSIXz$LockingTests.test_readlinkErrorPOSIXSs: 666 66666r cdfd }|td|dd }|td ||tj}tjt d ||||j||j d S)z 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. rr$rrc|tjtj|Sr')rrr)rr` rmlinkPatchs r fakeRmlinkz?LockingTests.test_lockCleanedUpConcurrently..fakeRmlinkis5    ! ! ! OE " " "?4(( (r rrurZrvc|dkrttjd|dkrttjddSrrxrs rr{z=LockingTests.test_lockCleanedUpConcurrently..fakeKillrrr rArN)rr$rrr|r)rrr{rKr`rs @@rtest_lockCleanedUpConcurrentlyz+LockingTests.test_lockCleanedUpConcurrentlybs ) ) ) ) ) ) )jj8Z@@  1 1 1 1 8VX... &u--UU+++  $$$  ###  $$$$$r cdd}|td|dd }|td ||}tjt d |tj|}|t|j}| |j tj | |j dS)z An exception raised by L{rmlink} other than C{ENOENT} is passed up to the caller of L{FilesystemLock.lock}. rr$rrc6ttjdr')rrrcrs rrz1LockingTests.test_rmlinkError..fakeRmlinkr=r rrurZrvrc|dkrttjd|dkrttjddSrrxrs rr{z/LockingTests.test_rmlinkError..fakeKillrr rArNrr|)r.rrrr$rJrrrKrrrcrLrj)rrr{r`rKrs rtest_rmlinkErrorzLockingTests.test_rmlinkErrors  . . . . 8Xz222 1 1 1 1 8VX...  UU+++&u--33 EL111 %%%%%r cd d}|td||}tjt d|tj|}|t|j}| |j tj | |j d S) z 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}. rurZrvrrc6ttjdr')rrryrs rr{z-LockingTests.test_killError..fakeKills%+t,, ,r rArN)rurZrvrZrr)r.rrrr$rJrrrKrrryrLrj)rr{r`rKrs rtest_killErrorzLockingTests.test_killErrors - - - - 8VX...  UU+++&u--33 EK000 %%%%%r c|}tjtt jdz|tj|}|t|j dS)z L{FilesystemLock.unlock} raises L{ValueError} if called for a lock which is held by a different process. N) rrrr$rBrCrJr ValueErrorrnrks rtest_unlockOtherzLockingTests.test_unlockOthersd  RY[[1_--u555&u-- *dk22222r c|}|tj|tj|}|||tj|||tj|dS)zp L{isLocked} returns C{True} if the named lock is currently locked, C{False} otherwise. N)rrLrisLockedrJrhrKrnrks r test_isLockedzLockingTests.test_isLockeds   *511222&u--  $$$ )%00111  *51122222r N)rrZrrrO)rrrrZrr)rPrQrRrardrr rTrfrlrorsr}rrrrrrrrrrrrrWr rrYrYs0 + + + +---- VC * * *  * % % % %%%%% , , , ,EEEE2%%%%>ZO&&& &,ZT&&& &*&&&&$7777 VC 7 7 7  7%%%%>&&&&:&&&&,3333 3 3 3 3 3 3r rY)rS __future__rrrBunittestrrtyping_extensionsrtwisted.pythonrtwisted.python.reflectrtwisted.python.runtimer twisted.trial.unittestr rUrVrTrrYrWr rrse #""""" ''''''''&&&&&&######000000++++++++++++ 8   ,--5 M, ' ' / <  _$_$_$_$_$_$_$_$DD3D3D3D3D38D3D3D3D3D3r