h*SrSSKrSSKrSSKJr SSKJr SrSSKJr \R"5(dSSKJ r J r J r Jr SrOS rSSKrSS KJr S rS rS r \rSrSr Sr "SS5rSrSS/rg!\a Sr N'f=f)z& Filesystem-based interprocess mutex. N)time)platformc@[[[5S-55$)Ni)strint _uniquefloat^/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/python/lockfile.pyuniquer s s<>D() **r )rename)killreadlinkremovesymlinkFT) OpenProcessWc[SSU5 [S5e![RaSnURS[ :XaSnAgURS[ :Xa[[RS5eeSnAff=f)Nrz OpenProcess is required to fail.) r RuntimeError pywintypeserrorargsERROR_ACCESS_DENIEDERROR_INVALID_PARAMETEROSErrorerrnoESRCH)pidsignales r rr4ss GAq#&##EFF## 66!9 33VVAY"99!%++t44  s BA< 2A<<BcUS-[5-S-n[RRUS5n[R"U5 Sn[ X45nUR U5 UR5 SSS5 [X!5 g!,(df  N=f![a. [R"U5 [R"U5 ef=f)zr Write a file at C{filename} with the contents of C{value}. See the above comment block as to why this is needed. .z.newlinkrwN) r ospathjoinmkdir_openwriteflushr BaseExceptionrrmdir)valuefilename newlinkname newvalnamemodefs r rrEs nvx/*< WW\\+y9   : $ GGEN GGI%  ; ) % $   IIj ! HH[ !  s"B B B8Cc[[RRUS5S5nU UR 5nSSS5 U$!,(df  W$=f![ aXnUR [ R:XdUR [ R:Xa[ UR S5eeSnAff=f)zY Read the contents of C{filename}. See the above comment block as to why this is needed. rrN) r)r%r&r'readrrENOENTEIO)r/fObjresultr!s r rr`s h :C@D MM ww%,,&!''UYY*>aggt,,  s#*AA  A B=%AB88B=c[R"[RRUS55 [R"U5 g)Nr)r%rr&r'r-)r/s r rmlinkr<rs) "'',,x34 r c2\rSrSrSrSrSrSrSrSr Sr g) FilesystemLockwa 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. NFcXlg)N)name)selfrAs r __init__FilesystemLock.__init__s r cSn[[[R"55UR5 SUlXlg![ Gan[ (a3UR[R[R4;aSnAgUR[R:XGa<[UR5nOm![ a`nUR[R:Xa SnASnAM[ (a'UR[R:Xa SnASnAgeSnAff=f[b[[U5S5 O![ anUR[R:Xad[!UR5 O@![ a3nUR[R:XaSnASnASnAGMeSnAff=fSnSnASnAGMeSnAff=fSnAgeSnAff=f)z Acquire this lock. @rtype: C{bool} @return: True if the lock is acquired, false otherwise. @raise OSError: Any exception L{os.symlink()} may raise, other than L{errno.EEXIST}. TNFr)rrr%getpidrAr_windowsrEACCESr8EEXISTrr7rrrr<lockedclean)rBrKr!rs r lockFilesystemLock.lockse, BIIK($))4XDKJ[* 8ELL%))+D D!77ell*&tyy1" 77ell2%H%X!''U\\*A $)5 + S1-"77ekk1& &tyy 1#*&#$77ell#:%-H % &%*E$H !U* s2A G/9G*G*.CG* D.D),G*6)D)G*(D))D..G*2EG* G!G8F G G G6G:G*GG  GG*GG!!G*)G**G/c[UR5n[U5[R"5:wa[ SUR<S35e[ UR5 SUlg)z Release this lock. This deletes the directory with the given name. @raise OSError: Any exception L{os.readlink()} may raise. @raise ValueError: If the lock is not owned by this process. zLock z not owned by this processFN)rrArr%rF ValueErrorr<rJ)rBrs r unlockFilesystemLock.unlocksPtyy! s8ryy{ "uTYYM1KLM Mtyy r )rKrJrA) __name__ __module__ __qualname____firstlineno____doc__rKrJrCrLrP__static_attributes__r r r r>r>ws#$ E F;z r r>c[U5nSnUR5nU(aUR5 U(+$!U(aUR5 ff=f)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)r>rLrP)rAlr:s r isLockedrZsL tA F  HHJ:  HHJ s =ArZ)rVrr%rrtwisted.python.runtimerr r isWindowsrrrr<rrGrwin32apirrr ImportErroropenr)r>rZ__all__r r r ras   %++<<HHG( "$ G E6$ ccL( Z (K s A66BB