Optimized primitives for collective multi-GPU communication
This report summarizes scanner evidence for NVIDIA/nccl, a C++ project with 5,152 GitHub stars. SynthScan examined 222,503 lines of code across 896 source files, recording 1262 pattern matches distributed across 19 syntactic categories. The legacy adjusted pattern signal is 8.8 (Moderate pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 830 finding(s).
Are imports declared and package/API names verified? 125 finding(s).
Are wrappers, guards, and repeated structures necessary? 464 finding(s).
Which changes need focused human review? 1262 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 1262 distinct pattern matches across 19 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 26 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 28 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 43 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 45 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 54 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 56 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 79 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 81 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 94 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 96 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 116 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 118 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 142 | # ========================================================================= | COMMENT |
| MEDIUM | …_point_to_point/01_ring_pattern/python/ring_pattern.py | 144 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 42 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 44 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 59 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 61 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 83 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 85 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 99 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 101 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 117 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 119 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 131 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 133 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 146 | # ========================================================================= | COMMENT |
| MEDIUM | …uffer_registration/01_allreduce/python/allreduce_ub.py | 148 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 26 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 28 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …amples/03_collectives/01_allreduce/python/allreduce.py | 39 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …amples/03_collectives/01_allreduce/python/allreduce.py | 41 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …amples/03_collectives/01_allreduce/python/allreduce.py | 50 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …amples/03_collectives/01_allreduce/python/allreduce.py | 52 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 72 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 74 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 86 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 88 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 107 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 109 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 125 | # ========================================================================= | COMMENT |
| MEDIUM | …amples/03_collectives/01_allreduce/python/allreduce.py | 127 | # ========================================================================= | COMMENT |
| MEDIUM | …ngle_process/python/multiple_devices_single_process.py | 26 | # ========================================================================= | COMMENT |
| MEDIUM | …ngle_process/python/multiple_devices_single_process.py | 28 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …ngle_process/python/multiple_devices_single_process.py | 51 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …ngle_process/python/multiple_devices_single_process.py | 53 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …ngle_process/python/multiple_devices_single_process.py | 62 | # ========================================================================= | COMMENT |
| MEDIUM⚡ | …ngle_process/python/multiple_devices_single_process.py | 64 | # ========================================================================= | COMMENT |
| MEDIUM | …ngle_process/python/multiple_devices_single_process.py | 89 | # ========================================================================= | COMMENT |
| MEDIUM | …ngle_process/python/multiple_devices_single_process.py | 91 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 40 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 42 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 57 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 59 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 82 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 84 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 98 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 100 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 112 | # ========================================================================= | COMMENT |
| MEDIUM | …e_per_process_mpi/python/one_device_per_process_mpi.py | 114 | # ========================================================================= | COMMENT |
| 150 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | CMakeLists.txt | 181 | # /Zc:preprocessor enables conformant preprocessor for proper variadic macro handling (needed for NVTX) | COMMENT |
| LOW | plugins/tuner/example/plugin.c | 1 | /************************************************************************* | COMMENT |
| LOW | plugins/tuner/example/plugin.c | 21 | #define CONFIG_FIELD_ALGORITHM 3 | COMMENT |
| LOW | plugins/tuner/example/nccl/tuner.h | 41 | #define NCCL_PROTO_UNDEF -1 | COMMENT |
| LOW | plugins/tuner/example/nccl/tuner.h | 81 | COMMENT | |
| LOW | plugins/tuner/example/nccl/tuner.h | 101 | // Gets info (algo, protocol, number of ctas and threads) for a given collective. | COMMENT |
| LOW | plugins/tuner/example/nccl/tuner.h | 141 | // Inputs: | COMMENT |
| LOW | plugins/tuner/example/nccl/tuner.h | 161 | // - numProto: number of protocols in collCostTable | COMMENT |
| LOW | plugins/tuner/example/nccl/tuner.h | 181 | // context: tuner context object | COMMENT |
| LOW | plugins/tuner/basic/nccl/tuner.h | 41 | #define NCCL_PROTO_UNDEF -1 | COMMENT |
| LOW | plugins/tuner/basic/nccl/tuner.h | 61 | COMMENT | |
| LOW | plugins/net/CMakeLists.txt | 1 | # Since all the plugins generate binary with the same name, build only one of them | COMMENT |
| LOW | plugins/net/README.md | 81 | // Connect to a handle and return a sending comm object for that peer. | COMMENT |
| LOW | plugins/net/example/nccl/net.h | 21 | COMMENT | |
| LOW | plugins/net/example/nccl/net_v6.h | 21 | int maxRecvs; // Maximum number of grouped receives. | COMMENT |
| LOW | plugins/net/example/nccl/net_v6.h | 41 | ncclResult_t (*connect)(int dev, void* handle, void** sendComm); | COMMENT |
| LOW | plugins/net/example/nccl/net_v2.h | 21 | // as data from the current GPU. Supported types should be composed with | COMMENT |
| LOW | plugins/net/example/nccl/net_v8.h | 41 | // This call must not block for the connection to be established, and instead | COMMENT |
| LOW | plugins/net/example/nccl/net_v10.h | 41 | size_t maxCollBytes; // Max transfer size for collective operations | COMMENT |
| LOW | plugins/net/example/nccl/net_v10.h | 61 | // If *sendDevComm points to a valid object, then NCCL is requesting device offload for this connection | COMMENT |
| LOW | plugins/net/example/nccl/net_v5.h | 21 | // Create a receiving object and provide a handle to connect to it. The | COMMENT |
| LOW | plugins/net/example/nccl/net_v4.h | 41 | ncclResult_t (*accept)(void* listenComm, void** recvComm); | COMMENT |
| LOW | plugins/net/example/nccl/net_v11.h | 61 | COMMENT | |
| LOW | plugins/net/example/nccl/net_v11.h | 81 | // Finalize connection establishment after remote peer has called connect. | COMMENT |
| LOW | plugins/net/example/nccl/net_v7.h | 41 | // should return successfully with sendComm == NULL with the expectation that | COMMENT |
| LOW | plugins/net/example/nccl/net_v12.h | 81 | // it will be called again until sendComm != NULL. | COMMENT |
| LOW | plugins/net/example/nccl/net_v9.h | 41 | // Return the number of adapters. | COMMENT |
| LOW | plugins/net/example/nccl/net_v9.h | 61 | // Register/Deregister memory. Comm can be either a sendComm or a recvComm. | COMMENT |
| LOW | plugins/net/example/nccl/net_v3.h | 21 | // Get various device properties. | COMMENT |
| LOW | plugins/profiler/README.md | 61 | // Input | COMMENT |
| LOW | plugins/profiler/README.md | 81 | // stopEvent - stop/finalize an event inside and event set | COMMENT |
| LOW | plugins/profiler/inspector/inspector_ring.h | 1 | #ifndef INSPECTOR_INSPECTOR_RING_H_ | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v4.h | 81 | struct { | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v4.h | 101 | COMMENT | |
| LOW | plugins/profiler/inspector/nccl/profiler_v3.h | 81 | typedef struct { | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v3.h | 101 | // - eHandle: handle to event object | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v2.h | 81 | ncclResult_t (*init)(void** context, int* eActivationMask); | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v1.h | 81 | // Input | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v1.h | 101 | // Input | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v5.h | 121 | // - logfn : logger function | COMMENT |
| LOW | plugins/profiler/inspector/nccl/profiler_v5.h | 141 | // - eHandle : handle to event object created through startEvent | COMMENT |
| LOW | plugins/profiler/example/event.h | 1 | /************************************************************************* | COMMENT |
| LOW | plugins/profiler/example/nccl/profiler_v4.h | 81 | COMMENT | |
| LOW | plugins/profiler/example/nccl/profiler_v4.h | 101 | // - eDescr : pointer to ncclProfilerEventDescr_t object | COMMENT |
| LOW | plugins/profiler/example/nccl/profiler_v3.h | 81 | COMMENT | |
| LOW | plugins/profiler/example/nccl/profiler_v3.h | 101 | COMMENT | |
| LOW | plugins/profiler/example/nccl/profiler_v2.h | 81 | // startEvent - initialize and start a new event for the supplied event descriptor inside the eventset | COMMENT |
| LOW | plugins/profiler/example/nccl/profiler_v1.h | 81 | // - eActivationMask: bitmask of active events set by the plugin | COMMENT |
| LOW | plugins/profiler/example/nccl/profiler_v5.h | 121 | // - rank : rank identifier in communicator | COMMENT |
| LOW | plugins/profiler/example/nccl/profiler_v5.h | 141 | // Input | COMMENT |
| LOW | plugins/gin/example/nccl/gin_v13.h | 21 | typedef struct { | COMMENT |
| LOW | plugins/rma/example/nccl/rma_v14.h | 21 | const char* name; | COMMENT |
| LOW | …rks/DeepEPv2_Analysis_Part1/DeepEPv2_Analysis_Part1.md | 1261 | agrs_buffer_slot_idx += 1; | COMMENT |
| LOW | docs/examples/common/include/utils.h | 1 | /************************************************************************* | COMMENT |
| LOW | contrib/nccl4rust/crates/nccl/src/types.rs | 141 | #[derive(Clone, Copy, Debug, Eq, Hash, PartialEq)] | COMMENT |
| LOW | contrib/nccl4rust/crates/nccl/src/types.rs | 221 | COMMENT | |
| LOW | contrib/nccl4rust/crates/nccl/src/group.rs | 141 | break; | COMMENT |
| LOW | contrib/nccl4rust/crates/nccl/src/communicator.rs | 41 | /// | COMMENT |
| LOW | contrib/nccl4rust/crates/nccl-device/src/lib.rs | 1 | // SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved. | COMMENT |
| LOW | contrib/nccl4rust/crates/nccl-device/src/lib.rs | 261 | /// Translate a registered window offset for an LSA-local peer. | COMMENT |
| 491 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 970 | Initializes a new NCCL communicator. Creates a communicator that connects multiple ranks. This is a col | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 998 | Initializes multiple NCCL communicators for single-process multi-GPU operations. Creates an array of NCCL commu | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1101 | Splits this communicator into sub-communicators based on color values. Ranks that pass the same ``color`` value | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1153 | Creates a new communicator by removing specified ranks from this one. Ranks listed in ``exclude_ranks`` are exc | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1233 | Grows the communicator by adding new ranks. Creates a new communicator that includes both existing ranks from | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1700 | Maps a rank within ``team`` to its rank in this communicator. ``team`` is anchored at this rank, so ``team.rank | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1722 | Maps a rank within ``team`` to its rank in the LSA team. The LSA-relative counterpart of :py:meth:`team_rank_to | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 2474 | Registers a buffer with this communicator for zero-copy communication. Registered buffers can enable performanc | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 2512 | Collectively registers a local buffer into an NCCL window. This is a collective call: every rank in the communi | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 2564 | Creates a PreMulSum custom reduction operator. Performs ``output = scalar * sum(inputs)`` and is useful for | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 2674 | Creates a device communicator for device-side NCCL operations. This is a collective call: every rank in the com | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 2799 | Queries communicator memory statistics. Args: stat: The memory statistic to query. Returns | STRING |
| HIGH | bindings/nccl4py/nccl/core/cuda.py | 82 | Resolves a stream specification to a cuda.core.Stream. Args: stream: A Stream instance, an integer stream h | STRING |
| HIGH | bindings/nccl4py/nccl/core/cuda.py | 112 | Resolves a CUDA stream specification to an integer ``cudaStream_t`` handle. Args: stream: A ``cuda.core.Str | STRING |
| HIGH | bindings/nccl4py/nccl/core/cuda.py | 137 | Resolves a CUDA event specification to an integer ``cudaEvent_t`` handle. Args: event: A ``cuda.core.Event` | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 319 | Returns the LSA multicast device pointer for this window. Returns a device pointer suitable for multicast opera | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 339 | Returns the multicast device pointer for this window and ``multimem``. Unlike :meth:`get_lsa_multimem_device_po | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 361 | Returns the LSA device pointer for a peer within the LSA team. Returns a device pointer to the peer's window bu | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 380 | Returns a device pointer to a peer's window buffer by world rank. If the peer is not reachable via LSA, returns | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 403 | Returns the multicast logical endpoint address for this window and offset. Args: offset: Byte offse | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 426 | Returns the logical endpoint address for a peer within ``cft_team``. Args: peer_cft: Rank within `` | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 451 | Returns the logical endpoint address for a peer by world rank. Args: peer: World rank of the peer. | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 650 | Returns the multimem handle requested for ``team``. The returned handle references storage owned by this resour | STRING |
| HIGH | bindings/nccl4py/nccl/core/typing.py | 321 | Maps a NumPy dtype to its NCCL equivalent. Args: dtype: A NumPy dtype. Mapped first by name (for `` | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/cupy.py | 32 | Converts a CuPy dtype to NcclDataType. CuPy dtypes are NumPy dtype objects, so resolution is delegated to :py:m | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/cupy.py | 67 | Allocates an NCCL-backed CuPy array on the current device. Args: shape: Shape of the array. dtype: | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/cupy.py | 98 | Creates an uninitialized CuPy array backed by NCCL-allocated memory. Returns an array filled with uninitialized dat | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/cupy.py | 150 | Resolves a CuPy array to its NCCL buffer descriptor. Args: array: CuPy array to resolve. Returns: | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/torch.py | 32 | Converts a PyTorch dtype to NcclDataType. torch.bool is mapped to UINT8 for convenience. float8_e4m3fn and floa | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/torch.py | 84 | Parses a device specification into a CUDA device index. Args: device: Device specification (torch.device, i | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/torch.py | 120 | Allocates an NCCL-backed PyTorch tensor. Args: shape: Shape of the tensor. dtype: PyTorch data type | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/torch.py | 166 | Creates an uninitialized PyTorch tensor backed by NCCL-allocated memory. Returns a tensor filled with uninitialized | STRING |
| HIGH | bindings/nccl4py/nccl/core/interop/torch.py | 225 | Resolves a PyTorch tensor to its NCCL buffer descriptor. Args: tensor: PyTorch tensor to resolve. Retu | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | plugins/tuner/example/scripts/optimize_config.py | 104 | def auto_determine_size_ranges(self, data: List[PerformanceData]) -> Dict[Tuple[int, int], List[Tuple[int, int]]]: | CODE |
| LOW | plugins/tuner/example/scripts/optimize_config.py | 262 | def combine_sequential_ranges(self, configs: List[Dict]) -> List[Dict]: | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 46 | def get_log_files_and_output_dir(): | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 127 | def microseconds_to_human_readable(microseconds): | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 206 | def create_per_node_parquet_files(files, output_dir): | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 244 | def generate_combined_scatter_plot(df, comm_type, coll_type, output_file, max_cols=3): | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 356 | def summarize_data_per_comm_coll_type(output_root, comm_type, coll_type, output_dir_name): | CODE |
| LOW⚡ | contrib/nccl_checkpoint/python/tests/test_unittest.py | 271 | def synchronize_multidevice_or_timeout(comms, timeout_s: float = 5.0) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 219 | def _expect_restore_unsafe_prepare_failure(request: pytest.FixtureRequest) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 324 | def _finalize_and_destroy_many(comms) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 350 | def test_empty_checkpointrestore(request: pytest.FixtureRequest, kvs_fixture, rank_info) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 469 | def test_restore_unsafe_window_user_ptr_prepare_fails(request: pytest.FixtureRequest, kvs_fixture, rank_info) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 493 | def test_restore_unsafe_custom_redop_prepare_fails(request: pytest.FixtureRequest, kvs_fixture, rank_info) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 510 | def test_restore_unsafe_dev_comm_prepare_fails(request: pytest.FixtureRequest, kvs_fixture, rank_info) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 583 | def test_even_ranks_two_gpus_same_process(request: pytest.FixtureRequest, kvs_fixture, comm_blocking: bool, rank_info) - | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 669 | def test_split_shared_resources_nocolor(request: pytest.FixtureRequest, kvs_fixture, comm_blocking: bool, rank_info) -> | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 702 | def test_shrink_shared_resources_excluded(request: pytest.FixtureRequest, kvs_fixture, comm_blocking: bool, rank_info) - | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 798 | def test_grow_preserves_parent(request: pytest.FixtureRequest, kvs_fixture, comm_blocking: bool, rank_info) -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_kv_store.py | 176 | def test_kv_set_get_round_trip() -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_kv_store.py | 184 | def test_kv_missing_key_timeout_is_quiet_until_timeout() -> None: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_kv_store.py | 196 | def test_kv_connect_timeout_is_reported_once() -> None: | CODE |
| LOW | contrib/pace/test/test_sg.py | 80 | def _run_strided_validator_checks(): | CODE |
| LOW | contrib/pace/test/utils.py | 218 | def quant_per_token_cast_back(qopt, x_fp8: torch.Tensor, x_scales: torch.Tensor): | CODE |
| LOW | contrib/nccl_ubx/bench/tests/test_smoke.py | 16 | def test_parse_size_case_insensitive(self): | CODE |
| LOW | contrib/nccl_ubx/bench/tests/test_smoke.py | 21 | def test_bench_config_defaults(self): | CODE |
| LOW⚡ | contrib/nccl_ubx/bench/tests/test_smoke.py | 35 | def test_size_sweep_multiplicative(self): | CODE |
| LOW⚡ | contrib/nccl_ubx/bench/tests/test_smoke.py | 41 | def test_backends_to_test_all(self): | CODE |
| LOW⚡ | contrib/nccl_ubx/bench/tests/test_smoke.py | 46 | def test_backends_to_test_single(self): | CODE |
| LOW⚡ | contrib/nccl_ubx/bench/tests/test_smoke.py | 51 | def test_backends_to_test_comma_separated(self): | CODE |
| LOW⚡ | contrib/nccl_ubx/bench/tests/test_smoke.py | 60 | def test_compute_bandwidth_allreduce(self): | CODE |
| LOW⚡ | contrib/nccl_ubx/bench/tests/test_smoke.py | 66 | def test_compute_bandwidth_zero_time(self): | CODE |
| LOW | contrib/nccl_ubx/tests/conftest.py | 8 | def pytest_collection_modifyitems(config, items): | CODE |
| LOW | contrib/nccl_ubx/tests/test_symm_tensor.py | 118 | def test_view_size_mismatch_raises(self, mock_pool, cuda_device): | CODE |
| LOW | contrib/nccl_ubx/tests/test_symm_tensor.py | 127 | def test_view_multiple_minus_one_raises(self, mock_pool, cuda_device): | CODE |
| LOW | contrib/nccl_ubx/tests/test_symm_tensor.py | 183 | def test_wrong_pool_dtype_raises(self, cuda_device): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 192 | def test_query_api_no_params_returns_ok(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 266 | def test_query_supported_hw_global_aggregate(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 277 | def test_query_supported_hw_per_api(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 285 | def test_query_supported_hw_unknown_api_returns_error(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 291 | def test_query_supported_hw_aggregate_is_immutable(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 309 | def test_replay_param_added_optional(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 319 | def test_replay_param_added_required(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 329 | def test_replay_param_removed(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 339 | def test_replay_param_renamed(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 391 | def test_replay_sm_min_changed(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 399 | def test_replay_api_removed_sets_removed_in(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 407 | def test_replay_api_renamed_carries_spec_to_new_name(): | CODE |
| LOW⚡ | contrib/nccl_ubx/tests/test_api_registry.py | 447 | def test_query_api_advises_when_param_was_removed(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 136 | def test_get_version_matches_constant(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 140 | def test_api_log_is_a_list_of_events(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 213 | def test_query_api_unknown_name_returns_not_found(bogus_name): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 221 | def test_query_api_unknown_param_returns_params_changed(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 238 | def test_query_api_multiple_unknown_params_listed_sorted(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 248 | def test_query_api_extra_optional_params_are_ok(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 352 | def test_replay_param_made_optional(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 362 | def test_replay_param_made_required(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 419 | def test_replay_description_changed(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_api_registry.py | 429 | def test_replay_unknown_kind_is_ignored_forward_compat(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_backend_detection.py | 27 | def test_get_cuda_sm_version_no_crash(self): | CODE |
| LOW | contrib/nccl_ubx/tests/test_backend_detection.py | 49 | def test_allocator_symbol_is_bound(self, nccl_backend): | CODE |
| 90 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | plugins/tuner/example/scripts/optimize_config.py | 45 | CODE | |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 18 | CODE | |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 24 | CODE | |
| LOW | contrib/nccl_checkpoint/gen_shim.py | 24 | CODE | |
| LOW | contrib/nccl_checkpoint/gen_shim.py | 25 | CODE | |
| LOW | …nccl_checkpoint/python/nccl_checkpoint/nccl_wrapper.py | 6 | CODE | |
| LOW | …rib/nccl_checkpoint/python/nccl_checkpoint/__init__.py | 4 | CODE | |
| LOW | …rib/nccl_checkpoint/python/nccl_checkpoint/__init__.py | 5 | CODE | |
| LOW | …rib/nccl_checkpoint/python/nccl_checkpoint/__init__.py | 5 | CODE | |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 4 | CODE | |
| LOW | contrib/nccl_checkpoint/python/tests/test_kv_store.py | 4 | CODE | |
| LOW | contrib/pace/setup.py | 4 | CODE | |
| LOW | contrib/pace/setup.py | 6 | CODE | |
| LOW | contrib/pace/test/test_sg.py | 1 | CODE | |
| LOW | contrib/pace/test/test_sg.py | 9 | CODE | |
| LOW | contrib/pace/test/test_ag.py | 1 | CODE | |
| LOW | contrib/pace/test/test_ag.py | 9 | CODE | |
| LOW | contrib/pace/test/test_ag.py | 11 | CODE | |
| LOW | contrib/pace/test/test_ag.py | 12 | CODE | |
| LOW | contrib/pace/test/test_rs.py | 1 | CODE | |
| LOW | contrib/pace/test/test_rs.py | 9 | CODE | |
| LOW | contrib/pace/test/test_rs.py | 12 | CODE | |
| LOW | contrib/pace/pace/__init__.py | 1 | CODE | |
| LOW | contrib/pace/pace/__init__.py | 5 | CODE | |
| LOW | contrib/pace/pace/__init__.py | 5 | CODE | |
| LOW | contrib/pace/pace/__init__.py | 6 | CODE | |
| LOW | contrib/pace/pace/__init__.py | 6 | CODE | |
| LOW | contrib/pace/pace/__init__.py | 6 | CODE | |
| LOW | contrib/pace/pace/rs/__init__.py | 1 | CODE | |
| LOW | contrib/pace/pace/rs/__init__.py | 2 | CODE | |
| LOW | contrib/pace/pace/sg/__init__.py | 1 | CODE | |
| LOW | contrib/pace/pace/sg/__init__.py | 2 | CODE | |
| LOW | contrib/pace/pace/sg/sgcomm.py | 3 | CODE | |
| LOW | contrib/pace/pace/ag/__init__.py | 1 | CODE | |
| LOW | contrib/pace/pace/ag/__init__.py | 2 | CODE | |
| LOW | contrib/pace/scripts/gen_rs_inst.py | 34 | CODE | |
| LOW | contrib/pace/scripts/gen_sg_inst.py | 38 | CODE | |
| LOW | contrib/nccl_ep/ep_test.py | 21 | CODE | |
| LOW | contrib/nccl_ubx/setup.py | 4 | CODE | |
| LOW | contrib/nccl_ubx/bench/tests/test_smoke.py | 3 | CODE | |
| LOW | contrib/nccl_ubx/bench/ubx_bench/runner.py | 3 | CODE | |
| LOW | contrib/nccl_ubx/bench/ubx_bench/configs.py | 3 | CODE | |
| LOW | contrib/nccl_ubx/bench/ubx_bench/__main__.py | 7 | CODE | |
| LOW | contrib/nccl_ubx/bench/ubx_bench/report.py | 3 | CODE | |
| LOW | contrib/nccl_ubx/bench/ubx_bench/report.py | 7 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_reduce.py | 3 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_reduce.py | 10 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_gather.py | 3 | CODE | |
| LOW | …ubx/bench/ubx_bench/collectives/a2av_token_dispatch.py | 21 | CODE | |
| LOW | …trib/nccl_ubx/bench/ubx_bench/collectives/alltoallv.py | 3 | CODE | |
| LOW | …trib/nccl_ubx/bench/ubx_bench/collectives/alltoallv.py | 5 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_to_all.py | 3 | CODE | |
| LOW | …nccl_ubx/bench/ubx_bench/collectives/reduce_scatter.py | 3 | CODE | |
| LOW | …b/nccl_ubx/bench/ubx_bench/collectives/a2av_combine.py | 14 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/a2av_mxfp8.py | 3 | CODE | |
| LOW | contrib/nccl_ubx/tests/conftest.py | 5 | CODE | |
| LOW | contrib/nccl_ubx/tests/test_allocator_pool.py | 8 | CODE | |
| LOW | contrib/nccl_ubx/tests/test_allocator_pool.py | 10 | CODE | |
| LOW | contrib/nccl_ubx/tests/test_allocator_pool.py | 10 | CODE | |
| LOW | …nccl_ubx/tests/distributed/_workers/_run_a2av_mxfp8.py | 19 | CODE | |
| 58 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | plugins/tuner/example/scripts/optimize_config.py | 179 | print(f"Error: File {csv_file} not found") | CODE |
| LOW⚡ | plugins/tuner/example/scripts/optimize_config.py | 181 | except Exception as e: | CODE |
| MEDIUM⚡ | plugins/tuner/example/scripts/optimize_config.py | 182 | print(f"Error reading {csv_file}: {e}") | CODE |
| MEDIUM⚡ | plugins/tuner/example/scripts/optimize_config.py | 367 | print(f"Error: Permission denied writing to {config_file}") | CODE |
| MEDIUM⚡ | plugins/tuner/example/scripts/optimize_config.py | 371 | print(f"Error: Cannot create/write to {config_file}: {e}") | CODE |
| LOW⚡ | plugins/tuner/example/scripts/optimize_config.py | 374 | except Exception as e: | CODE |
| MEDIUM | plugins/tuner/example/scripts/optimize_config.py | 409 | print("Error: Invalid size ranges format. Use 'min1-max1,min2-max2,...'") | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 193 | except Exception as e: | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 388 | except Exception as e: | CODE |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 422 | except Exception as e: | STRING |
| MEDIUM | contrib/nccl_checkpoint/python/tests/test_unittest.py | 30 | def _pick_local_port() -> int: | CODE |
| LOW⚡ | contrib/nccl_checkpoint/python/tests/test_unittest.py | 263 | except Exception: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 174 | except Exception as err: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 297 | except Exception: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 338 | except Exception: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 587 | except Exception as err: | CODE |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 610 | except Exception as err: | CODE |
| MEDIUM⚡ | contrib/pace/setup.py | 36 | print(f"Error calling ncclGetVersion, return code: {result}") | CODE |
| LOW⚡ | contrib/pace/setup.py | 46 | except Exception as e: | CODE |
| MEDIUM⚡ | contrib/pace/setup.py | 47 | print(f"Error loading NCCL library: {e}") | CODE |
| MEDIUM | contrib/pace/test/utils.py | 183 | print(f'Error: {kernel_name} durations len {len(durations)} not divided by {num_kernels_per_period[kerne | CODE |
| LOW | contrib/pace/pace/sg/sgcomm.py | 46 | except Exception: | CODE |
| MEDIUM⚡ | contrib/nccl_ep/ep_test.py | 189 | print("Error: nRanks must be 2, 4 or multiple of 8 for this test") | CODE |
| MEDIUM⚡ | contrib/nccl_ep/ep_test.py | 195 | print("Error: -m is only applicable to HT mode (-a ht)") | CODE |
| MEDIUM⚡ | contrib/nccl_ep/ep_test.py | 197 | print("Error: -m (NCCL_EP_AUTO for max_dispatch_tokens_per_rank) is not yet supported.\n" | CODE |
| MEDIUM | contrib/nccl_ep/ep_test.py | 210 | print(f"Error: num_experts ({num_experts}) must be divisible by nRanks ({n_ranks})") | CODE |
| MEDIUM | contrib/nccl_ep/ep_test.py | 214 | print(f"Error: top_k ({top_k}) must be <= num_local_experts ({num_local_experts})") | CODE |
| LOW | …ubx/bench/ubx_bench/collectives/a2av_token_dispatch.py | 661 | except Exception as e: # noqa: BLE001 | CODE |
| LOW | …b/nccl_ubx/bench/ubx_bench/collectives/a2av_combine.py | 529 | except Exception: | CODE |
| LOW | …/nccl_ubx/tests/distributed/_workers/_run_ubx_fused.py | 100 | except Exception as e: | CODE |
| LOW | …/nccl_ubx/tests/distributed/_workers/_run_ubx_fused.py | 164 | except Exception as e: | CODE |
| LOW | …/nccl_ubx/tests/distributed/_workers/_run_ubx_fused.py | 231 | except Exception as e: | CODE |
| LOW | …/nccl_ubx/tests/distributed/_workers/_run_ubx_graph.py | 97 | except Exception as e: | CODE |
| LOW | …/nccl_ubx/tests/distributed/_workers/_run_ubx_graph.py | 152 | except Exception as e: | CODE |
| LOW | …ubx/tests/distributed/_workers/_run_ubx_convenience.py | 122 | except Exception as e: | CODE |
| LOW | …rib/nccl_ubx/tests/distributed/_workers/_run_ubx_op.py | 132 | except Exception as e: | CODE |
| LOW | …sts/distributed/_workers/_run_alltoall_lamport_hang.py | 183 | except Exception as e: | CODE |
| LOW | …sts/distributed/_workers/_run_alltoall_lamport_hang.py | 198 | except Exception as e: | CODE |
| LOW | …nccl_ubx/tests/distributed/_workers/_run_large_pool.py | 174 | except Exception as e: | CODE |
| LOW | …nccl_ubx/tests/distributed/_workers/_run_large_pool.py | 186 | except Exception as e: | CODE |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 42 | except Exception as _e: # pragma: no cover - depends on environment | CODE |
| LOW⚡ | contrib/nccl_ubx/ubx/_nccl_backend.py | 94 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 111 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 398 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 404 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 422 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 431 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 186 | except Exception as _e: | CODE |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 339 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 347 | except Exception: | CODE |
| MEDIUM | contrib/nccl_ubx/ubx/allocator.py | 344 | def __del__(self): | CODE |
| LOW | bindings/nccl4py/nccl/core/communicator.py | 2749 | except Exception: | CODE |
| LOW | src/misc/generate_git_version.py | 34 | except Exception: | CODE |
| MEDIUM | src/misc/generate_git_version.py | 30 | def run_git(cmd, fallback="unknown"): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | contrib/nccl_checkpoint/python/tests/test_unittest.py | 263 | except Exception: | CODE |
| HIGH | contrib/nccl_checkpoint/python/tests/test_unittest.py | 297 | except Exception: | CODE |
| HIGH | contrib/nccl_ubx/ubx/_nccl_backend.py | 431 | except Exception: | CODE |
| HIGH | contrib/nccl_ubx/ubx/_nccl_backend.py | 398 | except Exception: | CODE |
| HIGH | contrib/nccl_ubx/ubx/_nccl_backend.py | 404 | except Exception: | CODE |
| HIGH | contrib/nccl_ubx/ubx/_nccl_backend.py | 422 | except Exception: | CODE |
| HIGH | contrib/nccl_ubx/ubx/allocator.py | 347 | except Exception: | CODE |
| HIGH | contrib/nccl_ubx/ubx/allocator.py | 339 | except Exception: | CODE |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 2749 | except Exception: | CODE |
| HIGH | bindings/nccl4py/nccl/core/utils.py | 111 | except (OSError, ValueError): | CODE |
| HIGH | bindings/nccl4py/nccl/core/utils.py | 123 | except (ImportError, RuntimeError, _nccl_bindings.NCCLError): | CODE |
| HIGH | bindings/nccl4py/nccl/core/buffer.py | 118 | except (ImportError, ModuleNotFoundError, NcclInvalid): | CODE |
| HIGH | bindings/nccl4py/nccl/core/buffer.py | 126 | except (ImportError, ModuleNotFoundError, NcclInvalid): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | plugins/tuner/example/scripts/optimize_config.py | 104 | CODE | |
| LOW | plugins/tuner/example/scripts/optimize_config.py | 167 | CODE | |
| LOW | plugins/tuner/example/scripts/optimize_config.py | 206 | CODE | |
| LOW | plugins/tuner/example/scripts/optimize_config.py | 262 | CODE | |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 146 | CODE | |
| LOW | contrib/nccl_checkpoint/gen_shim.py | 247 | CODE | |
| LOW | contrib/nccl_checkpoint/gen_shim.py | 263 | CODE | |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 60 | CODE | |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 247 | CODE | |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 271 | CODE | |
| LOW | contrib/nccl_checkpoint/python/tests/test_unittest.py | 583 | CODE | |
| LOW | contrib/nccl_checkpoint/python/tests/test_kv_store.py | 82 | CODE | |
| LOW | contrib/pace/setup.py | 51 | CODE | |
| LOW | contrib/pace/test/test_sg.py | 117 | CODE | |
| LOW | contrib/pace/test/test_sg.py | 148 | CODE | |
| LOW | contrib/pace/test/utils.py | 111 | CODE | |
| LOW | contrib/pace/scripts/gen_rs_inst.py | 141 | CODE | |
| LOW | contrib/pace/scripts/gen_sg_inst.py | 156 | CODE | |
| LOW | contrib/nccl_ep/ep_test.py | 162 | CODE | |
| LOW | contrib/nccl_ubx/bench/ubx_bench/runner.py | 52 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_reduce.py | 75 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_gather.py | 14 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_gather.py | 78 | CODE | |
| LOW | …ubx/bench/ubx_bench/collectives/a2av_token_dispatch.py | 130 | CODE | |
| LOW | …ubx/bench/ubx_bench/collectives/a2av_token_dispatch.py | 240 | CODE | |
| LOW | …ubx/bench/ubx_bench/collectives/a2av_token_dispatch.py | 443 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_to_all.py | 14 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/all_to_all.py | 82 | CODE | |
| LOW | …nccl_ubx/bench/ubx_bench/collectives/reduce_scatter.py | 13 | CODE | |
| LOW | …b/nccl_ubx/bench/ubx_bench/collectives/a2av_combine.py | 48 | CODE | |
| LOW | …b/nccl_ubx/bench/ubx_bench/collectives/a2av_combine.py | 263 | CODE | |
| LOW | …rib/nccl_ubx/bench/ubx_bench/collectives/a2av_mxfp8.py | 32 | CODE | |
| LOW | contrib/nccl_ubx/tests/test_routing.py | 94 | CODE | |
| LOW | …ib/nccl_ubx/tests/distributed/_workers/_run_combine.py | 97 | CODE | |
| LOW | …rib/nccl_ubx/tests/distributed/_workers/_run_ubx_op.py | 65 | CODE | |
| LOW | …cl_ubx/tests/distributed/_workers/_run_alltoall_e2e.py | 48 | CODE | |
| LOW | …sts/distributed/_workers/_run_alltoall_lamport_hang.py | 134 | CODE | |
| LOW | contrib/nccl_ubx/ubx/_api_registry.py | 367 | CODE | |
| LOW | contrib/nccl_ubx/ubx/tensor.py | 112 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 350 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 376 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 1016 | CODE | |
| LOW | bindings/nccl4py/nccl/core/communicator.py | 802 | CODE | |
| LOW | bindings/nccl4py/nccl/core/communicator.py | 2559 | CODE | |
| LOW | bindings/nccl4py/nccl/core/resources.py | 678 | CODE | |
| LOW | bindings/nccl4py/nccl/core/interop/torch.py | 83 | CODE | |
| LOW | src/device/generate.py | 186 | CODE | |
| LOW | src/device/symmetric/generate.py | 99 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …rib/nccl_checkpoint/python/nccl_checkpoint/__init__.py | 34 | __all__ = [ | CODE |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 35 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/params.py | 18 | __all__ = ["params", "dump_params"] | CODE |
| LOW | bindings/nccl4py/nccl/core/memory.py | 25 | __all__ = ["NcclMemoryResource", "get_memory_resource"] | CODE |
| LOW | bindings/nccl4py/nccl/core/constants.py | 15 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/__init__.py | 43 | __all__ = [ # noqa: RUF022 | CODE |
| LOW | bindings/nccl4py/nccl/core/team.py | 16 | __all__ = ["NCCLTeam"] | CODE |
| LOW | bindings/nccl4py/nccl/core/_binding_helpers.py | 28 | __all__ = ["PassBy", "Field", "LowppSpec", "LowppView"] | CODE |
| LOW | bindings/nccl4py/nccl/core/communicator.py | 64 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/utils.py | 26 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/buffer.py | 30 | __all__ = ["mem_alloc", "mem_free"] | CODE |
| LOW | bindings/nccl4py/nccl/core/group.py | 24 | __all__ = ["GroupSimInfo", "group_start", "group_end", "group"] | CODE |
| LOW | bindings/nccl4py/nccl/core/resources.py | 24 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/typing.py | 23 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/interop/cupy.py | 20 | __all__ = ["empty", "resolve_array"] | CODE |
| LOW | bindings/nccl4py/nccl/core/interop/torch.py | 20 | __all__ = ["empty", "resolve_tensor"] | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/reduce_copy.py | 127 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/coop.py | 123 | __all__ = [ | CODE |
| LOW⚡ | bindings/nccl4py/nccl/core/device/cute/handles.py | 170 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/window.py | 243 | __all__ = ["Window"] | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/comm.py | 397 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/barrier.py | 429 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/__init__.py | 40 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/types.py | 107 | __all__ = [ | CODE |
| LOW⚡ | bindings/nccl4py/nccl/core/device/cute/runtime.py | 126 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/gin.py | 414 | __all__ = [ | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | contrib/nccl_checkpoint/python/tests/test_unittest.py | 276 | event.record(cp.cuda.Stream.null) | CODE |
| HIGH | contrib/nccl_checkpoint/python/tests/test_unittest.py | 249 | event.record(cp.cuda.Stream.null) | CODE |
| HIGH | …ntrib/nccl_ubx/tests/distributed/test_ubx_fused_ops.py | 3 | These test the fused paths where gamma/residual_in are non-null, | STRING |
| HIGH | …/nccl_ubx/tests/distributed/_workers/_run_ubx_fused.py | 3 | Tests the fused paths where residual_in and/or gamma are non-null, | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1422 | """Integer value of the underlying :c:type:`ncclComm_t` (0 if destroyed or null).""" | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1427 | """Whether the communicator is valid (not destroyed or null).""" | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 295 | """Whether the window is still registered (not closed, handle non-null).""" | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …uffer_registration/01_allreduce/python/allreduce_ub.py | 0 | determine the local rank of this process on its physical node. uses mpi_comm_split_type with mpi_comm_type_shared to spl | STRING |
| HIGH | …e_per_process_mpi/python/one_device_per_process_mpi.py | 0 | determine the local rank of this process on its physical node. uses mpi_comm_split_type with mpi_comm_type_shared to spl | STRING |
| HIGH | …5_symmetric_memory/02_allgather/python/allgather_ce.py | 0 | determine the local rank of this process on its physical node. uses mpi_comm_split_type with mpi_comm_type_shared to spl | STRING |
| HIGH | …5_symmetric_memory/01_allreduce/python/allreduce_sm.py | 0 | determine the local rank of this process on its physical node. uses mpi_comm_split_type with mpi_comm_type_shared to spl | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | plugins/tuner/example/scripts/optimize_config.py | 298 | # Check if ranges are adjacent or overlapping | COMMENT |
| LOW | plugins/tuner/example/scripts/optimize_config.py | 337 | # Check if file exists and has content | COMMENT |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 150 | # Check if parquet file exists and is newer than source file | COMMENT |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 160 | # Check if file is empty or too small | COMMENT |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 360 | # Check if there are any parquet files | COMMENT |
| LOW | …er/inspector/exporter/example/perf_summary_exporter.py | 393 | # Check if any valid files remain | COMMENT |
| LOW | docs/userguide/build_docs.sh | 19 | # Check if doc directory exists | COMMENT |
| LOW | docs/userguide/build_docs.sh | 25 | # Check if requirements.txt exists | COMMENT |
| LOW | docs/userguide/build_docs.sh | 92 | # Check if build was successful | COMMENT |
| LOW | contrib/niin/test/compat/run_nvshmem_tests.sh | 159 | # Check if it's a known missing symbol | COMMENT |
| LOW | contrib/nccl_ubx/bench/ubx_bench/runner.py | 296 | # Output results (rank 0 only) | COMMENT |
| LOW | bindings/nccl4py/examples/01_basic/01_allreduce.py | 45 | # Assign GPU to each process | COMMENT |
| LOW | bindings/nccl4py/examples/01_basic/02_send_recv.py | 51 | # Assign GPU to each process | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …er/inspector/exporter/example/perf_summary_exporter.py | 515 | # Step 1: Summarize data per communication and collective type | COMMENT |
| LOW⚡ | …er/inspector/exporter/example/perf_summary_exporter.py | 518 | # Step 2: Generate visualizations if data exists | COMMENT |
| LOW | contrib/nccl_ep/README.md | 238 | ### Step 1: Build NCCL with Device API Support | COMMENT |
| LOW | contrib/nccl_ep/README.md | 249 | ### Step 2: Build NCCL EP Library and Test | COMMENT |
| LOW | …ib/nccl_ubx/tests/distributed/_workers/_run_combine.py | 160 | # Step 1: dispatch (bf16 wire) so expert_outputs are populated symmetrically. | COMMENT |
| LOW | …ib/nccl_ubx/tests/distributed/_workers/_run_combine.py | 171 | # Step 2: combine. | COMMENT |
| LOW⚡ | src/include/nccl_device/impl/reduce_copy__impl.h | 302 | // Step 1: Process scalar prefix to achieve alignment (if needed) | COMMENT |
| LOW⚡ | src/include/nccl_device/impl/reduce_copy__impl.h | 311 | // Step 2: Process aligned bulk - match all_reduce.cuh strategy: check relative alignment and try pack sizes | COMMENT |
| LOW | src/include/nccl_device/impl/reduce_copy__impl.h | 393 | // Step 3: Scalar remainder | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …er/inspector/exporter/example/perf_summary_exporter.py | 515 | # Step 1: Summarize data per communication and collective type | COMMENT |
| LOW⚡ | …er/inspector/exporter/example/perf_summary_exporter.py | 518 | # Step 2: Generate visualizations if data exists | COMMENT |
| LOW | …ib/nccl_ubx/tests/distributed/_workers/_run_combine.py | 160 | # Step 1: dispatch (bf16 wire) so expert_outputs are populated symmetrically. | COMMENT |
| LOW | …ib/nccl_ubx/tests/distributed/_workers/_run_combine.py | 171 | # Step 2: combine. | COMMENT |
| LOW⚡ | src/include/nccl_device/impl/reduce_copy__impl.h | 302 | // Step 1: Process scalar prefix to achieve alignment (if needed) | COMMENT |
| LOW⚡ | src/include/nccl_device/impl/reduce_copy__impl.h | 311 | // Step 2: Process aligned bulk - match all_reduce.cuh strategy: check relative alignment and try pack sizes | COMMENT |
| LOW | src/include/nccl_device/impl/reduce_copy__impl.h | 393 | // Step 3: Scalar remainder | COMMENT |
| LOW | src/include/nvtx3/nvtx3.hpp | 26 | /* This section handles the decision of whether to provide unversioned symbols. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | plugins/tuner/example/test/test_plugin.c | 569 | fprintf(f, "# This file contains many configurations to test memory allocation\n"); | CODE |
| MEDIUM | contrib/pace/setup.py | 25 | # Define the function prototype | COMMENT |
| MEDIUM | contrib/nccl_ubx/tests/test_symm_tensor.py | 157 | # Create a view — new SymmTensor at same offset | COMMENT |
| MEDIUM | bindings/nccl4py/nccl/core/communicator.py | 2660 | # Create the custom reduction operator | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | contrib/nccl_m2n/tests/run_basic_api_tests.sh | 8 | # Usage: | COMMENT |
| LOW | contrib/niin/test/run_all.sh | 6 | # Usage: | COMMENT |
| LOW | contrib/niin/test/compat/run_nvshmem_tests.sh | 5 | # Usage: | COMMENT |
| LOW | contrib/nccl_ep/tests/run_tests.sh | 9 | # Usage: | COMMENT |
| LOW | maint/run-clang-format.sh | 12 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | contrib/pace/test/utils.py | 302 | CODE | |
| LOW | contrib/nccl_ubx/tests/distributed/conftest.py | 93 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 479 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 526 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 573 | CODE | |
| LOW | bindings/nccl4py/nccl/core/device/cute/gin.py | 33 | CODE | |
| LOW | bindings/nccl4py/nccl/core/device/cute/gin.py | 105 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | contrib/niin/test/run_all.sh | 3 | # NIIN comprehensive test suite — functional + performance. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/include/collectives.h | 888 | // Don't forget to receive at least once even if we don't send afterwards | COMMENT |