ó ßüÚ\c@`såddlmZmZmZddlmZmZddlmZddl Z ddl Z ddl m Z ddl Z ddlmZddlmZdd lmZe jeƒZd efd „ƒYZd efd „ƒYZdS(i(tprint_functiontdivisiontabsolute_import(t defaultdicttdeque(t timedeltaN(tgeni(t_get_global_client(t log_errors(t get_workert LockExtensioncB`sGeZdZd„Zejddddd„ƒZdddd„ZRS(s’ An extension for the scheduler to manage Locks This adds the following routes to the scheduler * lock_acquire * lock_release cC`s_||_ttƒ|_tƒ|_|jjji|jd6|j d6ƒ||jj dt|tƒr(t|ƒ}n||jkr@t}nÉxÆ||jkrtjjƒ}|j |j |ƒ|j ƒ}|dk r«t jtd|ƒ|ƒ}nz1y |VWnt jk rÔt}PnXt}Wd|j |jƒ}||kst‚XqCW|r4||jks$t‚||j|>> lock = Lock('x') # doctest: +SKIP >>> lock.acquire(timeout=1) # doctest: +SKIP >>> # do things with protected resource >>> lock.release() # doctest: +SKIP cC`sY|ptƒptƒj|_|p4dtjƒj|_tjƒj|_t|_ dS(Nslock-( RR tclienttuuidtuuid4thexR*R+R%t_locked(RR*R;((s/lib/python2.7/site-packages/distributed/lock.pyRascC`sj|s*|dk r!tdƒ‚nd}n|jj|jjjd|jd|jd|ƒ}t|_ |S(s” Acquire the lock Parameters ---------- blocking : bool, optional If false, don't wait on the lock in the scheduler at all. timeout : number, optional Seconds to wait on the lock in the scheduler. This does not include local coroutine time, network transfer time, etc.. It is forbidden to specify a timeout when blocking is false. Examples -------- >>> lock = Lock('x') # doctest: +SKIP >>> lock.acquire(timeout=1) # doctest: +SKIP Returns ------- True or False whether or not it sucessfully acquired the lock s/can't specify a timeout for a non-blocking calliR*R+R,N( R"R2R;tsyncRR R*R+RR?(RtblockingR,R-((s/lib/python2.7/site-packages/distributed/lock.pyRgs       cC`sU|jƒstdƒ‚n|jj|jjjd|jd|jƒ}t|_ |S(s& Release the lock if already acquired sLock is not yet acquiredR*R+( tlockedR2R;R@RR R*R+R%R?(RR-((s/lib/python2.7/site-packages/distributed/lock.pyRŠs   $ cC`s|jS(N(R?(R((s/lib/python2.7/site-packages/distributed/lock.pyRB”scC`s|jƒ|S(N(R(R((s/lib/python2.7/site-packages/distributed/lock.pyt __enter__—s cO`s|jƒdS(N(R(Rtargstkwargs((s/lib/python2.7/site-packages/distributed/lock.pyt__exit__›scc`s|jƒVtj|ƒ‚dS(N(RRR((R((s/lib/python2.7/site-packages/distributed/lock.pyt __aenter__žs co`s|jƒVdS(N(R(RRDRE((s/lib/python2.7/site-packages/distributed/lock.pyt __aexit__£scC`st|jffS(N(R:R*(R((s/lib/python2.7/site-packages/distributed/lock.pyt __reduce__§sN(R6R7R8R"RRRRRBRCRFRR9RGRHRI(((s/lib/python2.7/site-packages/distributed/lock.pyR:Ps#   (t __future__RRRt collectionsRRtdatetimeRtloggingR<RRt tornado.locksR;RtutilsRtworkerR t getLoggerR6tloggertobjectR R:(((s/lib/python2.7/site-packages/distributed/lock.pyts   >