ó ¨9Vc @@s)dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z e edƒs”ej e_ ne ejdƒs»ejjej_ndddd d d d d dddddg Zdefd„ƒYZdefd„ƒYZdefd„ƒYZd efd„ƒYZd efd„ƒYZd efd„ƒYZd efd„ƒYZd efd„ƒYZdd%d„ƒYZd„Zd„Zd„Zd„Zdd „Z!e ed!ƒrd"d#l"m#Z$e$j%Z&nd"d$l"m'Z(e(j)Z&e&Z*dS(&s lockfile.py - Platform-independent advisory file locks. Requires Python 2.5 unless you apply 2.4.diff Locking is done on a per-thread basis instead of a per-process basis. Usage: >>> lock = LockFile('somefile') >>> try: ... lock.acquire() ... except AlreadyLocked: ... print 'somefile', 'is locked already.' ... except LockFailed: ... print 'somefile', 'can\'t be locked.' ... else: ... print 'got lock' got lock >>> print lock.is_locked() True >>> lock.release() >>> lock = LockFile('somefile') >>> print lock.is_locked() False >>> with lock: ... print lock.is_locked() True >>> print lock.is_locked() False >>> lock = LockFile('somefile') >>> # It is okay to lock twice from the same thread... >>> with lock: ... lock.acquire() ... >>> # Though no counter is kept, so you can't unlock multiple times... >>> print lock.is_locked() False Exceptions: Error - base class for other exceptions LockError - base class for all locking exceptions AlreadyLocked - Another thread or process already holds the lock LockFailed - Lock failed for some other reason UnlockError - base class for all unlocking exceptions AlreadyUnlocked - File was not locked. NotMyLock - File was locked but not by the current thread/process i(tabsolute_importNtcurrent_threadtget_nametErrort LockErrort LockTimeoutt AlreadyLockedt LockFailedt UnlockErrort NotLockedt NotMyLockt LinkLockFilet MkdirLockFiletSQLiteLockFiletLockBasetlockedcB@seZdZRS(sw Base class for other exceptions. >>> try: ... raise Error ... except Exception: ... pass (t__name__t __module__t__doc__(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyRJscB@seZdZRS(s– Base class for error arising from attempts to acquire the lock. >>> try: ... raise LockError ... except Error: ... pass (RRR(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyRUscB@seZdZRS(sRaised when lock creation fails within a user-defined period of time. >>> try: ... raise LockTimeout ... except LockError: ... pass (RRR(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyR`scB@seZdZRS(sˆSome other thread/process is locking the file. >>> try: ... raise AlreadyLocked ... except LockError: ... pass (RRR(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyRjscB@seZdZRS(s‡Lock file creation failed for some other reason. >>> try: ... raise LockFailed ... except LockError: ... pass (RRR(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyRtscB@seZdZRS(s™ Base class for errors arising from attempts to release the lock. >>> try: ... raise UnlockError ... except Error: ... pass (RRR(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyR~scB@seZdZRS(s’Raised when an attempt is made to unlock an unlocked file. >>> try: ... raise NotLocked ... except UnlockError: ... pass (RRR(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyR ‰scB@seZdZRS(sœRaised when an attempt is made to unlock a file someone else locked. >>> try: ... raise NotMyLock ... except UnlockError: ... pass (RRR(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyR “scB@sheZdZed d„Zd d„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z RS( s.Base class for platform-specific lock classes.cC@sã||_tjj|ƒd|_tjƒ|_tjƒ|_|r~t j ƒ}t |dt |ƒƒ}d|d@|_ n d|_ tjj|jƒ}tjj|d|j|j |jt |jƒfƒ|_||_dS(si >>> lock = LockBase('somefile') >>> lock = LockBase('somefile', threaded=False) s.locktidents-%xIÿÿÿÿts %s%s.%s%sN(tpathtostabspatht lock_filetsockett gethostnamethostnametgetpidtpidt threadingRtgetattrthashttnametdirnametjoint unique_namettimeout(tselfRtthreadedR%ttRR"((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyt__init__Ÿs      cC@stdƒ‚dS(s Acquire the lock. * If timeout is omitted (or None), wait forever trying to lock the file. * If timeout > 0, try to acquire the lock for that many seconds. If the lock period expires and the file is still locked, raise LockTimeout. * If timeout <= 0, raise AlreadyLocked immediately if the file is already locked. simplement in subclassN(tNotImplemented(R&R%((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pytacquireÀscC@stdƒ‚dS(sX Release the lock. If the file is not locked, raise NotLocked. simplement in subclassN(R*(R&((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pytreleaseÐscC@stdƒ‚dS(s9 Tell whether or not the file is locked. simplement in subclassN(R*(R&((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyt is_lockedØscC@stdƒ‚dS(sA Return True if this object is locking the file. simplement in subclassN(R*(R&((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyt i_am_lockingÞscC@stdƒ‚dS(sN Remove a lock. Useful if a locking thread failed to unlock. simplement in subclassN(R*(R&((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyt break_lockäscC@s|jƒ|S(s* Context manager support. (R+(R&((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyt __enter__ês cG@s|jƒdS(s* Context manager support. N(R,(R&t_exc((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyt__exit__ñscC@sd|jj|j|jfS(Ns<%s: %r -- %r>(t __class__RR$R(R&((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyt__repr__÷sN(RRRtTruetNoneR)R+R,R-R.R/R0R2R4(((s:/tmp/pip-build-5Z5nTX/pip/pip/_vendor/lockfile/__init__.pyRs!       cO@smtjd|tddƒt|dtƒs:|d}nt|ƒdkr`| r`t|d2sJ                    ^