\dZdZddlZddlZddlmZddlmZdZddlmZej sddlm Z m Z m Z mZdZn-d Z ddlZdd lmZd Zd Zd Z n #e$rdZ YnwxYweZdZdZ dZ GddZdZddgZdS)z& Filesystem-based interprocess mutex. N)time)platformcXtttdzS)Ni)strint _uniquefloat7lib/python3.11/site-packages/twisted/python/lockfile.pyuniquer s! s<>>D()) * **r )rename)killreadlinkremovesymlinkFT) OpenProcessWc  tdd|td#tj$rR}|jdt krYd}~dS|jdt krttj dd}~wwxYw)Nrz OpenProcess is required to fail.) r RuntimeError pywintypeserrorargsERROR_ACCESS_DENIEDERROR_INVALID_PARAMETEROSErrorerrnoESRCH)pidsignales r rr4s GAq#&&&##EFFF#   6!9 333FFFFFVAY"999!%+t444  s"BA> 1A>>Bc|dztzdz}tj|d}tj|d}t ||5}|||dddn #1swxYwY t||dS#t$r*tj |tj |wxYw)z 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 nvxx/*< W\\+y99   :t $ $  GGENNN GGIII                 ; ) ) ) ) )    Ij ! ! ! H[ ! ! !  s*BBB B224C&cd ttj|dd}|5|}dddn #1swxYwY|S#t $rE}|jt jks|jt jkrt |jdd}~wwxYw)zq 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  % % % % % % % % % % % % % % % % %M   w%,&&!'UY*>*>agt,,,  s).A AAA B/*AB**B/ctjtj|dtj|dS)Nr)r%rr&r'r-)r/s r rmlinkr<rs8 "',,x33444 r c,eZdZdZdZdZdZdZdZdS)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. NFc||_dS)N)name)selfr@s r __init__zFilesystemLock.__init__s  r crd} tttj|jno#t $ra}t r%|jtjtj fvrYd}~dS|jtj kr t|j}nW#t $rJ}|jtj kr Yd}~Yd}~t r|jtjkr Yd}~Yd}~dSd}~wwxYw ttt|dn#t $rs}|jtjkrX t!|jn6#t $r)}|jtj krYd}~Yd}~Yd}~yd}~wwxYwd}Yd}~Yd}~d}~wwxYwYd}~dSd}~wwxYwd|_||_dS)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%getpidr@r_windowsrEACCESr8EEXISTrr7rrrr<lockedclean)rArIr!rs r lockzFilesystemLock.locks0 , BIKK(($)4444* * * !EL%)+D D D!555557el**&ty11"   7el22%HHHHHHHH%)!'U\*A*A $)555555555 + S1---"7ek11& &ty 1 1 1 1#*&&&#$7el#:#:%-HHHHHHHHHHHH % &%*E$HHHHHHHH !55555U* VDKDJ4s3: F&&F!1F!BF! C1'C,<F!C,!F!+C,,C11F!5$DF! F$F:EF FE=.F2F!<E==FFF!FFF! F!!F&ct|j}t|tjkrt d|jdt |jd|_dS)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%rD ValueErrorr<rH)rArs r unlockzFilesystemLock.unlocksaty!! s88ry{{ " "LTYLLLMM Mty r ) __name__ __module__ __qualname____doc__rIrHrBrJrMr r r r>r>wsX$ E F;;;z     r r>ct|}d} |}|r|n#|r|wwxYw| S)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>rJrM)r@lr:s r isLockedrTsh tA F   HHJJJ   HHJJJJ :s >ArT)rQrr%rrtwisted.python.runtimerr r isWindowsrrrr<rrErwin32apirrr ImportErroropenr)r>rT__all__r r r r[s   %%%%%%+++++++++x\<<<<<<<<<<<<HHHG(((((( "$ G G G G * E6$ ccccccccL( Z (s AAA