mirror of
https://github.com/deepspeedai/DeepSpeed.git
synced 2025-10-20 23:53:48 +08:00
10ba3dde84
* Handles an edge case when building `gds` where `CUDA_HOME` is not defined on ROCm systems
67 lines
2.1 KiB
Python
67 lines
2.1 KiB
Python
# Copyright (c) Microsoft Corporation.
|
|
# SPDX-License-Identifier: Apache-2.0
|
|
|
|
# DeepSpeed Team
|
|
|
|
import os
|
|
from .async_io import AsyncIOBuilder
|
|
|
|
|
|
class GDSBuilder(AsyncIOBuilder):
|
|
BUILD_VAR = "DS_BUILD_GDS"
|
|
NAME = "gds"
|
|
|
|
def __init__(self):
|
|
super().__init__()
|
|
|
|
def absolute_name(self):
|
|
return f'deepspeed.ops.gds.{self.NAME}_op'
|
|
|
|
def lib_sources(self):
|
|
src_list = ['csrc/gds/py_lib/deepspeed_py_gds_handle.cpp', 'csrc/gds/py_lib/deepspeed_gds_op.cpp']
|
|
return super().lib_sources() + src_list
|
|
|
|
def sources(self):
|
|
return self.lib_sources() + ['csrc/gds/py_lib/py_ds_gds.cpp']
|
|
|
|
def cxx_args(self):
|
|
return super().cxx_args() + ['-lcufile']
|
|
|
|
def include_paths(self):
|
|
import torch
|
|
CUDA_INCLUDE = [os.path.join(torch.utils.cpp_extension.CUDA_HOME, "include")]
|
|
return ['csrc/aio/py_lib', 'csrc/aio/common'] + CUDA_INCLUDE
|
|
|
|
def extra_ldflags(self):
|
|
return super().extra_ldflags() + ['-lcufile']
|
|
|
|
def is_compatible(self, verbose=False):
|
|
if self.is_rocm_pytorch():
|
|
if verbose:
|
|
self.warning(f'{self.NAME} is not compatible with ROCM')
|
|
return False
|
|
|
|
try:
|
|
import torch.utils.cpp_extension
|
|
except ImportError:
|
|
if verbose:
|
|
self.warning("Please install torch if trying to pre-compile GDS")
|
|
return False
|
|
|
|
CUDA_HOME = torch.utils.cpp_extension.CUDA_HOME
|
|
if CUDA_HOME is None:
|
|
if verbose:
|
|
self.warning("Please install torch CUDA if trying to pre-compile GDS with CUDA")
|
|
return False
|
|
|
|
CUDA_LIB64 = os.path.join(CUDA_HOME, "lib64")
|
|
gds_compatible = self.has_function(funcname="cuFileDriverOpen",
|
|
libraries=("cufile", ),
|
|
library_dirs=(
|
|
CUDA_HOME,
|
|
CUDA_LIB64,
|
|
),
|
|
verbose=verbose)
|
|
|
|
return gds_compatible and super().is_compatible(verbose)
|