o 8ήc[@sdZddlmZmZmZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlZddlmZddlmZddlmZddlmZdd lmZmZdd lmZd d Z Gd ddedZ!Gddde!Z"GdddedZ#Gddde$Z%Gddde%e#Z&Gddde%e#Z'Gddde%e#Z(Gddde#Z)GdddedZ*Gd d!d!e*Z+Gd"d#d#e*Z,Gd$d%d%e$Z-Gd&d'd'e!Z.Gd(d)d)e.Z/e0d*gZ1d+d,Z2dS)-z+ Caching mechanism for compiled functions. )ABCMetaabstractmethodabstractpropertyN)AppDirs) NumbaWarning) BaseContext) CodeLibrary) CompileResult)configcompilerdumpscGstjr ||}t|dSdSN)r DEBUG_CACHEprint)msgargsr9/tmp/pip-target-vg8gfxp4/lib/python/numba/core/caching.py _cache_logs rc@sTeZdZeddZeddZeddZeddZed d Z ed d Z d S)_CachecCdS)zW The base filesystem path of this cache (for example its root folder). Nrselfrrr cache_path&z_Cache.cache_pathcCr)z Load an overload for the given signature using the target context. The saved object must be returned if successful, None if not found in the cache. Nrrsigtarget_contextrrr load_overload,rz_Cache.load_overloadcCr)z< Save the overload for the given signature. Nrrrdatarrr save_overload4rz_Cache.save_overloadcCr)z# Enable the cache. Nrrrrrenable:rz _Cache.enablecCr)z$ Disable the cache. Nrrrrrdisable@rz_Cache.disablecCr)z" Flush the cache. NrrrrrflushFrz _Cache.flushN) __name__ __module__ __qualname__rrrrr"r#r$r%rrrrr$s     r) metaclassc@s@eZdZeddZddZddZddZd d Zd d Z d S) NullCachecCdSrrrrrrrNszNullCache.cache_pathcCr+rrrrrrrRzNullCache.load_overloadcCr+rr)rrcresrrrr"Ur,zNullCache.save_overloadcCr+rrrrrrr#Xr,zNullCache.enablecCr+rrrrrrr$[r,zNullCache.disablecCr+rrrrrrr%^r,zNullCache.flushN) r&r'r(propertyrrr"r#r$r%rrrrr*Ms  r*c@sTeZdZdZddZeddZeddZedd Ze d d Z e d d Z dS) _CacheLocatorz< A filesystem locator for caching a given function. cCs*|}tj|ddtj|ddS)NT)exist_ok)dir)get_cache_pathosmakedirstempfile TemporaryFileclose)rpathrrrensure_cache_pathgsz_CacheLocator.ensure_cache_pathcCr)zA Return the directory the function is cached in. Nrrrrrr2mrz_CacheLocator.get_cache_pathcCr)z{ Get a timestamp representing the source code's freshness. Can return any picklable Python object. Nrrrrrget_source_stampsrz_CacheLocator.get_source_stampcCr)z Get a string disambiguator for this locator's function. It should allow disambiguating different but similarly-named functions. Nrrrrrget_disambiguatorzrz_CacheLocator.get_disambiguatorcCst)ze Create a locator instance for the given function located in the given file. )NotImplementedError)clspy_funcpy_filerrr from_functionsz_CacheLocator.from_functioncCsHtj|}tj|}tj|d}t|}d ||gS)zGiven the Python file path, compute a suitable path inside the cache directory. This will reduce a file path that is too long, which can be a problem on some operating system (i.e. Windows 7). _) r3r8abspathdirnamesplithashlibsha1encode hexdigestjoin)r=r?r8subpath parentdirhashedrrrget_suitable_cache_subpaths  z(_CacheLocator.get_suitable_cache_subpathN) r&r'r(__doc__r9rr2r:r; classmethodr@rNrrrrr/bs    r/c@,eZdZdZddZddZeddZdS) _SourceFileBackedLocatorMixinzf A cache locator mixin for functions which are backed by a well-known Python source file. cCs2ttddr ttj}nt|j}|j|jfSNfrozenF)getattrsysr3stat executable_py_filest_mtimest_size)rstrrrr:s   z._SourceFileBackedLocatorMixin.get_source_stampcCs t|jSr)str_linenorrrrr; z/_SourceFileBackedLocatorMixin.get_disambiguatorcCs>tj|sdS|||}z|W|StyYdSwr)r3r8existsr9OSErrorr=r>r?rrrrr@s    z+_SourceFileBackedLocatorMixin.from_functionN)r&r'r(rOr:r;rPr@rrrrrRs  rRcs4eZdZdZddZddZefddZZS)_UserProvidedCacheLocatorzd A locator that always point to the user provided directory in `numba.config.CACHE_DIR` cCs0||_|jj|_||}tjtj ||_ dSr) rY__code__co_firstlinenor^rNr3r8rJr CACHE_DIR _cache_path)rr>r? cache_subpathrrr__init__s  z"_UserProvidedCacheLocator.__init__cC|jSrrgrrrrr2z(_UserProvidedCacheLocator.get_cache_pathcs tjsdStt|}|||Sr)r rfsuperrcr@)r=r>r?parent __class__rrr@s  z'_UserProvidedCacheLocator.from_function) r&r'r(rOrir2rPr@ __classcell__rrrorrcs rcc@s eZdZdZddZddZdS)_InTreeCacheLocatorzn A locator for functions backed by a regular Python module with a writable __pycache__ directory. cCs.||_|jj|_tjtj|jd|_dS)N __pycache__) rYrdrer^r3r8rJrDrg)rr>r?rrrris z_InTreeCacheLocator.__init__cCrjrrkrrrrr2rlz"_InTreeCacheLocator.get_cache_pathN)r&r'r(rOrir2rrrrrrs rrc@rQ) _UserWideCacheLocatorz A locator for functions backed by a regular Python module or a frozen executable, cached into a user-wide cache directory. cCs@||_|jj|_tddd}|j}||}tj |||_ dS)NnumbaF)appname appauthor) rYrdrer^ruser_cache_dirrNr3r8rJrg)rr>r?appdirs cache_dirrhrrrris    z_UserWideCacheLocator.__init__cCrjrrkrrrrr2rlz$_UserWideCacheLocator.get_cache_pathcCsJtj|sttddsdS|||}z|W|Sty$YdSwrS)r3r8r`rUrVr9rarbrrrr@s   z#_UserWideCacheLocator.from_functionN)r&r'r(rOrir2rPr@rrrrrts rtc@s<eZdZdZddZddZddZdd Zed d Z d S) _IPythonCacheLocatorzT A locator for functions entered at the IPython prompt (notebook or other). cCs4||_t|}t|tr||_dS|d|_dS)Nzutf-8)rYinspect getsource isinstancebytes _bytes_sourcerH)rr>r?sourcerrrris    z_IPythonCacheLocator.__init__cCs@zddlm}Wntyddlm}Ynwtj|dS)Nr)get_ipython_cache_dir numba_cache) IPython.pathsr ImportErrorIPython.utils.pathr3r8rJ)rrrrrr2s  z#_IPythonCacheLocator.get_cache_pathcCst|jSr)rFsha256rrIrrrrr:z%_IPythonCacheLocator.get_source_stampcCs0d|jddd}t|ddS)NT )rJr splitlinesrFrrI)r firstlinesrrrr;sz&_IPythonCacheLocator.get_disambiguatorcCsV|dstjtj|dsdS|||}z|W|Sty*YdSw)Nz qualname source_pathr=locatorfilenamemodnamefullnamerrrrriCs*          zCacheImpl.__init__cCs<|dddd}d}|||jtjdtjd|fS)Nz%s-%s.py%d%d%sr)replacerr;rV version_info)rrrfixed_fullnamefmtrrrr\s  zCacheImpl.get_filename_basecCrjr)rrrrr filename_basedzCacheImpl.filename_basecCrjr)rrrrrrhrzCacheImpl.locatorcCr)z$Returns the serialized form the dataNrrr!rrrreducelzCacheImpl.reducecCr)z4Returns the de-serialized form of the *reduced_data*Nr)rr reduced_datarrrrebuildqrzCacheImpl.rebuildcCr)zEReturns True if the given data is cachable; otherwise, returns False.Nrrrrrcheck_cachablevrzCacheImpl.check_cachableN)r&r'r(rOrcrrrtr{rrirr.rrrrrrrrrrr7s&    rc@s(eZdZdZddZddZddZdS) CompileResultCacheImplz> Implements the logic to cache CompileResult objects. cC|S)z4 Returns a serialized CompileResult )_reduce)rr-rrrrzCompileResultCacheImpl.reducecCstjj|g|RS)z8 Returns the unserialized CompileResult )r r _rebuildrrpayloadrrrrszCompileResultCacheImpl.rebuildcCsfd}tdd|jDrd}n|jjrd}|r1d|jjdd|f}t|t |j j |j d Sd S) z@ Check cachability of the given compile result. Ncss|]}|j VqdSr) can_cache.0xrrr sz8CompileResultCacheImpl.check_cachable..zas it uses lifted codezLas it uses dynamic globals (such as ctypes pointers and large global arrays)z&Cannot cache compiled function "%s" %s.rAFT) anyliftedlibraryhas_dynamic_globalsfndescrrEwarnings warn_explicitrrrYr^)rr- cannot_cacherrrrrs z%CompileResultCacheImpl.check_cachableN)r&r'r(rOrrrrrrrr|s  rcs<eZdZdZdZddZddZddZfd d ZZ S) CodeLibraryCacheImplz< Implements the logic to cache CodeLibrary objects. NcCr)z2 Returns a serialized CodeLibrary )serialize_using_object_codercodelibrrrrrzCodeLibraryCacheImpl.reducecCs||S)z6 Returns the unserialized CodeLibrary )codegenunserialize_libraryrrrrrszCodeLibraryCacheImpl.rebuildcCs|j S)z= Check cachability of the given CodeLibrary. )rrrrrrrz#CodeLibraryCacheImpl.check_cachablecs&tt|}|||}d|j|gS)N-)rmrrrJ_filename_prefix)rrrrnresrorrrs  z&CodeLibraryCacheImpl.get_filename_base) r&r'r(rOrrrrrrqrrrorrsrc@sveZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZejddZdS)IndexDataCacheFilezP Implements the logic for the index file and data file used by a cache. cCsD||_d|f|_tj|j|j|_d|f|_||_tj |_ dS)Nz%s.nbiz%s.{number:d}.nbc) rg _index_namer3r8rJ _index_path_data_name_pattern _source_stampru __version___version)rrr source_stamprrrris    zIndexDataCacheFile.__init__cCs|idSr) _save_indexrrrrr%zIndexDataCacheFile.flushcCs||}z||}Wn+ty5t|}tdD] }||}||vr)nq|||<||Ynw|||dS)z? Save a new cache entry with *key* and *data*. rN) _load_indexKeyErrorsetvalues itertoolscount _data_namer _save_data)rkeyr! overloads data_nameexistingirrrsaves     zIndexDataCacheFile.savecCs@|}||}|durdSz||WStyYdSw)z0 Load a cache entry with *key*. N)rget _load_datara)rrrrrrrloads   zIndexDataCacheFile.loadcCsz!t|jd}t|}|}Wdn1swYWn ty,iYSw||jkr4iSt|\}}td|j||j krHiS|S)z| Load the cache index and return it as a dictionary (possibly empty if cache is empty or obsolete). rbNz[cache] index loaded from %r) openrpicklerreadFileNotFoundErrorrloadsrr)rfversionr!stamprrrrrs       zIndexDataCacheFile._load_indexcCsl|j|f}||}||j}tj|j|dd||Wdn1s)wYtd|jdS)NrA)protocolz[cache] index saved to %r) r_dump_open_for_writerrdumprwriter)rrr!rrrrrs   zIndexDataCacheFile._save_indexcCsT||}t|d }|}Wdn1swYt|}td||S)Nrzache] data loaded from %r) _data_pathrrrrr)rnamer8rr!tuprrrrs     zIndexDataCacheFile._load_datacCsV||}||}|| }||Wdn1swYtd|dS)Nz[cache] data saved to %r)rrrrr)rrr!r8rrrrrs    zIndexDataCacheFile._save_datacCs|jj|dS)N)number)rformat)rrrrrrrzIndexDataCacheFile._data_namecCstj|j|Sr)r3r8rJrg)rrrrrr"rzIndexDataCacheFile._data_pathcCst|Srr )robjrrrr%szIndexDataCacheFile._dumpc cstjdd}d||f}z!t|d }|VWdn1s$wYt||WdStyIzt|WtyHYww)z Open *filepath* for writing in a race condition-free way (hopefully). uuid4 is used to try and avoid name collisions on a shared filesystem. Nz %s.tmp.%swb) uuiduuid4hexrr3r Exceptionunlinkra)rfilepathuidtmpnamerrrrr(s"     z"IndexDataCacheFile._open_for_writeN)r&r'r(rOrir%rrrrrrrrr contextlibcontextmanagerrrrrrrsrc@s~eZdZdZdZddZddZeddZd d Z d d Z d dZ ddZ ddZ ddZddZejddZddZdS)Cachea< A per-function compilation cache. The cache saves data in separate data files and maintains information in an index file. There is one index file per function and Python version ("function_name-.pyXY.nbi") which contains a mapping of signatures and architectures to data files. It is prefixed by a versioning key and a timestamp of the Python source file containing the function. There is one data file ("function_name-.pyXY..nbc") per function, function signature, target architecture and Python version. Separate index and data files per Python version avoid pickle compatibility problems. Note: This contains the driver logic only. The core logic is provided by a subclass of ``CacheImpl`` specified as *_impl_class* in the subclass. NcCs\t||_||_|||_|jj|_|jj}|jj }t |j||d|_ | dS)N)rrr) repr_name_py_func _impl_class_implrr2rgr:rr _cache_filer#)rr>rrrrrriVs    zCache.__init__cCsd|jj|jfS)Nz<%s py_func=%r>)rpr&r rrrr__repr__cszCache.__repr__cCrjrrkrrrrrfrzCache.cache_pathcC d|_dS)NT_enabledrrrrr#jr_z Cache.enablecCr)NFrrrrrr$mr_z Cache.disablecCs|jdSr)rr%rrrrr%prz Cache.flushcCs@|||||WdS1swYdS)zr Load and recreate the cached object for the given signature, using the *target_context*. N)refresh!_guard_against_spurious_io_errors_load_overloadrrrrrss  $zCache.load_overloadcCs@|jsdS|||}|j|}|dur|j||}|Sr)r _index_keyrrrrr)rrrrr!rrrr~s zCache._load_overloadcCs:||||WddS1swYdS)zE Save the data for the given signature in the cache. N)r_save_overloadr rrrr"s "zCache.save_overloadcCsR|jsdS|j|s dS|jj|||j}|j|}|j ||dSr) rrrrr9rrrrr)rrr!rrrrrs   zCache._save_overloadc csXtjdkr'zdVWdSty&}z|jtjkrWYd}~dSd}~wwdVdS)Nnt)r3rraerrnoEACCES)rerrrrs    z'Cache._guard_against_spurious_io_errorscCs\|jjj}|jjdurtdd|jjD}t|}nd}dd}||||||ffS)a  Compute index key for the given signature and codegen. It includes a description of the OS, target architecture and hashes of the bytecode for the function and, if the function has a __closure__, a hash of the cell_contents. NcSsg|]}|jqSr) cell_contentsrrrr sz$Cache._index_key..rcSst|Sr)rFrrI)rrrrsz"Cache._index_key..)r rdco_code __closure__tupler magic_tuple)rrr codebytescvars cvarbyteshasherrrrrs   zCache._index_key)r&r'r(rOrrirr.rr#r$r%rrr"rrr rrrrrrr =s"      r c@seZdZdZeZdS) FunctionCachezF Implements Cache that saves and loads CompileResult objects. N)r&r'r(rOrrrrrrr)sr)rcsBtvsJtGfdddtGfdddt}|S)z Create a Cache class for additional compilation features to cache their result for reuse. The cache is saved in filename pattern like in ``FunctionCache`` but with additional *prefix* as specified. cseZdZZdS)z6make_library_cache..CustomCodeLibraryCacheImplN)r&r'r(rr)prefixrrCustomCodeLibraryCacheImplsr+cseZdZdZZdS)z(make_library_cache..LibraryCachez Implements Cache that saves and loads CodeLibrary objects for additional feature for the specified python function. N)r&r'r(rOrr)r+rr LibraryCachesr,)_lib_cache_prefixesaddrr )r*r,r)r+r*rmake_library_caches  r/)3rOabcrrrrrrFr|rr3rrVr5rrnumba.misc.appdirsrrunumba.core.errorsrnumba.core.basernumba.core.codegenrnumba.core.compilerr numba.corer r numba.core.serializer rrr*r/objectrRrcrrrtr{rrrrr r)rr-r/rrrrsL      )9  7E$~~