+ Dfj*Rt^RIt^RIt^RIHt^RIHtRt^RIHt]P!4'g^RIH t H t H t HtRtMRt^RIt^R IHt^t^WtR t ]tR tR t R t !RR4tRtRR.tR# ]dRt L)i;i)z& Filesystem-based interprocess mutex. N)time)platformcH\\\4R,44#)i)strint _uniquefloat9/usr/lib/python3/dist-packages/twisted/python/lockfile.pyuniquer s s<>D() **r )rename)killreadlinkremovesymlinkFT) OpenProcessc \^^V4\R4h \Pd_pTP^,\ 8XdRp?R#TP^,\ 8Xd\\PR4hhRp?ii;i)z OpenProcess is required to fail.N) r RuntimeError pywintypeserrorargsERROR_ACCESS_DENIEDERROR_INVALID_PARAMETEROSErrorerrnoESRCH)pidsignales&& r r r 4ss GAq#&##EFF## 66!9 33VVAY"99!%++t44  s B B7BB cVR,\4,R,p\PPVR4p\P!V4Rp\ W44;_uu_4pVP V4VP4RRR4\W!4R# +'giL;i \d/\P!T4\P!T4hi;i)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# B6# B3 69C/c\\PPVR4R4pV;_uu_4VP 4pRRR4V# +'giX#;i \ d[pTP \ P8Xg TP \ P8Xd\ TP R4hhRp?ii;i)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-fObjresultrs& r rr`s h :C@D MM ww%,,&!''UYY*>aggt,,  s#*A%A A" % C 0ACC c\P!\PPVR44\P!V4R#)rN)r#rr$r%r+)r-s&r rmlinkr:rs) "'',,x34 r c>a]tRt^wtoRtRtRtRtRtRt Rt Vt R#)FilesystemLocka 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. NFcWnR#)N)name)selfr>s&&r __init__FilesystemLock.__init__s r c Rp\\\P!44VP4RTnYnR# \ Edp\ 'd6TP\P\P39dRp?R#TP\P8XEdH\TP4pMr \ depTP\P8Xd Rp?Rp?K\ 'd*TP\P8Xd Rp?Rp?R#hRp?ii;i\e\\T4^4M \ dpTP\P8Xdg\!TP4MB \ d5pTP\P8XdRp?Rp?Rp?EKhRp?ii;iRpRp?Rp?EKhRp?ii;iRp?R#hRp?ii;i)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}. TNF)rrr#getpidr>r_windowsrEACCESr6EEXISTrr5r rrr:lockedclean)r?rHrrs& 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 H;G; G;4C  G; D9D44G;> D4 D4)G;3D44D99G;=EG; G1&G,FG, G'GG, G;GGG, G;+G,,G11G;:G;;Hc \VP4p\V4\P!48wd\ RVP: R24h\ VP4RVnR#)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)rr>rr#rC ValueErrorr:rG)r?rs& r unlockFilesystemLock.unlocksPtyy! s8ryy{ "uTYYM1KLM Mtyy r )rHrGr>) __name__ __module__ __qualname____firstlineno____doc__rHrGr@rIrM__static_attributes____classdictcell__) __classdict__s@r r<r<ws+$ E F;z  r r<c\V4pRpVP4pV'dVP4V'*# T'dTP4ii;i)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<rIrM)r>lr8s& r isLockedrYsL tA F  HHJ:  HHJ s >ArY)rSrr#rrtwisted.python.runtimerr r isWindowsr rrr:rrDrwin32apirrr ImportErroropenr'r<rY__all__rr r r`s   %++<<HHG( "$ G E6$ ccL( Z (K s A88 BB