Optimized primitives for collective multi-GPU communication
This report presents the forensic synthetic code analysis of NVIDIA/nccl, a C++ project with 4,924 GitHub stars. SynthScan v2.0 examined 167,947 lines of code across 666 source files, recording 1027 pattern matches distributed across 18 syntactic categories. The overall adjusted score of 9.4 places this repository in the Low AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 1027 distinct pattern matches across 18 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| 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 |
| 128 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | CMakeLists.txt | 141 | endif() | 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/inspector.h | 281 | struct inspectorCommInfoList liveComms; | 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 | docs/examples/common/include/utils.h | 1 | /************************************************************************* | COMMENT |
| LOW | contrib/nccl_checkpoint/shim_core.h | 1 | #pragma once | COMMENT |
| LOW | contrib/nccl_m2n/tests/CMakeLists.txt | 1 | # SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved. | COMMENT |
| LOW | contrib/nccl_m2n/tests/basic_api_test_core.h | 21 | * | COMMENT |
| LOW | contrib/nccl_m2n/tests/run_basic_api_tests.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | contrib/nccl_m2n/third_party/nlohmann/json.hpp | 21 | #include <algorithm> // all_of, find, for_each | COMMENT |
| LOW | contrib/nccl_m2n/third_party/nlohmann/json.hpp | 41 | // SPDX-License-Identifier: MIT | COMMENT |
| LOW | contrib/nccl_m2n/third_party/nlohmann/json.hpp | 61 | #if defined(NLOHMANN_JSON_VERSION_MAJOR) && defined(NLOHMANN_JSON_VERSION_MINOR) && defined(NLOHMANN_JSON_VERSION_PA | COMMENT |
| 382 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 324 | Initializes a new NCCL communicator. Creates a communicator that connects multiple ranks. This is a col | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 352 | Initializes multiple NCCL communicators for single-process multi-GPU operations. Creates an array of NCCL commu | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 455 | 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 | 507 | 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 | 586 | 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 | 1584 | Registers a buffer with this communicator for zero-copy communication. Registered buffers can enable performanc | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1622 | 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 | 1680 | Creates a PreMulSum custom reduction operator. Performs ``output = scalar * sum(inputs)`` and is useful for | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1790 | Creates a device communicator for device-side NCCL operations. Device communicators enable direct GPU kernel ac | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1889 | Queries communicator memory statistics. Args: stat: The memory statistic to query. Returns | STRING |
| HIGH | bindings/nccl4py/nccl/core/resources.py | 241 | 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 | 261 | 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 | 280 | 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/typing.py | 236 | 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 |
| HIGH | bindings/nccl4py/nccl/ep/interop/torch.py | 31 | Create a fresh NCCL communicator that mirrors *group*'s membership. Args: group: A torch ``ProcessGroup``; | STRING |
| 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/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 | |
| LOW | …sts/distributed/_workers/_run_alltoall_lamport_hang.py | 21 | CODE | |
| LOW | contrib/nccl_ubx/ubx/_api_registry.py | 33 | CODE | |
| LOW | contrib/nccl_ubx/ubx/_api_registry.py | 35 | CODE | |
| LOW | contrib/nccl_ubx/ubx/fused.py | 8 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 20 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 21 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 22 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 22 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 22 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 23 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 24 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 25 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 25 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 25 | CODE | |
| LOW | contrib/nccl_ubx/ubx/__init__.py | 25 | CODE | |
| LOW | contrib/nccl_ubx/ubx/tensor.py | 3 | CODE | |
| LOW | contrib/nccl_ubx/ubx/tensor.py | 9 | CODE | |
| LOW | contrib/nccl_ubx/ubx/ops.py | 7 | CODE | |
| LOW | contrib/nccl_ubx/ubx/ops.py | 15 | CODE | |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 13 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 11 | CODE | |
| LOW | bindings/nccl4py/nccl/__init__.py | 14 | CODE | |
| LOW | bindings/nccl4py/nccl/__init__.py | 15 | CODE | |
| LOW | bindings/nccl4py/nccl/__init__.py | 15 | CODE | |
| LOW | bindings/nccl4py/nccl/__init__.py | 15 | CODE | |
| LOW | bindings/nccl4py/nccl/__init__.py | 15 | CODE | |
| 52 more matches not shown… | ||||
| 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/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_routing.py | 131 | def test_max_tokens_per_rank_is_symmetric(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_routing.py | 143 | def test_unrouted_entries_are_minus_one(): | CODE |
| LOW | contrib/nccl_ubx/tests/test_routing.py | 151 | def test_all_tokens_same_expert(): | CODE |
| 28 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/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 | 32 | except Exception as _e: # pragma: no cover - depends on environment | CODE |
| LOW⚡ | contrib/nccl_ubx/ubx/_nccl_backend.py | 59 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/_nccl_backend.py | 76 | except Exception: | CODE |
| LOW⚡ | contrib/nccl_ubx/ubx/_nccl_backend.py | 327 | except Exception: | CODE |
| LOW⚡ | contrib/nccl_ubx/ubx/_nccl_backend.py | 333 | except Exception: | CODE |
| LOW⚡ | contrib/nccl_ubx/ubx/_nccl_backend.py | 342 | except Exception: | CODE |
| LOW⚡ | contrib/nccl_ubx/ubx/_nccl_backend.py | 350 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 186 | except Exception as _e: | CODE |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 332 | except Exception: | CODE |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 344 | except Exception: | CODE |
| MEDIUM | contrib/nccl_ubx/ubx/allocator.py | 341 | def __del__(self): | CODE |
| LOW | bindings/nccl4py/nccl/core/communicator.py | 1839 | except Exception: | CODE |
| LOW | bindings/nccl4py/nccl/ep/tensor.py | 47 | except Exception as e: | CODE |
| LOW | bindings/nccl4py/nccl/ep/interop/torch.py | 65 | 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 |
|---|---|---|---|---|
| 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/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 | 347 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 373 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 1013 | CODE | |
| LOW | bindings/nccl4py/nccl/core/communicator.py | 1675 | CODE | |
| LOW | bindings/nccl4py/nccl/core/interop/torch.py | 83 | CODE | |
| LOW | src/device/generate.py | 165 | CODE | |
| LOW | src/device/symmetric/generate.py | 99 | 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 | 777 | (0 if destroyed or null). | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 783 | """Whether the communicator is valid (not destroyed or null).""" | STRING |
| HIGH | bindings/nccl4py/nccl/core/communicator.py | 1666 | # But if status is Success and handle is still null, then we can | COMMENT |
| 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/__init__.py | 17 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/_binding_helpers.py | 20 | __all__ = ["binding_dataclass"] | CODE |
| LOW | bindings/nccl4py/nccl/_show_versions.py | 28 | __all__ = ["LibraryInfo", "VersionInfo", "get_version", "show_versions"] | 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 | 35 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/communicator.py | 59 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/utils.py | 36 | __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 | 25 | __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/coop.py | 140 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/comm.py | 225 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/barrier.py | 363 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/__init__.py | 43 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/types.py | 52 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/core/device/cute/gin.py | 147 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/ep/enums.py | 16 | __all__ = ["Algorithm", "Layout", "PassDir"] | CODE |
| LOW | bindings/nccl4py/nccl/ep/handle.py | 30 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/ep/__init__.py | 54 | __all__ = [ | CODE |
| LOW | bindings/nccl4py/nccl/ep/tensor.py | 20 | __all__ = ["Tensor"] | CODE |
| LOW | bindings/nccl4py/nccl/ep/group.py | 30 | __all__ = ["Group", "GroupConfig"] | CODE |
| LOW | bindings/nccl4py/nccl/ep/allocator.py | 74 | __all__ = ["AllocConfig", "AllocFn", "FreeFn"] | CODE |
| LOW | bindings/nccl4py/nccl/ep/interop/torch.py | 27 | __all__ = ["get_nccl_comm_from_group"] | CODE |
| 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/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 | 236 | ### Step 1: Build NCCL with Device API Support | COMMENT |
| LOW | contrib/nccl_ep/README.md | 247 | ### 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 | 418 | // Step 1: Process scalar prefix to achieve alignment (if needed) | COMMENT |
| LOW⚡ | src/include/nccl_device/impl/reduce_copy__impl.h | 427 | // 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 | 509 | // 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 | 418 | // Step 1: Process scalar prefix to achieve alignment (if needed) | COMMENT |
| LOW⚡ | src/include/nccl_device/impl/reduce_copy__impl.h | 427 | // 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 | 509 | // 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/nccl_ubx/tests/test_symm_tensor.py | 157 | # Create a view — new SymmTensor at same offset | COMMENT |
| MEDIUM | bindings/nccl4py/nccl/core/communicator.py | 1776 | # Create the custom reduction operator | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | contrib/nccl_ubx/tests/distributed/conftest.py | 93 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 476 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 523 | CODE | |
| LOW | contrib/nccl_ubx/ubx/allocator.py | 570 | CODE | |
| LOW | bindings/nccl4py/nccl/core/device/cute/gin.py | 48 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | contrib/nccl_m2n/tests/run_basic_api_tests.sh | 8 | # Usage: | COMMENT |
| LOW | contrib/nccl_ep/tests/run_tests.sh | 9 | # Usage: | COMMENT |
| LOW | maint/run-clang-format.sh | 7 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | bindings/nccl4py/nccl/core/communicator.py | 1667 | # simply return None. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/include/collectives.h | 867 | // Don't forget to receive at least once even if we don't send afterwards | COMMENT |