ó
•abc @` sŽ d d l m Z m Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m
Z
m Z m Z m
Z
d e f d „ ƒ YZ d S( i ( t absolute_importt divisionNi ( t LockBaset
LockFailedt NotLockedt NotMyLockt LockTimeoutt
AlreadyLockedt
MkdirLockFilec B` sM e Z d Z e d d „ Z d d „ Z d „ Z d „ Z d „ Z d „ Z
RS( s" Lock file by creating a directory.c C` sK t j | | | | ƒ t j j | j d | j | j | j f ƒ | _ d S( ss
>>> lock = MkdirLockFile('somefile')
>>> lock = MkdirLockFile('somefile', threaded=False)
s %s.%s%sN(
R t __init__t ost patht joint lock_filet hostnamet tnamet pidt unique_name( t selfR t threadedt timeout( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyR s
c C` s{ | d k r | n | j } t j ƒ } | d k rL | d k rL | | 7} n | d k ra d } n t d | d ƒ } x t rvy t j | j ƒ WnÅ t k
rXt j
ƒ d } | j t j k rBt j
j | j ƒ rÜ d S| d k r2t j ƒ | k r2| d k r t d | j
ƒ ‚ q2t d | j
ƒ ‚ n t j | ƒ qst d | j ƒ ‚ qw Xt | j d ƒ j ƒ d Sqw Wd S( Ni gš™™™™™¹?i
i s& Timeout waiting to acquire lock for %ss %s is already lockeds failed to create %st wb( t NoneR t timet maxt TrueR
t mkdirR
t OSErrort syst exc_infot errnot EEXISTR t existsR R R t sleepR t opent close( R R t end_timet waitt err( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyt acquire s2
c C` sq | j ƒ s" t d | j ƒ ‚ n+ t j j | j ƒ sM t d | j ƒ ‚ n t j | j ƒ t j | j ƒ d S( Ns %s is not lockeds %s is locked, but not by me(
t is_lockedR R R
R R R t unlinkt rmdirR
( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyt releaseA s c C` s t j j | j ƒ S( N( R
R R R
( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyR( I s c C` s | j ƒ o t j j | j ƒ S( N( R( R
R R R ( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyt i_am_lockingL s c C` sh t j j | j ƒ rd x9 t j | j ƒ D]% } t j t j j | j | ƒ ƒ q( Wt j | j ƒ n d S( N( R
R R R
t listdirR) R R* ( R t name( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyt
break_lockP s #N( t __name__t
__module__t __doc__R R R R' R+ R( R, R/ ( ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyR s
& ( t
__future__R R R R
R R t R R R R R R R ( ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/lockfile/mkdirlockfile.pyt s .