ó ßüÚ\c@sddlZddlZddlZddlZdgZyddlZWnüek rGy(ddlZddlZddl Z Wnek r edƒ‚qiXej dde ƒZ e j Zejje_ejjgejjgde_e jZejje_ejjgejjgde_eZd„Zd„Zn"Xe Zd „Zd „Zd „ZejƒZejƒZd „Z d „Z!de"fd„ƒYZ#d„Z$de%fd„ƒYZ&de%fd„ƒYZ'de%fd„ƒYZ(de%fd„ƒYZ)dS(iÿÿÿÿNt lock_files?Platform not supported (failed to import fcntl, ctypes, msvcrt)tkernel32tuse_last_erroricCscttj|jƒƒddddƒ}|r1tStjƒ}|dkr[tj|ƒ‚ntSdS(Niii!( t_WinAPI_LockFiletmsvcrtt get_osfhandletfilenotTruetctypestget_last_errortWinErrortFalse(tfile_tresterr((s1lib/python2.7/site-packages/distributed/locket.pyt_lock_file_non_blocking)s'  cCs)ttj|jƒƒddddƒdS(Nii(t_WinAPI_UnlockFileRRR(R ((s1lib/python2.7/site-packages/distributed/locket.pyt _unlock_file4scCstj|jƒtjƒdS(N(tfcntltflockRtLOCK_EX(R ((s1lib/python2.7/site-packages/distributed/locket.pyt_lock_file_blocking;scCsdy(tj|jƒtjtjBƒtSWn5tk r_}|jtjtj gkrYt S‚nXdS(N( RRRRtLOCK_NBRtIOErrorterrnotEACCEStEAGAINR (R terror((s1lib/python2.7/site-packages/distributed/locket.pyR>s cCstj|jƒtjƒdS(N(RRRtLOCK_UN(R ((s1lib/python2.7/site-packages/distributed/locket.pyRHscKs]tjƒz8tj|ƒ}|dkrAt|ƒ}|t|•tR3R4R%(R!RBRR7R?(R8R3R4((R8s1lib/python2.7/site-packages/distributed/locket.pyRs cCs|jjƒdS(N(RBR#(R8((s1lib/python2.7/site-packages/distributed/locket.pyR#›sN(R.R/R:R!RR#(((s1lib/python2.7/site-packages/distributed/locket.pyR(‹s  R)cBs)eZd„Zddd„Zd„ZRS(cCs%||_d|_tjƒ|_dS(N(R?R!t_fileR@RAt _thread_lock(R8R%((s1lib/python2.7/site-packages/distributed/locket.pyR: s  c sxˆjdkr'tˆjdƒˆ_n|dkrItrItˆjƒn+td‡fd†d|d|dˆjƒdS(NtwbRcs tˆjƒS(N(RRE((R8(s1lib/python2.7/site-packages/distributed/locket.pyRC¬RDR3R4R%(RER!topenR?t_lock_file_blocking_availableRR7(R8R3R4((R8s1lib/python2.7/site-packages/distributed/locket.pyR¥scCs't|jƒ|jjƒd|_dS(N(RREtcloseR!(R8((s1lib/python2.7/site-packages/distributed/locket.pyR#²s  N(R.R/R:R!RR#(((s1lib/python2.7/site-packages/distributed/locket.pyR)Ÿs  R$cBsAeZdZddd„Zd„Zd„Zd„Zd„ZRS(sg A lock wrapper to always apply the given *timeout* and *retry_period* to acquire() calls. cCs||_||_||_dS(N(RBt_timeoutt _retry_period(R8R'R3R4((s1lib/python2.7/site-packages/distributed/locket.pyR:¾s  cCs|jj|j|jƒdS(N(RBRRKRL(R8((s1lib/python2.7/site-packages/distributed/locket.pyRÃscCs|jjƒdS(N(RBR#(R8((s1lib/python2.7/site-packages/distributed/locket.pyR#ÆscCs|jƒ|S(N(R(R8((s1lib/python2.7/site-packages/distributed/locket.pyt __enter__És cGs|jƒdS(N(R#(R8targs((s1lib/python2.7/site-packages/distributed/locket.pyt__exit__ÍsN( R.R/t__doc__R!R:RR#RMRO(((s1lib/python2.7/site-packages/distributed/locket.pyR$¸s    (*R0RR@tweakreft__all__Rt ImportErrorRtctypes.wintypesRtWinDLLRt _kernel32tLockFileRtwintypestBOOLtrestypetHANDLEtDWORDtargtypest UnlockFileRR RIRRRRARtWeakValueDictionaryRRR"t ExceptionR-R7tobjectR*R(R)R$(((s1lib/python2.7/site-packages/distributed/locket.pytsT