h1>SrSSKJr SSKrSSKrSSKJrJr SSKJ r SSK J r SSK J r SSKJr SS KJr S rS r\R("5(a\ "S 5c \ "S 5cSrSr"SS\5r"SS\5rg)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.c\rSrSrSrSSjr\"\R"5S5SSj5r SSjr \"\R"5S5SSj5r \ "\ \5SS j5r\ "\ \5SS j5rSS jrS rg ) UtilTests#zE Tests for the helper functions used to implement L{FilesystemLock}. cUR5n[R"SU5 UR[[RSU5nUR UR [ R5 g)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 a/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_lockfile.pytest_symlinkEEXISTUtilTests.test_symlinkEEXIST(sS {{}%)9)95$G ELL1Bspecial rename EIO handling only necessary and correct on Windows.cUR5nSSjnUR[SU5 UR[[R US5nUR UR[R5 g)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). c6[[RS5eNrrEIOsrcdsts r fakeRename4UtilTests.test_symlinkEIOWindows..fakeRenameAs%))T* *r renamerNr(strr)r.returnr) rpatchrrIOErrorrrrr&)rrr*rs rtest_symlinkEIOWindows UtilTests.test_symlinkEIOWindows2sZ{{} + 8Xz2)9)94G EII.r cUR5nUR[[RU5nUR UR [ R5 g)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_readlinkENOENTUtilTests.test_readlinkENOENTHsA {{}):):DA ELL1r Gspecial readlink EACCES handling only necessary and correct on Windows.cUR5nSSjnUR[SU5 UR[[R U5nUR UR[R5 g)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). c6[[RS5er$rrEACCES)pathmodes rfakeOpen6UtilTests.test_readlinkEACCESWindows..fakeOpen`%,,- -r _openN)r>r.r?r.r/r) rr0rrr1r5rrr=)rrr@rs rtest_readlinkEACCESWindows$UtilTests.test_readlinkEACCESWindowsQsX{{} . 8Wh/):):DA ELL1r cX[R"[R"5S5 g)ze L{lockfile.kill} returns without error if passed the PID of a process which exists and signal C{0}. rN)rkillosgetpidrs r test_killUtilTests.test_killgs  biik1%r cUR[[RSS5nUR UR [ R 5 g)zu L{lockfile.kill} raises L{OSError} with errno of L{ESRCH} if passed a PID which does not correspond to any process. irN)rrrrGrrESRCH)rrs rtest_killESRCHUtilTests.test_killESRCHos6 1E EKK0r cUR[SS5 [R"UR55nUR 5 UR UR 55 g)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}. rGN)r0rFilesystemLockrlock assertFalse)rfls rtest_noKillCallUtilTests.test_noKillCallysG 8VT*  $ $T[[] 3   #r Nr/None)__name__ __module__ __qualname____firstlineno____doc__rrr isWindowsr2r7rDrskipKillskipKillReasonrKrOrV__static_attributes__rXr rrr#s2O/ /$2T2 2$ Hn%&&& Hn%1&1 $r rc\rSrSrSSjrSSjr\"\R"5S5SSj5r SSjr SSjr SSjr SS jr SS jr\"\R"5S 5SS j5r\"\R"5S 5SSj5rSSjrSSjr\"\R"5S5SSj5rSSjrSSjrSSjrSSjrSSjrSrg) LockingTestsc^SU4SjjnUR[SU5 UR5n[R"U5nUR [ UR 5nURURT5 g)Nc>[TS5er$)r)sourcedestrs r fakeSymlink3LockingTests._symlinkErrorTest..fakeSymlinks%& &r r)rir.rjr.r/r) r0rrrRrrrSrr)rrrklockfrSrs ` r_symlinkErrorTestLockingTests._symlinkErrorTests_ ' 8Y 4 &&u-3 E*r cBUR[R5 g)zn An exception raised by C{symlink} other than C{EEXIST} is passed up to the caller of L{FilesystemLock.lock}. N)rnrENOSYSrJs rtest_symlinkErrorLockingTests.test_symlinkErrors u||,r z9POSIX-specific error propagation not expected on Windows.cUR[R5 UR[R5 g)z 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)rnrr=r&rJs rtest_symlinkErrorPOSIX#LockingTests.test_symlinkErrorPOSIXs( u||, uyy)r cUR5n[R"U5nURUR 55 URUR 5 URUR 5 g)zs 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)rrrR assertTruerScleanlockedrrmrSs rtest_cleanlyAcquire LockingTests.test_cleanlyAcquiresQ  &&u-  $  #  $r cUR5n[R"U5nURUR 55 UR 5 UR UR5 [R"U5nURUR 55 URUR5 URUR5 g)zt 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) rrrRrxrSunlockrTrzryr{s rtest_cleanlyRelease LockingTests.test_cleanlyReleases  &&u-  $  %&&u-  $  #  $r c.UR5n[R"U5nURUR 55 [R"U5nUR UR 55 UR UR 5 g)z; If a lock is currently locked, it cannot be locked again. N)rrrRrxrSrTrz)rrm firstLock secondLocks rtest_cannotLockLocked"LockingTests.test_cannotLockLockedsk ++E2   (),,U3  *+ **+r c^SmSU4SjjnUR5nUR[SU5 [R"[ T5U5 [R "U5nUR UR55 URUR5 UR UR5 UR[R"U5[ [R"555 g)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}. i90c>US:wa[[RS5eUT:Xa[[RS5eg)NrrrEPERMrN)pidsignalowners rfakeKill4LockingTests.test_uncleanlyAcquire..fakeKills8{ekk400e|ekk400r rGNrintrrr/rZ)rr0rrr.rRrxrSrTryrzrr5rHrI)rrrmrSrs @rtest_uncleanlyAcquire"LockingTests.test_uncleanlyAcquires  1   8VX.UU+&&u-  $ $  $ **513ryy{3CDr c^^SUU4SjjnUR[SU5mSSjnUR[SU5 UR5m[R"T5n[R"[ S5T5 UR UR55 UR UR5 UR UR5 g) 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}. c|>[R"T5 TR5 [R"U5$r$)rrmlinkrestorer5)rrm readlinkPatchs r fakeReadlink?LockingTests.test_lockReleasedBeforeCheck..fakeReadlinks, OOE "  ! ! #$$T* *r r5cUS:wa[[RS5eUS:Xa[[RS5egNrurrrs rr;LockingTests.test_lockReleasedBeforeCheck..fakeKill7{ekk400e|ekk400r rGrN)rr.r/r.r r0rrrRrr.rxrSryrz)rrrrSrmrs @@rtest_lockReleasedBeforeCheck)LockingTests.test_lockReleasedBeforeChecks + + 8ZF  1 8VX. &&u-UU+  $  #  $r r!cSSjnUR[SU5 UR5n[R"U5nUR UR 55 UR UR 5 g)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. c6[[RS5er$r%r's rrkGLockingTests.test_lockReleasedDuringAcquireSymlink..fakeSymlinks%))T* *r rNr-)r0rrrRrTrSrz)rrkrmrSs r%test_lockReleasedDuringAcquireSymlink2LockingTests.test_lockReleasedDuringAcquireSymlinksZ + 8Y 4 &&u- % %r r9c<SSjnUR[SU5 UR5n[R"U5n[R"[ S5U5 UR UR55 UR UR5 g)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}. c6[[RS5er$r<rs rrILockingTests.test_lockReleasedDuringAcquireReadlink..fakeReadlink+s%,,- -r r5rNrr.r/r) r0rrrRrr.rTrSrz)rrrmrSs r&test_lockReleasedDuringAcquireReadlink3LockingTests.test_lockReleasedDuringAcquireReadlink sn . 8Z6 &&u-UU+ % %r cz^^SUU4SjjnUR[SU5 UR5n[R"[ S5U5 [R "U5nUR TUR5nURURT5 URUR5 g)Nc>T"TS5er$rX)rr exceptionTypes rr5LockingTests._readlinkErrorTest..fakeReadlink<st, ,r r5rr) r0rrrr.rRrrSrrrTrz)rrrrrmrSrs `` r_readlinkErrorTestLockingTests._readlinkErrorTest9s - - 8Z6  UU+&&u- tyy9 E* %r cUR[[R5 UR[[R5 g)zo An exception raised by C{readlink} other than C{ENOENT} is passed up to the caller of L{FilesystemLock.lock}. N)rrrrqr1rJs rtest_readlinkErrorLockingTests.test_readlinkErrorKs, 6 6r cUR[[R5 UR[[R5 g)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)rr1rrqr=rJs rtest_readlinkErrorPOSIX$LockingTests.test_readlinkErrorPOSIXSs, 6 6r c^^SUU4SjjnUR[SU5mSSjnUR[SU5 UR5m[R"T5n[R"[ S5T5 UR UR55 UR UR5 UR UR5 g) 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. c|>TR5 [R"T5 [R"U5$r$)rrr)rrm rmlinkPatchs r fakeRmlink?LockingTests.test_lockCleanedUpConcurrently..fakeRmlinkis*    ! OOE "??4( (r rcUS:wa[[RS5eUS:Xa[[RS5egrrrs rr=LockingTests.test_lockCleanedUpConcurrently..fakeKillrrr rGrN)rr.r/rZrr)rrrrSrmrs @@rtest_lockCleanedUpConcurrently+LockingTests.test_lockCleanedUpConcurrentlybs ) )jj8Z@  1 8VX. &&u-UU+  $  #  $r cSSjnUR[SU5 SSjnUR[SU5 UR5n[R"[ S5U5 [R "U5nUR [UR5nURUR[R5 URUR5 g) zm An exception raised by L{rmlink} other than C{ENOENT} is passed up to the caller of L{FilesystemLock.lock}. c6[[RS5er$)rrrqrs rr1LockingTests.test_rmlinkError..fakeRmlinkrBr rcUS:wa[[RS5eUS:Xa[[RS5egrrrs rr/LockingTests.test_rmlinkError..fakeKillrr rGrNrr)r0rrrr.rRrrrSrrrqrTrz)rrrrmrSrs rtest_rmlinkErrorLockingTests.test_rmlinkErrors  . 8Xz2 1 8VX.  UU+&&u-3 ELL1 %r cSSjnUR[SU5 UR5n[R"[ S5U5 [R "U5nUR [UR5nURUR[R5 URUR5 g)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}. c6[[RS5er$)rrrrs rr-LockingTests.test_killError..fakeKills%++t, ,r rGrN)rrrrr/r)r0rrrr.rRrrrSrrrrTrz)rrrmrSrs rtest_killErrorLockingTests.test_killErrors - 8VX.  UU+&&u-3 EKK0 %r cUR5n[R"[[R "5S-5U5 [R "U5nUR[UR5 g)zj L{FilesystemLock.unlock} raises L{ValueError} if called for a lock which is held by a different process. N) rrrr.rHrIrRr ValueErrorrr{s rtest_unlockOtherLockingTests.test_unlockOthersR  RYY[1_-u5&&u- *dkk2r cUR5nUR[R"U55 [R"U5nUR UR 55 UR [R"U55 UR5 UR[R"U55 g)zX L{isLocked} returns C{True} if the named lock is currently locked, C{False} otherwise. N)rrTrisLockedrRrxrSrr{s r test_isLockedLockingTests.test_isLockeds   **512&&u-  $ ))%01  **512r rXN)rrr/rZrY)rztype[OSError] | type[IOError]rrr/rZ)r[r\r]r^rnrrrr r`rur|rrrrrrrrrrrrrrrrcrXr rreres +- C *  * %% ,E2%>O& &,T& &*&:&CF& &$7 C 7  7%>&:&,3 3r re)r_ __future__rrrHunittestrrtyping_extensionsrtwisted.pythonrtwisted.python.reflectrtwisted.python.runtimer twisted.trial.unittestr rarbr`rrerXr rrs # '&#0++  ,-5 , ' / <  _$_$DD38D3r