compiler: Add skeleton support for NCU-based profiling

Author: FabioLuporini

devito/__init__.py

@@ -42,7 +42,7 @@
 from devito.core import *   # noqa
 from devito.logger import logger_registry, _set_log_level  # noqa
 from devito.mpi.routines import mpi_registry
-from devito.operator import profiler_registry, operator_registry
+from devito.operator import NcuProfiling, profiler_registry, operator_registry
 
 # Apply monkey-patching while we wait for our patches to be upstreamed and released
 from devito.mpatches import *  # noqa
@@ -160,7 +160,15 @@ def autotune_callback(val):  # noqa
 configuration.add('opt-options', {}, deprecate='dle-options')
 
 # Setup Operator profiling
-configuration.add('profiling', 'basic', list(profiler_registry), impacts_jit=False)
+def profiling_preprocessor(i):
+    if isinstance(i, dict):
+        return NcuProfiling(i['ncu'])
+
+    return i
+
+
+configuration.add('profiling', 'basic', list(profiler_registry),
+                  preprocessor=profiling_preprocessor, impacts_jit=False)
 
 # Initialize `configuration`
 init_configuration()

devito/arch/archinfo.py

@@ -21,8 +21,9 @@
 __all__ = [  # noqa: RUF022
     'platform_registry', 'get_cpu_info', 'get_gpu_info', 'get_visible_devices',
     'get_nvidia_cc', 'get_cuda_path', 'get_cuda_version', 'get_hip_path',
-    'check_cuda_runtime', 'get_m1_llvm_path', 'get_advisor_path', 'Platform',
-    'Cpu64', 'Intel64', 'IntelSkylake', 'Amd', 'Arm', 'Power', 'Device',
+    'check_cuda_runtime', 'load_cudart', 'get_m1_llvm_path', 'get_advisor_path',
+    'Platform', 'Cpu64', 'Intel64', 'IntelSkylake', 'Amd', 'Arm', 'Power',
+    'Device',
     'NvidiaDevice', 'AmdDevice', 'IntelDevice',
     # Brand-agnostic
     'ANYCPU', 'ANYGPU',
@@ -646,13 +647,25 @@ def get_m1_llvm_path(language):
 
 
 @memoized_func
-def check_cuda_runtime():
+def load_cudart():
+    """
+    Load the CUDA runtime library.
+    """
     libname = ctypes.util.find_library("cudart")
     if not libname:
+        raise RuntimeError("Unable to find CUDA runtime library `libcudart`")
+
+    return ctypes.CDLL(libname)
+
+
+@memoized_func
+def check_cuda_runtime():
+    try:
+        cuda = load_cudart()
+    except RuntimeError:
         warning("Unable to check compatibility of NVidia driver and runtime")
         return
 
-    cuda = ctypes.CDLL(libname)
     driver_version = ctypes.c_int()
     runtime_version = ctypes.c_int()
 
@@ -1115,11 +1128,10 @@ def max_shm_per_block(self):
         """
         Get the maximum amount of shared memory per thread block
         """
-        # Load libcudart
-        libname = ctypes.util.find_library("cudart")
-        if not libname:
+        try:
+            lib = load_cudart()
+        except RuntimeError:
             return 64 * 1024  # 64 KB default
-        lib = ctypes.CDLL(libname)
 
         cudaDevAttrMaxSharedMemoryPerBlockOptin = 97
         # get current device

devito/operator/__init__.py

@@ -1,3 +1,3 @@
 from .operator import Operator  # noqa
-from .profiling import profiler_registry  # noqa
+from .profiling import NcuProfiling, profiler_registry  # noqa
 from .registry import operator_registry  # noqa

devito/operator/profiling.py

@@ -19,7 +19,7 @@
 from devito.symbolics import subs_op_args
 from devito.tools import DefaultOrderedDict, flatten
 
-__all__ = ['create_profile']
+__all__ = ['create_profile', 'NcuProfiling']
 
 
 SectionData = namedtuple('SectionData', 'ops sops points traffic itermaps')
@@ -28,6 +28,28 @@
 PerfEntry = namedtuple('PerfEntry', 'time gflopss gpointss oi ops itershapes')
 
 
+class NcuProfiling(str):
+
+    """
+    String-like profiling mode carrying the Operator selected for NCU.
+
+    The string value is ``'ncu'`` so profiler construction can use this object
+    directly as a key into ``profiler_registry``. The selected Operator is kept
+    in ``operator_name``.
+    """
+
+    def __new__(cls, operator_name):
+        if not isinstance(operator_name, str) or not operator_name:
+            raise ValueError("Expected DEVITO_PROFILING=ncu:op_name")
+        if ',' in operator_name:
+            raise ValueError("NCU profiling supports one Operator at a time")
+
+        obj = str.__new__(cls, 'ncu')
+        obj.operator_name = operator_name
+
+        return obj
+
+
 class Profiler:
 
     _default_includes = []
@@ -532,6 +554,7 @@ def create_profile(name):
     'advanced': AdvancedProfiler,
     'advanced1': AdvancedProfilerVerbose1,
     'advanced2': AdvancedProfilerVerbose2,
+    'ncu': AdvancedProfilerVerbose2,
     'advisor': AdvisorProfiler
 }
 """Profiling levels."""

devito/parameters.py

@@ -199,7 +199,14 @@ def init_configuration(configuration=configuration, env_vars_mapper=env_vars_map
             # Env variable format: 'var=k1:v1;k2:v2:k3:v3:...'
             keys, values = zip(*[i.split(':') for i in items], strict=True)
             # Casting
-            values = [eval(i) for i in values]
+            processed = []
+            for i in values:
+                try:
+                    processed.append(eval(i))
+                except (NameError, SyntaxError):
+                    # Allow unquoted strings as `k:v` values.
+                    processed.append(i)
+            values = processed
         except AttributeError:
             # Env variable format: 'var=v', 'v' is not a string
             keys = [v]