U hW>@sddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZejejeZejedgZedd Zd d ZGd d d eZddZddZGdddeZGdddeZdS)N)Path)_build)get_cache_manager) GPUTarget) GPUDriverincludec sjdtd}|r@|r,tj|r,|Std|dg}ddl}|D]4}tj|dd}tj|r~|S| |qTtd}|r| d D]0}tj|}tj|r|S| |qt d d g }fd d |D}|D]&} tj| r| S| | qtjd} tj| rH| S| | tdd|dS)Nzlibamdhip64.soZTRITON_LIBHIP_PATHzTRITON_LIBHIP_PATH 'z' does not point to a valid rtorchlibZLD_LIBRARY_PATH:z/sbin/ldconfigz-pcs&g|]}|r|dqS))stripendswithsplit).0lineZlib_nameL/var/www/html/venv/lib/python3.8/site-packages/triton/backends/amd/driver.py 5sz2_get_path_to_hip_runtime_dylib..z/opt/rocm/lib/zcannot locate z after attempted paths )osgetenvr pathexists RuntimeErrorsitegetsitepackagesjoinappendr subprocess check_outputdecode splitlines) Zenv_libhip_pathpathsrrZenv_ld_library_pathdfZlibslocslocZcommon_install_pathrrr_get_path_to_hip_runtime_dylibs>        r'c Cst|d}t|}||d}|dkrtv}tj |d}t |d}| |W5QRXt |||gtg}t |d }|j||ddd}W5QRXW5QRXddl} | j||} | j| } | j| | S) Nzutf-8z.sozmain.cwrbT)binaryr)hashlibsha256encode hexdigestrZget_filetempfileTemporaryDirectoryrrropenwriter include_dirputreadimportlib.utilutilspec_from_file_locationmodule_from_specloader exec_module) srcnamekeycache cache_pathZtmpdirZsrc_pathr$so importlibspecmodrrrcompile_module_from_srcDs    .  rEcs$eZdZfddZddZZS)HIPUtilscs"t|dstt|||_|jS)Ninstance)hasattrsuperrF__new__rG)cls __class__rrrJYs zHIPUtils.__new__cCsHt}ttjtd}|d|d}t|d}|j |_ |j |_ dS)Nzdriver.cz/*py_libhip_search_path*/Z hip_utils) r'rrrrdirname read_textreplacerEZ load_binaryget_device_properties)self libhip_pathr<rDrrr__init__^s  zHIPUtils.__init__)__name__ __module__ __qualname__rJrU __classcell__rrrLrrFWs rFcCs8|ddkrdSddddddd d dd d d d d d d|S)Nr*ZhipDeviceptr_tint32_tint8_tint16_tint64_tuint32_tuint8_tuint16_tuint64_tfloatdoublei1i8Zi16Zi32Zi64u1u8u16u32Zu64Zfp16Zbf16Zfp32Zf32Zfp64rtyrrr ty_to_cppks( rnc sXt|}ddd|D}dddddfd d |D}d |}t|d kr~ddd d|Dnd}t} fdd |D} d| dt|d krd|nddddd| Dd|ddfdd |Dd|d|dddd |Ddt|d krJdddd|Dndd} | S)N, css$|]\}}t|d|VqdS)z argN)rnrirmrrr sz make_launcher..cSs8|ddkrdSddddddd d dd d d d d d d|S)NrrZ PyObject*r[r\r]r^r_r`rarbrcrdrerrlrrr_extracted_types( z&make_launcher.._extracted_typec Ss"dddddddddd d d d |S) NOr$r#lbhrqBHIK) rsrcrdlongr\r]r[r^r`rar_rbrrlrrr format_ofs z make_launcher..format_ofcsg|]}|qSrr)rrm)rtr~rrrsz!make_launcher..Z iiiKKOOOOrcss|]\}}d|VqdS)z&_argNrrprrrrrscsg|]}|kr|qSrrrrq) constantsrrrsa; #define __HIP_PLATFORM_AMD__ #include #include #include #include #include // The list of paths to search for the HIP runtime library. The caller Python // code should substitute the search path placeholder. static const char *hipLibSearchPaths[] = {"a"}; // The list of HIP dynamic library symbols and their signature we are interested // in this file. #define HIP_SYMBOL_LIST(FOR_EACH_ERR_FN, FOR_EACH_STR_FN) \ FOR_EACH_STR_FN(hipGetErrorString, hipError_t hipError) \ FOR_EACH_ERR_FN(hipModuleLaunchKernel, hipFunction_t f, \ unsigned int gridDimX, unsigned int gridDimY, \ unsigned int gridDimZ, unsigned int blockDimX, \ unsigned int blockDimY, unsigned int blockDimZ, \ unsigned int sharedMemBytes, hipStream_t stream, \ void **kernelParams, void **extra) \ FOR_EACH_ERR_FN(hipPointerGetAttribute, void *data, \ hipPointer_attribute attribute, hipDeviceptr_t ptr) // The HIP symbol table for holding resolved dynamic library symbols. struct HIPSymbolTable { #define DEFINE_EACH_ERR_FIELD(hipSymbolName, ...) \ hipError_t (*hipSymbolName)(__VA_ARGS__); #define DEFINE_EACH_STR_FIELD(hipSymbolName, ...) \ const char *(*hipSymbolName)(__VA_ARGS__); HIP_SYMBOL_LIST(DEFINE_EACH_ERR_FIELD, DEFINE_EACH_STR_FIELD) }; static struct HIPSymbolTable hipSymbolTable; bool initSymbolTable() { // Use the HIP runtime library loaded into the existing process if it exits. void *lib = dlopen("libamdhip64.so", RTLD_NOLOAD); if (lib) { // printf("[triton] chosen loaded libamdhip64.so in the process\n"); } // Otherwise, go through the list of search paths to dlopen the first HIP // driver library. if (!lib) { int n = sizeof(hipLibSearchPaths) / sizeof(hipLibSearchPaths[0]); for (int i = 0; i < n; ++i) { void *handle = dlopen(hipLibSearchPaths[i], RTLD_LAZY | RTLD_LOCAL); if (handle) { lib = handle; // printf("[triton] chosen %s\n", hipLibSearchPaths[i]); } } } if (!lib) { PyErr_SetString(PyExc_RuntimeError, "cannot open libamdhip64.so"); return false; } // Resolve all symbols we are interested in. dlerror(); // Clear existing errors const char *error = NULL; #define QUERY_EACH_FN(hipSymbolName, ...) \ *(void **)&hipSymbolTable.hipSymbolName = dlsym(lib, #hipSymbolName); \ error = dlerror(); \ if (error) { \ PyErr_SetString(PyExc_RuntimeError, \ "cannot query " #hipSymbolName " from libamdhip64.so"); \ dlclose(lib); \ return false; \ } HIP_SYMBOL_LIST(QUERY_EACH_FN, QUERY_EACH_FN) return true; } static inline void gpuAssert(hipError_t code, const char *file, int line) { if (code != HIP_SUCCESS) { const char* prefix = "Triton Error [HIP]: "; const char* str = hipSymbolTable.hipGetErrorString(code); char err[1024] = {0}; snprintf(err, 1024, "%s Code: %d, Messsage: %s", prefix, code, str ); PyErr_SetString(PyExc_RuntimeError, err); } } #define HIP_CHECK(ans) { gpuAssert((ans), __FILE__, __LINE__); } static void _launch(int gridX, int gridY, int gridZ, int num_warps, int num_ctas, int clusterDimX, int clusterDimY, int clusterDimZ, int shared_memory, hipStream_t stream, hipFunction_t functionz>) { // printf("_launch hip kernel\n"); void *params[] = { css|]}d|VqdS)z&argNrrrrrrrszw }; if (gridX*gridY*gridZ > 0) { HIP_CHECK(hipSymbolTable.hipModuleLaunchKernel(function, gridX, gridY, gridZ, aw*num_warps, 1, 1, shared_memory, stream, params, 0)); } } typedef struct _DevicePtrInfo { hipDeviceptr_t dev_ptr; bool valid; } DevicePtrInfo; static inline DevicePtrInfo getPointer(PyObject *obj, int idx) { DevicePtrInfo ptr_info; ptr_info.dev_ptr = 0; ptr_info.valid = true; if (PyLong_Check(obj)) { ptr_info.dev_ptr = (hipDeviceptr_t)PyLong_AsUnsignedLongLong(obj); return ptr_info; } if (obj == Py_None) { // valid nullptr return ptr_info; } PyObject *ptr = PyObject_GetAttrString(obj, "data_ptr"); if(ptr){ PyObject *empty_tuple = PyTuple_New(0); PyObject *ret = PyObject_Call(ptr, empty_tuple, NULL); Py_DECREF(empty_tuple); Py_DECREF(ptr); if (!PyLong_Check(ret)) { PyErr_SetString(PyExc_TypeError, "data_ptr method of Pointer object must return 64-bit int"); ptr_info.valid = false; return ptr_info; } ptr_info.dev_ptr = (hipDeviceptr_t)PyLong_AsUnsignedLongLong(ret); if(!ptr_info.dev_ptr) return ptr_info; uint64_t dev_ptr; hipError_t status = hipSymbolTable.hipPointerGetAttribute(&dev_ptr, HIP_POINTER_ATTRIBUTE_DEVICE_POINTER, ptr_info.dev_ptr); if (status == hipErrorInvalidValue) { PyErr_Format(PyExc_ValueError, "Pointer argument (at %d) cannot be accessed from Triton (cpu tensor?)", idx); ptr_info.valid = false; } ptr_info.dev_ptr = (hipDeviceptr_t)dev_ptr; Py_DECREF(ret); return ptr_info; } PyErr_SetString(PyExc_TypeError, "Pointer argument must be either uint64 or have data_ptr method"); return ptr_info; } static PyObject* launch(PyObject* self, PyObject* args) { // printf("launch\n"); int gridX, gridY, gridZ; uint64_t _stream; uint64_t _function; PyObject *launch_enter_hook = NULL; PyObject *launch_exit_hook = NULL; PyObject *kernel_metadata = NULL; PyObject *launch_metadata = NULL;  cs$g|]\}}|d|dqS)z _arg; rrp)rtrrrOsz if(!PyArg_ParseTuple(args, "z", &gridX, &gridY, &gridZ, &_stream, &_function, &kernel_metadata, &launch_metadata, &launch_enter_hook, &launch_exit_hook a=)) { return NULL; } // extract kernel metadata int num_warps, num_ctas, shared_memory, clusterDimX, clusterDimY, clusterDimZ; if (!PyArg_ParseTuple(kernel_metadata, "iiiiii", &num_warps, &num_ctas, &shared_memory, &clusterDimX, &clusterDimY, &clusterDimZ)) { return NULL; } // extract launch metadata if (launch_enter_hook != Py_None){ PyObject* args = Py_BuildValue("(O)", launch_metadata); PyObject* ret = PyObject_CallObject(launch_enter_hook, args); Py_DECREF(args); if (!ret) return NULL; } // raise exception asap rc Ss>g|]6\}}|ddkr6d|d|d|d|d ndqS)rrZzDevicePtrInfo ptr_infoz = getPointer(_argroz); if (!ptr_infoz.valid) return NULL;rrrprrrrfsz; _launch(gridX, gridY, gridZ, num_warps, num_ctas, clusterDimX, clusterDimY, clusterDimZ, shared_memory, (hipStream_t)_stream, (hipFunction_t)_functioncss4|],\}}|ddkr"d|dnd|VqdS)rrZZptr_infoz.dev_ptrZ_argNrrprrrrrgsan); if(launch_exit_hook != Py_None){ PyObject* args = Py_BuildValue("(O)", launch_metadata); PyObject* ret = PyObject_CallObject(launch_exit_hook, args); Py_DECREF(args); if (!ret) return NULL; } if(PyErr_Occurred()) { return NULL; } // return None Py_INCREF(Py_None); return Py_None; } static PyMethodDef ModuleMethods[] = { {"launch", launch, METH_VARARGS, "Entry point for all kernels with this signature"}, {NULL, NULL, 0, NULL} // sentinel }; static struct PyModuleDef ModuleDef = { PyModuleDef_HEAD_INIT, "__triton_launcher", NULL, //documentation -1, //size ModuleMethods }; PyMODINIT_FUNC PyInit___triton_launcher(void) { if (!initSymbolTable()) { return NULL; } PyObject *m = PyModule_Create(&ModuleDef); if(m == NULL) { return NULL; } PyModule_AddFunctions(m, ModuleMethods); return m; } )lenritemsvaluesr'keys) r signatureids warp_sizeZ start_descZ arg_declsZ args_formatformatZ args_listrTparamsr<r)rtrr~r make_launchersP, ]_a 45,`rc@seZdZddZddZdS) HIPLaunchercsdtdrjjnti}tdr,jnt}fddfdd|D}fddjD}t||||j t d }|j |_ dS) NZids_of_const_exprsfnrcst|trjj|S|SN) isinstancestrr arg_namesindex)rq)r<rrz&HIPLauncher.__init__..csi|]\}}||qSrrrr>valuecst_keyrr sz(HIPLauncher.__init__..csi|]\}}||qSrrrrrrrsZ__triton_launcher) rHrZ constexprstuplerdictrrrrrElaunch)rSr<metadatarrrrDr)rr<rrUs  zHIPLauncher.__init__cOs|j||dSr)r)rSargskwargsrrr__call__szHIPLauncher.__call__N)rVrWrXrUrrrrrrs rcs0eZdZfddZeddZddZZS) HIPDrivercstt|_t|_dSr)rIrUrFutilsrZ launcher_cls)rSrLrrrUs zHIPDriver.__init__cCsddl}|jjdk S)Nr)rversionhip)rrrr is_activeszHIPDriver.is_activecCs:|}|j|}|d}|d}td|dd|S)NarchZwarpSizerr r)Zget_current_devicerrRrr)rSZdeviceZdevice_propertiesrrrrrget_current_targets  zHIPDriver.get_current_target)rVrWrXrU staticmethodrrrYrrrLrrs  r) functoolsrr+rr/pathlibrZtriton.runtime.buildrZtriton.runtime.cacherZtriton.backends.compilerrZtriton.backends.driverrrrOrealpath__file__rr3 lru_cacher'rEobjectrFrnrrrrrrrs*      3