eCi3dZddlZddlZddlZddlZ ddlZn #e$rdZYnwxYw ddlZn #e$rdZYnwxYw ddlZn #e$rdZYnwxYw e n #e $re Z YnwxYwgdZ dZ dadZGdde ZGdd ZGd d ZGd d eZGddeZGddeZdZereZdSereZdSeZeejddSdS)zD A platform independent file lock that supports the with-statement. N)Timeout BaseFileLockWindowsFileLock UnixFileLock SoftFileLockFileLockz3.0.12cPtptjtatS)z0Returns the logger instance used in this module.)_loggerlogging getLogger__name__2/b/s/w/ir/x/w/install/emscripten/tools/filelock.pyloggerrSs4*844G NrceZdZdZdZdZdS)rzN Raised when the lock could not be acquired in *timeout* seconds. c||_dS N) lock_file)selfrs r__init__zTimeout.__init__bs#trc:d|j}|S)Nz)The file lock '{}' could not be acquired.)formatr)rtemps r__str__zTimeout.__str__is:t~&&  rN)r __module__ __qualname____doc__rrrrrrr\s< rrc eZdZdZdZdZdS)_Acquire_ReturnProxyc||_dSNlock)rr%s rrz_Acquire_ReturnProxy.__init__|s trc|jSr#r$rs r __enter__z_Acquire_ReturnProxy.__enter__s yrc8|jdSr#)r%releaser _exc_type _exc_value _tracebacks r__exit__z_Acquire_ReturnProxy.__exit__s trN)r rrrr(r/rrrr!r!zsArr!ceZdZdZddZedZedZejdZdZ dZ ed Z dd Z ddZ dZdZdZd S)rz3 Implements the base class of a file lock. cn||_d|_||_tj|_d|_dS)rNr) _lock_file _lock_file_fdtimeout threadingLock _thread_lock _lock_counter)rrr5s rrzBaseFileLock.__init__s?$ " &N,, trc|jS)z, The path to the lock file. )r3r's rrzBaseFileLock.lock_files rc|jS)a~ You can set a default timeout for the filelock. It will be used as fallback value in the acquire method, if no timeout value (*None*) is given. If you want to disable the timeout, set it to a negative value. A timeout of 0 means, that there is exactly one attempt to acquire the file lock. .. versionadded:: 2.0.0 )_timeoutr's rr5zBaseFileLock.timeouts }rc.t||_dSr)floatr<)rvalues rr5zBaseFileLock.timeoutse  trct)z Platform dependent. If the file lock could be acquired, self._lock_file_fd holds the file descriptor of the lock file. NotImplementedErrorr's r_acquirezBaseFileLock._acquires "###rct)zH Releases the lock and sets self._lock_file_fd to None. rAr's r_releasezBaseFileLock._releases"###rc|jduS)z True, if the object holds the file lock. .. versionchanged:: 2.0.0 This was previously a method and is now a property. N)r4r's r is_lockedzBaseFileLock.is_lockeds!--rN皙?c||j}|j5|xjdz c_dddn #1swxYwYt|}|j}t j} |j5|js7td||| dddn #1swxYwY|jr$td||n|dkrQt j|z |kr7td||t|jtd|||t j |nB#|j5td|jdz |_dddn #1swxYwYxYwt| S) aY Acquires the file lock or fails with a :exc:`Timeout` error. .. code-block:: python # You can use this method in the context manager (recommended) with lock.acquire(): pass # Or use an equivalent try-finally construct: lock.acquire() try: pass finally: lock.release() :arg float timeout: The maximum time waited for the file lock. If ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired. If ``timeout`` is None, the default :attr:`~timeout` is used. :arg float poll_intervall: We check once in *poll_intervall* seconds if we can acquire the file lock. :raises Timeout: if the lock could not be acquired in *timeout* seconds. .. versionchanged:: 2.0.0 This method returns now a *proxy* object instead of *self*, so that it can be used in a with statement without side effects. NTz#Attempting to acquire lock %s on %szLock %s acquired on %srz"Timeout on acquiring lock %s on %sz2Lock %s not acquired on %s, waiting %s seconds ...r$)r5r8r9idr3timerGrdebugrCrsleepmaxr!)rr5poll_intervalllock_id lock_filename start_times racquirezBaseFileLock.acquiresH ?lG  $ $   ! #   $ $ $ $ $ $ $ $ $ $ $ $ $ $ $T(( Y[[   /&((>('LgWdeee ((((((((((((((( > /HHNN#;WmTTT\\dikkJ&>&H&HHHNN#GR_```!$/222HHNNLJ~...# / " D D%(D,>,B%C%C" D D D D D D D D D D D D D D D #40000sa.22#E>+?B6* E>6B::E>=B:>B?E>> F=F1% F=1F5 5F=8F5 9F=Fcz|j5|jr|xjdzc_|jdks|rwt|}|j}t d|||d|_t d||dddn #1swxYwYdS)aW Releases the file lock. Please note, that the lock is only completely released, if the lock counter is 0. Also note, that the lock file itself is not automatically deleted. :arg bool force: If true, the lock counter is ignored and the lock is released in every case. rJrz#Attempting to release lock %s on %szLock %s released on %sN)r8rGr9rKr3rrMrE)rforcerQrRs rr*zBaseFileLock.release,s   U U~ U""a'""%**e* hhG$(OMHHNN#H'S`aaaMMOOO)*D&HHNN#;WmTTT U U U U U U U U U U U U U U UtsBB00B47B4c.||Sr#)rTr's rr(zBaseFileLock.__enter__Is  rc.|dSr#r*r+s rr/zBaseFileLock.__exit__Ms trc2|ddS)NT)rVrYr's r__del__zBaseFileLock.__del__Qs T """tr)r1)NrH)F)r rrrrpropertyrr5setterrCrErGrTr*r(r/r[rrrrrs0X   X  ^^$$$$$$..X.H1H1H1H1T:rrceZdZdZdZdZdS)rze Uses the :func:`msvcrt.locking` function to hard lock the lock file on windows systems. cPtjtjztjz} tj|j|} t j|t jd||_ n;#ttf$rtj |YnwxYw#t$rYnwxYwdSNrJ) osO_RDWRO_CREATO_TRUNCopenr3msvcrtlockingLK_NBLCKr4IOErrorOSErrorcloser open_modefds rrCzWindowsFileLock._acquire_sI *RZ7  ()44B (r6?A666&(""W%          D ts#B A++%BB B#"B#c|j}d|_tj|tjdt j| t j|jn#t$rYnwxYwdSr`) r4rfrgLK_UNLCKrarkremover3rjrrns rrEzWindowsFileLock._releaseosv  !r6?A...    Ido & & & &    D tsA A+*A+Nr rrrrCrErrrrrYs<      rrceZdZdZdZdZdS)rzR Uses the :func:`fcntl.flock` to hard lock the lock file on unix systems. ctjtjztjz}tj|j|} t j|t jt j ztj |}|j dkrtj |n3||_ n+#ttf$rtj |YnwxYwdS)Nr)rarbrcrdrer3fcntlflockLOCK_EXLOCK_NBfstatst_nlinkrkr4rirj)rrmrnsts rrCzUnixFileLock._acquiresI *RZ7 WT_i 0 0 & KEMEM9 : : :"B{a hrllll#%d  !    HRLLLLL ts,B**%CCc|j}d|_tj|jt j|tjtj|dSr#)r4raunlinkr3rvrwLOCK_UNrkrrs rrEzUnixFileLock._releasesJ  ! $/""" B &&&  trNrsrrrrrs<*rrceZdZdZdZdZdS)rz8 Simply watches the existence of the lock file. ctjtjztjztjz} tj|j|}||_n#ttf$rYnwxYwdSr#) raO_WRONLYrcO_EXCLrdrer3r4rirjrls rrCzSoftFileLock._acquiresqK"*,ry82:E  $)44B"$D  !    D tsAA+*A+ctj|jd|_ tj|jn#t $rYnwxYwdSr#)rarkr4rqr3rjr's rrEzSoftFileLock._releases\ #$$$!  Ido & & & &    D ts< A A Nrsrrrrrs<     rrz only soft file lock is available)rr rar6rLwarnings ImportErrorrfrv TimeoutError NameErrorrj__all__ __version__r rrr!rrrrrwarnrrrrsB  OOOOHHHMMMM FFFLLLL EEE LLLLL      l<        KKKKKKKKb"""""l"""N     <   J<B  :HHH :HHHH 899999s9##,66?A A  AAA