ó éÐLac@seddlmZddlmZddlZdefd„ƒYZdefd„ƒYZeƒZdS(iÿÿÿÿ(tdirname(tObserverNt CacheManagercBs2eZdZd„Zd„Zd„Zd„ZRS(s| A naive cache implementation for listdir and digest_file The listdir_cache is just a giant list of PkgFile objects, and for simplicity it is invalidated anytime a modification occurs within the directory it represents. If we were smarter about the way that the listdir data structure were created/stored, then we could do more granular invalidation. In practice, this is good enough for now. The digest_cache exists on a per-file basis, because computing hashes on large files can get expensive, and it's very easy to invalidate specific filenames. cCshi|_i|_tƒ|_|jjƒtƒ|_tjƒ|_ tjƒ|_ tjƒ|_ dS(N( t listdir_cachet digest_cacheRtobservertstarttsettwatchedt threadingtLockt watch_lockt digest_lockt listdir_lock(tself((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pyt__init__s     c Cs†|jwy|j|SWn`tk r{|j$||jkrR|j|ƒnWdQXt||ƒƒ}||j|<|SXWdQXdS(N(R RtKeyErrorR Rt_watchtlist(Rtroottimpl_fntv((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pytlistdir0s    c CsÆ|j·y|j|}Wn&tk rC|jj|iƒ}nXy ||SWnLtk ržt|ƒ}|j$||jkr•|j|ƒnWdQXnX|||ƒ}|||<|SWdQXdS(N(R RRt setdefaultRR RR(Rtfpatht hash_algoRtcacheRR((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pyt digest_file>s       cCs6|jj|ƒ|jjt||ƒ|dtƒdS(Nt recursive(RtaddRtschedulet _EventHandlertTrue(RR((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pyRTs(t__name__t __module__t__doc__RRRR(((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pyR s    RcBseZd„Zd„ZRS(cCs||_||_dS(N(RR(RRR((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pyRZs c CsÙ|j}|jrdS|j|jj|jdƒWdQXg}|jdkrt|j|j ƒ|j|j ƒn|j|j ƒ|j Fx>|j j ƒD]-\}}x|D]}|j|dƒq±WqžWWdQXdS(sCalled by watchdog observerNtmoved(Rt is_directoryR RtpopRtNonet event_typetappendtsrc_patht dest_pathR Rtitems(RteventRtpathst_tsubcachetpath((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pytdispatch^s     (R!R"RR2(((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pyRXs ( tos.pathRtwatchdog.observersRR tobjectRRt cache_manager(((sK/var/www/html/packages/venv/lib/python3.8/site-packages/pypiserver/cache.pyts  M