ó ø¢TQc@s´dZddlZddlmZddlmZmZddlmZddl m Z defd„ƒYZ d e fd „ƒYZ d e fd „ƒYZ d e fd„ƒYZdS(sMemcached cache backendiÿÿÿÿN(tlocal(t BaseCachetInvalidCacheBackendError(tsix(t force_strtBaseMemcachedCachecBsÅeZd„Zed„ƒZd„Zdd„Zddd„Zddd„Z ddd„Z dd„Z dd „Z d „Z d dd „Zd dd „Zddd„Zdd„Zd„ZRS(cCsqtt|ƒj|ƒt|tjƒr=|jdƒ|_n ||_||_||_ |j ddƒ|_ dS(Nt;tOPTIONS( tsuperRt__init__t isinstanceRt string_typestsplitt_serverstLibraryValueNotFoundExceptiont_libtgettNonet_options(tselftservertparamstlibrarytvalue_not_found_exception((s=../Django//lib/python/django/core/cache/backends/memcached.pyR s   cCs:t|ddƒdkr3|jj|jƒ|_n|jS(sR Implements transparent thread-safe access to a memcached client. t_clientN(tgetattrRRtClientR R(R((s=../Django//lib/python/django/core/cache/backends/memcached.pyt_cachescCs>|p |j}|dkr4|ttjƒƒ7}nt|ƒS(s– Memcached deals with long (> 30 days) timeouts in a special way. Call this function to obtain a safe value for your timeout. i'(tdefault_timeouttintttime(Rttimeout((s=../Django//lib/python/django/core/cache/backends/memcached.pyt_get_memcache_timeout&s cCsttt|ƒj||ƒƒS(N(RRRtmake_key(Rtkeytversion((s=../Django//lib/python/django/core/cache/backends/memcached.pyR!6sicCs4|j|d|ƒ}|jj|||j|ƒƒS(NR#(R!RtaddR (RR"tvalueRR#((s=../Django//lib/python/django/core/cache/backends/memcached.pyR$:scCs;|j|d|ƒ}|jj|ƒ}|dkr7|S|S(NR#(R!RRR(RR"tdefaultR#tval((s=../Django//lib/python/django/core/cache/backends/memcached.pyR>s  cCs8|j|d|ƒ}|jj|||j|ƒƒdS(NR#(R!RtsetR (RR"R%RR#((s=../Django//lib/python/django/core/cache/backends/memcached.pyR(EscCs)|j|d|ƒ}|jj|ƒdS(NR#(R!Rtdelete(RR"R#((s=../Django//lib/python/django/core/cache/backends/memcached.pyR)Isc s†t‡‡fd†|ƒ}ˆjj|ƒ}|r‚i}tt||ƒƒ}x(|jƒD]\}}||||Ns(tmapRt get_multitdicttziptitems( RtkeysR#tnew_keystrett_tmtktv((RR#s=../Django//lib/python/django/core/cache/backends/memcached.pytget_manyMs cKs|jjƒdS(N(Rtdisconnect_all(Rtkwargs((s=../Django//lib/python/django/core/cache/backends/memcached.pytcloseXsicCsŽ|j|d|ƒ}|dkr5|jj|| ƒSy|jj||ƒ}Wn|jk rjd}nX|dkrŠtd|ƒ‚n|S(NR#isKey '%s' not found(R!RtdecrtincrRRt ValueError(RR"tdeltaR#R'((s=../Django//lib/python/django/core/cache/backends/memcached.pyR=[s   cCsŽ|j|d|ƒ}|dkr5|jj|| ƒSy|jj||ƒ}Wn|jk rjd}nX|dkrŠtd|ƒ‚n|S(NR#isKey '%s' not found(R!RR=R<RRR>(RR"R?R#R'((s=../Django//lib/python/django/core/cache/backends/memcached.pyR<ms   cCsbi}x9|jƒD]+\}}|j|d|ƒ}|||(RRRRMRP((s=../Django//lib/python/django/core/cache/backends/memcached.pyR Žs   (RIRJR (((s=../Django//lib/python/django/core/cache/backends/memcached.pyRLstMemcachedCachecBseZdZd„ZRS(s;An implementation of a cache binding using python-memcachedcCs5ddl}tt|ƒj||d|dtƒdS(NiÿÿÿÿRR(RPRRRR R>(RRRRP((s=../Django//lib/python/django/core/cache/backends/memcached.pyR  s (RIRJt__doc__R (((s=../Django//lib/python/django/core/cache/backends/memcached.pyRRžst PyLibMCCachecBs&eZdZd„Zed„ƒZRS(s2An implementation of a cache binding using pylibmccCsDddl}tƒ|_tt|ƒj||d|d|jƒdS(NiÿÿÿÿRR(tpylibmcRt_localRRTR tNotFound(RRRRU((s=../Django//lib/python/django/core/cache/backends/memcached.pyR ¨s   cCs\t|jddƒ}|r|S|jj|jƒ}|jrL|j|_n||j_|S(Ntclient( RRVRRRR Rt behaviorsRX(RRX((s=../Django//lib/python/django/core/cache/backends/memcached.pyR¯s  (RIRJRSR RKR(((s=../Django//lib/python/django/core/cache/backends/memcached.pyRT¦s (RSRt threadingRtdjango.core.cache.backends.baseRRt django.utilsRtdjango.utils.encodingRRRLRRRT(((s=../Django//lib/python/django/core/cache/backends/memcached.pyts ‚