Mooncake is the serving platform for Kimi, a leading LLM service provided by Moonshot AI.
This report summarizes scanner evidence for kvcache-ai/Mooncake, a C++ project with 6,759 GitHub stars. SynthScan examined 748,956 lines of code across 2197 source files, recording 4419 pattern matches distributed across 20 syntactic categories. The legacy adjusted pattern signal is 6.5 (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? 3474 finding(s).
Are imports declared and package/API names verified? 527 finding(s).
Are wrappers, guards, and repeated structures necessary? 1923 finding(s).
Which changes need focused human review? 4419 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 4419 distinct pattern matches across 20 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 |
|---|---|---|---|---|
| LOW | dependencies.sh | 1 | #!/bin/bash | COMMENT |
| LOW | mooncake-common/include/rpc_client_io_context.h | 1 | #pragma once | COMMENT |
| LOW | mooncake-common/include/rpc_client_io_context.h | 121 | namespace detail { | COMMENT |
| LOW | mooncake-common/include/environment_value_parser.h | 1 | #pragma once | COMMENT |
| LOW | mooncake-common/include/glog_compat.h | 1 | // Copyright 2026 KVCache.AI | COMMENT |
| LOW | mooncake-common/include/glog_compat.h | 21 | // detected glog version is >= 0.6.0, where google::IsGoogleLoggingInitialized() | COMMENT |
| LOW | mooncake-common/include/glog_compat.h | 41 | namespace glog_internal_namespace_ { | COMMENT |
| LOW | mooncake-common/include/ib_link_speed.h | 1 | // Copyright 2025 KVCache.AI | COMMENT |
| LOW | mooncake-common/include/default_config.h | 1 | #pragma once | COMMENT |
| LOW | mooncake-common/tests/environ_test.cpp | 1 | // Copyright 2024 KVCache.AI | COMMENT |
| LOW | mooncake-common/tests/ib_link_speed_test.cpp | 1 | // Copyright 2025 KVCache.AI | COMMENT |
| LOW | mooncake-common/src/default_config.cpp | 1 | #include "default_config.h" | COMMENT |
| LOW | mooncake-common/src/environ.h | 1 | #pragma once | COMMENT |
| LOW | mooncake-common/src/asio_impl.cpp | 1 | // ASIO separate compilation implementation | COMMENT |
| LOW | python/tests/ep/test_ep_grid.py | 81 | topk_weights = torch.softmax( | COMMENT |
| LOW | mooncake-wheel/pyproject.toml | 1 | # mooncake-wheel/pyproject.toml | COMMENT |
| LOW | mooncake-wheel/mooncake/mooncake_store_service.py | 301 | {"error": "Missing path or size for decode mode"} | COMMENT |
| LOW | mooncake-wheel/tests/test_promotion_on_hit.py | 261 | f"and the client's 'ProcessPromotionTasks pulled' log)" | COMMENT |
| LOW | mooncake-pg/include/common_types.h | 1 | // Common types shared by host and device code. | COMMENT |
| LOW | mooncake-pg/include/mooncake_pg.h | 1 | #ifndef MOONCAKE_PG_H_ | COMMENT |
| LOW | mooncake-pg/include/mooncake_communicator.h | 1 | #ifndef MOONCAKE_PG_COMMUNICATOR_H | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 1 | #ifndef MOONCAKE_P2P_PROXY_H | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 21 | COMMENT | |
| LOW | mooncake-pg/include/p2p_proxy.h | 41 | // +---------------------------------------------------------+ | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 61 | // Protocol overview: | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 81 | // - All pool allocations are non-blocking. If a pool is exhausted the step | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 101 | // | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 121 | // Rank 0's SendPool RDMA Write Rank 1's RecvPool | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 141 | // +-----------------------+ | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 161 | // | chunk 1 : free | | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 181 | return (static_cast<ControlToken>(epoch) << 32) | | COMMENT |
| LOW | mooncake-pg/include/p2p_proxy.h | 521 | // Request a lane reset and report the link failure to the Agent. | COMMENT |
| LOW | mooncake-pg/include/gpu_runtime.h | 1 | #ifndef MOONCAKE_PG_GPU_RUNTIME_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/agent_host.h | 1 | #ifndef MOONCAKE_PG_AGENT_HOST_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/agent_host.h | 21 | COMMENT | |
| LOW | mooncake-pg/include/control_plane/agent_host.h | 41 | // | | COMMENT |
| LOW | mooncake-pg/include/control_plane/control_types.h | 1 | #ifndef MOONCAKE_PG_CONTROL_PLANE_CONTROL_TYPES_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/control_types.h | 21 | // | COMMENT |
| LOW | mooncake-pg/include/control_plane/control_types.h | 141 | COMMENT | |
| LOW | mooncake-pg/include/control_plane/rpc_runtime.h | 1 | #ifndef MOONCAKE_PG_RPC_RUNTIME_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/link_manager.h | 1 | #ifndef MOONCAKE_PG_LINK_MANAGER_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/serialized_executor.h | 1 | #ifndef MOONCAKE_PG_SERIALIZED_EXECUTOR_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/coordinator_host.h | 1 | #ifndef MOONCAKE_PG_COORDINATOR_HOST_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/coordinator_host.h | 21 | COMMENT | |
| LOW | mooncake-pg/include/control_plane/coordinator_host.h | 41 | // +------------------------------------+ | COMMENT |
| LOW | mooncake-pg/include/control_plane/coordinator.h | 1 | #ifndef MOONCAKE_PG_COORDINATOR_H | COMMENT |
| LOW | mooncake-pg/include/control_plane/rpc.h | 1 | #ifndef MOONCAKE_PG_CONTROL_PLANE_RPC_H | COMMENT |
| LOW | …/device_comm/device_collective/device_control_update.h | 1 | #ifndef MOONCAKE_PG_DEVICE_COMM_DEVICE_COLLECTIVE_DEVICE_CONTROL_UPDATE_H | COMMENT |
| LOW | …/device_comm/device_collective/device_control_update.h | 21 | // | COMMENT |
| LOW | …lude/device_comm/device_collective/device_collective.h | 1 | #ifndef MOONCAKE_PG_DEVICE_COMM_DEVICE_COLLECTIVE_DEVICE_COLLECTIVE_H | COMMENT |
| LOW | …ice_comm/device_collective/device_collective_feature.h | 1 | #ifndef MOONCAKE_PG_DEVICE_COMM_DEVICE_COLLECTIVE_FEATURE_H | COMMENT |
| LOW | …ce_comm/device_collective/device_collective_recovery.h | 1 | #ifndef MOONCAKE_PG_DEVICE_COMM_DEVICE_COLLECTIVE_DEVICE_COLLECTIVE_RECOVERY_H | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 1 | #ifndef MOONCAKE_PG_DEVICE_COMM_DEVICE_COLLECTIVE_STRONG_STREAM_H | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 21 | // | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 41 | // eager order stream user stream A user stream B | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 61 | // to the same capture reuse it, even if their kernels use different user | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 81 | // | | | | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 101 | // Eager A submitted before Graph G: | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 121 | // external event nodes because its wait and record must execute on every | COMMENT |
| LOW | …/include/device_comm/device_collective/strong_stream.h | 141 | // submitted before it. Later records do not retarget an already submitted | COMMENT |
| 1625 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | mooncake-rl/examples/rl_samples.py | 119 | def init_weight_update_connections(self, rollout_manager): | CODE |
| LOW | python/mooncake/mooncake_ssd_unregister.py | 287 | def start_ssd_unregister_service(self): | CODE |
| LOW | python/mooncake/mooncake_ep_buffer.py | 29 | def _native_current_stream_ptr() -> int: | CODE |
| LOW | python/mooncake/mooncake_ep_buffer.py | 33 | def _wait_native_event_on_current_stream(event: "ep.EventHandle") -> None: | CODE |
| LOW⚡ | python/mooncake/spdk_tgt_create.py | 210 | def _discover_nvme_pci_devices(self, ssh: paramiko.SSHClient) -> List[str]: | CODE |
| LOW | python/mooncake/spdk_tgt_create.py | 283 | def _filter_spdk_ready_pci_devices( | CODE |
| LOW | python/mooncake/spdk_tgt_create.py | 373 | def _format_transport_options(self) -> str: | CODE |
| LOW | python/mooncake/transfer_engine_topology_dump.py | 86 | def sanitize_tent_conf_for_discover(): | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 68 | def _resolve_transport_consensus( | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 134 | def _resolve_nccl_membership_masks(rank_masks: Sequence[Sequence[int]]) -> None: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 162 | def _bootstrap_collective_device(group: dist.ProcessGroup) -> str: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 168 | def _select_transport_for_group( | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 487 | def _require_full_nccl_membership(self) -> None: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 515 | def _refresh_topology_from_runtime(self) -> None: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 525 | def _validate_handle_generation(self, handle: EPHandle) -> None: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 792 | def _atomic_scratch_num_bytes() -> int: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 846 | def get_engram_storage_size_hint( | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 863 | def get_agrs_buffer_size_hint( | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 869 | def _calculate_physical_domain_size(group: dist.ProcessGroup) -> Tuple[int, int]: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 886 | def _calculate_logical_domain_size( | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 907 | def _hybrid_num_max_tokens_per_channel( | CODE |
| LOW | python/tests/packaging/test_project.py | 32 | def test_scikit_build_core_is_the_only_build_backend() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 51 | def test_dependency_boundaries_are_declared() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 66 | def test_legacy_wheel_administration_extra_matches_root_project() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 79 | def test_tracked_source_roots_contain_no_generated_native_artifacts() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 87 | def test_http_metadata_service_has_one_authoritative_source( | CODE |
| LOW | python/tests/packaging/test_project.py | 149 | def test_async_store_has_one_authoritative_source() -> None: | STRING |
| LOW | python/tests/packaging/test_project.py | 173 | def test_ep_modules_have_one_authoritative_source() -> None: | STRING |
| LOW | python/tests/packaging/test_project.py | 205 | def test_cli_has_one_authoritative_source_and_test_location() -> None: | STRING |
| LOW | python/tests/packaging/test_project.py | 222 | def test_scikit_build_consumes_unified_python_sources() -> None: | STRING |
| LOW | python/tests/packaging/test_project.py | 264 | def test_python_package_init_keeps_namespace_extension() -> None: | STRING |
| LOW | python/tests/packaging/test_project.py | 278 | def test_cli_entry_points_remain_stable_across_build_interfaces() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 288 | def test_cli_build_inputs_use_the_canonical_sources() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 309 | def test_lightweight_modules_have_one_authoritative_source() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 331 | def test_ssd_administration_modules_have_one_authoritative_source() -> None: | CODE |
| LOW | python/tests/packaging/test_project.py | 360 | def test_pg_extension_build_stages_outside_the_source_tree( | CODE |
| LOW | python/tests/packaging/test_installed_wheel.py | 33 | def test_wheel_imports_outside_the_repository( | CODE |
| LOW | python/tests/ssd/test_spdk_tgt_create.py | 7 | def test_parse_arguments_accepts_ssh_port(): | CODE |
| LOW | python/tests/ssd/test_spdk_tgt_create.py | 24 | def test_ssh_connect_uses_requested_port(): | CODE |
| LOW | python/tests/ssd/test_administration.py | 10 | def test_missing_paramiko_reports_install_command(): | CODE |
| LOW | python/tests/ssd/test_administration.py | 24 | def test_paramiko_is_loaded_on_demand(): | CODE |
| LOW | python/tests/ssd/test_administration.py | 30 | def test_broken_transitive_dependency_is_not_hidden(): | CODE |
| LOW | python/tests/unit/test_cli_modules.py | 53 | def test_cli_wrappers_forward_arguments_via_launcher( | CODE |
| LOW | python/tests/unit/test_cli_modules.py | 90 | def test_launcher_locates_binary_and_sets_exec_bit( | CODE |
| LOW | python/tests/unit/test_cli_modules.py | 127 | def test_launcher_raises_when_binary_is_missing( | CODE |
| LOW | python/tests/unit/test_cli_modules.py | 145 | def test_topology_cli_import_keeps_native_backends_lazy( | CODE |
| LOW | python/tests/unit/test_cli_modules.py | 158 | def test_topology_cli_runs_from_the_canonical_source_tree() -> None: | CODE |
| LOW⚡ | python/tests/unit/test_mooncake_config.py | 102 | def test_tenant_id_null_defaults(self): | CODE |
| LOW⚡ | python/tests/unit/test_mooncake_config.py | 109 | def test_ssd_offload_path_null_defaults(self): | CODE |
| LOW⚡ | python/tests/unit/test_mooncake_config.py | 116 | def test_enable_ssd_offload_string_values(self): | CODE |
| LOW⚡ | python/tests/unit/test_mooncake_config.py | 457 | def test_negative_sizes_raise(self): | CODE |
| LOW⚡ | python/tests/unit/test_mooncake_config.py | 465 | def test_empty_required_field_raises(self): | CODE |
| LOW⚡ | python/tests/unit/test_mooncake_config.py | 473 | def test_from_file_warns_on_unknown_protocol(self): | CODE |
| LOW | python/tests/unit/test_mooncake_config.py | 63 | def test_load_with_default_values(self): | CODE |
| LOW | python/tests/unit/test_mooncake_config.py | 83 | def test_load_tenant_id_from_file(self): | CODE |
| LOW | python/tests/unit/test_mooncake_config.py | 153 | def test_client_http_config_from_file(self): | CODE |
| LOW | python/tests/unit/test_mooncake_config.py | 167 | def test_missing_required_field(self): | CODE |
| LOW | python/tests/unit/test_mooncake_config.py | 181 | def test_load_from_config_path_env(self): | CODE |
| LOW | python/tests/unit/test_mooncake_config.py | 195 | def test_load_from_config_env(self): | CODE |
| LOW | python/tests/unit/test_mooncake_config.py | 287 | def test_tenant_id_env_defaults(self): | CODE |
| 1433 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/mooncake/buffer_pool.py | 1 | CODE | |
| LOW | python/mooncake/spdk_tgt_create.py | 5 | CODE | |
| LOW | python/mooncake/__init__.py | 5 | CODE | |
| LOW | python/mooncake/__init__.py | 5 | CODE | |
| LOW | python/mooncake/_launcher.py | 12 | CODE | |
| LOW | python/tests/packaging/test_project.py | 1 | CODE | |
| LOW | python/tests/packaging/test_installed_wheel.py | 1 | CODE | |
| LOW | python/tests/unit/test_cli_modules.py | 1 | CODE | |
| LOW | …hon/tests/ep/test_mooncake_elastic_buffer_transport.py | 3 | CODE | |
| LOW | python/tests/ep/test_ep_grid.py | 38 | CODE | |
| LOW | python/tests/ep/test_elastic_buffer.py | 20 | CODE | |
| LOW | python/tests/ep/test_elastic_buffer.py | 45 | CODE | |
| LOW | python/tests/store/test_buffer_pool_native.py | 1 | CODE | |
| LOW | python/tests/store/test_async_store.py | 1 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/lifetime.py | 8 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/_typing.py | 6 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/_typing.py | 8 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/__init__.py | 3 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/__init__.py | 3 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/__init__.py | 3 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/__init__.py | 3 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/geometry.py | 3 | CODE | |
| LOW | mooncake-reshard/python/mooncake/reshard/_compat.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 3 | CODE | |
| LOW | …ake-reshard/python/mooncake/reshard/weight/lifetime.py | 3 | CODE | |
| LOW | …ake-reshard/python/mooncake/reshard/weight/lifetime.py | 3 | CODE | |
| LOW | …ake-reshard/python/mooncake/reshard/weight/lifetime.py | 3 | CODE | |
| LOW | …ake-reshard/python/mooncake/reshard/weight/lifetime.py | 3 | CODE | |
| LOW | …ake-reshard/python/mooncake/reshard/weight/lifetime.py | 3 | CODE | |
| LOW | …ake-reshard/python/mooncake/reshard/weight/lifetime.py | 3 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 3 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 3 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 3 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 8 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 8 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 8 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 13 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 13 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 13 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 18 | CODE | |
| 458 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/mooncake/mooncake_ep_buffer.py | 708 | # ----------------- | COMMENT |
| MEDIUM | python/mooncake/mooncake_ep_buffer.py | 710 | # ----------------- | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 20 | # ========================================== | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 22 | # ========================================== | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 116 | # ========================================== | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 118 | # ========================================== | COMMENT |
| MEDIUM⚡ | python/tests/store/async_store_integration.py | 177 | # ========================================== | COMMENT |
| MEDIUM⚡ | python/tests/store/async_store_integration.py | 179 | # ========================================== | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 198 | # ========================================== | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 200 | # ========================================== | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 322 | # ========================================== | COMMENT |
| MEDIUM | python/tests/store/async_store_integration.py | 324 | # ========================================== | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 8 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 10 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 18 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 20 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 108 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 110 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/setup.py | 151 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/setup.py | 153 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 168 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 170 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 180 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 182 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/mooncake/structured_object_store.py | 6771 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | mooncake-wheel/mooncake/structured_object_store.py | 6773 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 247 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 249 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 288 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 290 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 327 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 329 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 580 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 582 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 620 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 622 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 725 | # -------------------------- | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 727 | # -------------------------- | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 23 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 25 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 38 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 40 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 68 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 70 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 209 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 211 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 638 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 640 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 727 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/benchmark.py | 729 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/layout/mla.py | 12 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/layout/mla.py | 14 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/layout/mla.py | 121 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/layout/mla.py | 123 | # ============================================================================ | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/storage/disk.py | 158 | # ======================================================================== | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/storage/disk.py | 160 | # ======================================================================== | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/storage/disk.py | 314 | # ======================================================================== | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/storage/disk.py | 316 | # ======================================================================== | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/storage/disk.py | 373 | # ======================================================================== | COMMENT |
| MEDIUM | benchmarks/storage_benchmark_v1/storage/disk.py | 375 | # ======================================================================== | COMMENT |
| 27 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/mooncake/http_metadata_server.py | 143 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ssd_unregister.py | 59 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ssd_unregister.py | 237 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ssd_unregister.py | 319 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ep_buffer.py | 293 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ep_buffer.py | 307 | except Exception: | CODE |
| LOW | python/mooncake/mooncake_ep_buffer.py | 319 | except Exception: | CODE |
| LOW | python/mooncake/mooncake_ep_buffer.py | 331 | except Exception: | CODE |
| LOW | python/mooncake/mooncake_ep_buffer.py | 347 | except Exception: | CODE |
| MEDIUM | python/mooncake/mooncake_ep_buffer.py | 316 | def _is_mooncake_backend(self) -> bool: | CODE |
| LOW | python/mooncake/spdk_tgt_create.py | 165 | except Exception as e: | CODE |
| LOW | python/mooncake/spdk_tgt_create.py | 511 | except Exception as e: | CODE |
| LOW | python/mooncake/spdk_tgt_create.py | 644 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ssd_register.py | 58 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ssd_register.py | 218 | except Exception as e: | CODE |
| LOW | python/mooncake/mooncake_ssd_register.py | 267 | except Exception as e: | CODE |
| LOW | python/mooncake/transfer_engine_topology_dump.py | 191 | except Exception as exc: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 491 | except Exception: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 627 | except Exception as exc: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 665 | except Exception as exc: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 821 | except Exception: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 880 | except Exception: | CODE |
| LOW | python/tests/ep/test_regmr_overhead.py | 264 | except Exception as e: | CODE |
| LOW | python/tests/ep/test_regmr_overhead.py | 299 | except Exception: | CODE |
| LOW | python/tests/ep/test_regmr_overhead.py | 334 | except Exception as e: | CODE |
| LOW⚡ | python/tests/ep/test_regmr_overhead.py | 407 | except Exception as e: | CODE |
| LOW⚡ | python/tests/ep/test_regmr_overhead.py | 416 | except Exception: | CODE |
| MEDIUM | python/tests/ep/test_regmr_overhead.py | 445 | print("Error: WORLD_SIZE must be at least 2 for distributed tests") | CODE |
| LOW | python/tests/ep/test_mooncake_ep.py | 334 | except Exception: | CODE |
| LOW | python/tests/ep/test_ep_grid.py | 238 | except Exception: | CODE |
| LOW | python/tests/ep/test_ep_grid.py | 394 | except Exception: | CODE |
| LOW | python/tests/integration/test_cli.py | 43 | except Exception as e: | CODE |
| LOW | python/tests/integration/test_cli.py | 114 | except Exception as e: | CODE |
| LOW | python/tests/store/async_store_integration.py | 54 | except Exception as e: | CODE |
| LOW | python/tests/store/async_store_integration.py | 160 | except Exception as e: | CODE |
| LOW⚡ | python/tests/store/async_store_integration.py | 171 | except Exception as e: | CODE |
| MEDIUM⚡ | python/tests/store/async_store_integration.py | 172 | print(f"Error during close: {e}") | CODE |
| MEDIUM | .claude/skills/mooncake-api/SKILL.md | 446 | print("Error checking existence") | CODE |
| LOW | …/python/mooncake/reshard/weight/_store/registration.py | 108 | except Exception as error: | CODE |
| LOW | …/python/mooncake/reshard/weight/_store/registration.py | 294 | except Exception as error: | CODE |
| LOW | …shard/python/mooncake/reshard/weight/_store/backend.py | 191 | except Exception as error: | CODE |
| LOW | …shard/python/mooncake/reshard/weight/_store/backend.py | 210 | except Exception as error: | CODE |
| LOW | …d/python/mooncake/reshard/weight/_store/transaction.py | 189 | except Exception as error: | CODE |
| LOW | …d/python/mooncake/reshard/weight/_store/transaction.py | 239 | except Exception as error: | CODE |
| LOW | …d/python/mooncake/reshard/weight/_store/transaction.py | 279 | except Exception as error: | CODE |
| LOW | …shard/python/mooncake/reshard/weight/_store/payload.py | 97 | except Exception as error: | CODE |
| LOW | …-reshard/python/mooncake/reshard/weight/_store/load.py | 51 | except Exception as error: | CODE |
| LOW | …-reshard/python/mooncake/reshard/weight/_store/load.py | 55 | except Exception as error: | CODE |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/executor.py | 175 | except Exception as exc: # noqa: BLE001 - native exceptions become failed receipts | CODE |
| LOW⚡ | …/python/mooncake/reshard/transfer_engine/completion.py | 104 | except Exception as error: | CODE |
| LOW⚡ | …/python/mooncake/reshard/transfer_engine/completion.py | 112 | except Exception as error: | CODE |
| LOW | …/python/mooncake/reshard/transfer_engine/completion.py | 177 | except Exception as error: | CODE |
| LOW | …/python/mooncake/reshard/transfer_engine/completion.py | 194 | except Exception as error: | CODE |
| LOW | …/python/mooncake/reshard/transfer_engine/completion.py | 208 | except Exception as error: | CODE |
| LOW | …/python/mooncake/reshard/transfer_engine/completion.py | 219 | except Exception: | CODE |
| LOW | …/python/mooncake/reshard/transfer_engine/completion.py | 464 | except Exception: | CODE |
| LOW | …rd/python/mooncake/reshard/transfer_engine/executor.py | 265 | except Exception as error: | CODE |
| LOW | mooncake-reshard/tests/model_weight_store/helpers.py | 844 | except Exception: | CODE |
| LOW | …shard/tests/model_weight_te/test_quarantine_cleanup.py | 201 | except Exception as error: | CODE |
| MEDIUM | …shard/tests/model_weight_te/test_quarantine_cleanup.py | 198 | def run_execute() -> None: | CODE |
| 149 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/mooncake/transfer_engine_topology_dump.py | 198 | except OSError: | CODE |
| HIGH | python/mooncake/mooncake_elastic_buffer.py | 821 | except Exception: | CODE |
| HIGH | python/tests/ep/test_regmr_overhead.py | 299 | except Exception: | CODE |
| HIGH | python/tests/ep/test_regmr_overhead.py | 416 | except Exception: | CODE |
| HIGH | python/tests/ep/test_mooncake_ep.py | 334 | except Exception: | CODE |
| HIGH | …reshard/tests/kv_cache/test_runtime_transfer_native.py | 208 | except (BrokenPipeError, EOFError): | CODE |
| HIGH | mooncake-wheel/setup.py | 53 | except (subprocess.CalledProcessError, FileNotFoundError, subprocess.TimeoutExpired): | CODE |
| HIGH | mooncake-wheel/setup.py | 90 | except (subprocess.CalledProcessError, FileNotFoundError, subprocess.TimeoutExpired): | CODE |
| HIGH | mooncake-wheel/mooncake/structured_object_store.py | 6637 | except TypeError: | CODE |
| HIGH | mooncake-wheel/mooncake/structured_object_store.py | 4161 | except RuntimeError: | CODE |
| HIGH | mooncake-wheel/mooncake/structured_object_store.py | 4986 | except Exception: | CODE |
| HIGH | mooncake-wheel/mooncake/mooncake_store_service.py | 47 | except AttributeError: | CODE |
| HIGH | mooncake-wheel/mooncake/mooncake_store_service.py | 235 | except asyncio.TimeoutError: | CODE |
| HIGH | mooncake-wheel/tests/test_offload_on_eviction.py | 138 | except Exception: | CODE |
| HIGH | mooncake-wheel/tests/test_promotion_on_hit.py | 307 | except Exception: | CODE |
| HIGH | mooncake-wheel/tests/test_promotion_on_hit.py | 375 | except Exception: | CODE |
| HIGH | mooncake-wheel/tests/test_promotion_on_hit.py | 579 | except Exception: | CODE |
| HIGH | mooncake-pg/tests/pg_test_utils.py | 240 | except Exception: | CODE |
| HIGH | mooncake-pg/tests/pg_test_utils.py | 245 | except Exception: | CODE |
| HIGH | mooncake-pg/tests/pg_test_utils.py | 424 | except Exception: | CODE |
| HIGH | mooncake-pg/tests/pg_test_utils.py | 439 | except Exception: | CODE |
| HIGH | mooncake-pg/tests/pg_test_topology.py | 73 | except Exception: | CODE |
| HIGH | mooncake-pg/tests/test_pg_init_functional.py | 81 | except Exception: | CODE |
| HIGH | benchmarks/storage_benchmark_v1/storage/disk.py | 390 | except OSError: | CODE |
| HIGH | benchmarks/storage_benchmark_v1/storage/disk.py | 239 | except OSError: | CODE |
| HIGH | benchmarks/storage_benchmark_v1/storage/disk.py | 311 | except OSError: | CODE |
| HIGH | benchmarks/storage_benchmark_v1/storage/disk.py | 384 | except OSError: | CODE |
| HIGH | scripts/test_drain_http_api.py | 436 | except Exception: | CODE |
| HIGH | scripts/ascend/perf/hccl_tools.py | 69 | except EOFError: | CODE |
| HIGH | scripts/ci/tests/test_rpc_smoke.py | 74 | except ProcessLookupError: | CODE |
| HIGH | …ts/e2e/python/test_hicache_storage_mooncake_backend.py | 139 | except (requests.RequestException, ConnectionError): | CODE |
| HIGH | mooncake-integration/fabric_allocator_utils.py | 17 | except (ImportError, FileNotFoundError, TypeError): | CODE |
| HIGH | mooncake-integration/fabric_allocator_utils.py | 27 | except (ImportError, FileNotFoundError, TypeError): | CODE |
| HIGH | mooncake-integration/allocator.py | 115 | except (ImportError, FileNotFoundError, TypeError): | CODE |
| HIGH | mooncake-integration/allocator.py | 126 | except (ImportError, FileNotFoundError, TypeError): | CODE |
| HIGH | mooncake-integration/shared_segment.py | 280 | except (RuntimeError, AttributeError): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 722 | # Step 1: All ranks participate in first collective | COMMENT |
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 727 | # Step 2: Broken rank exits after first collective | COMMENT |
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 732 | # Step 3: Survivors wait for broken rank to exit | COMMENT |
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 735 | # Step 4: Survivors run collective without broken rank | COMMENT |
| LOW | docs/source/design/tent/metrics.md | 317 | ### Step 1: Declare the Metric | COMMENT |
| LOW | docs/source/design/tent/metrics.md | 332 | ### Step 2: Register the Metric | COMMENT |
| LOW | docs/source/design/tent/metrics.md | 352 | ### Step 3: Add Recording Methods (Optional) | COMMENT |
| LOW⚡ | docs/source/api-reference/python/mooncake-store.md | 401 | # Step 1: Register the buffer | COMMENT |
| LOW⚡ | docs/source/api-reference/python/mooncake-store.md | 406 | # Step 2: Zero-copy store | COMMENT |
| LOW⚡ | docs/source/api-reference/python/mooncake-store.md | 413 | # Step 3: Pre-allocate buffer for retrieval | COMMENT |
| LOW⚡ | docs/source/api-reference/python/mooncake-store.md | 418 | # Step 4: Register receive buffer | COMMENT |
| LOW⚡ | docs/source/api-reference/python/mooncake-store.md | 423 | # Step 5: Zero-copy retrieval | COMMENT |
| LOW⚡ | docs/source/api-reference/python/mooncake-store.md | 432 | # Step 6: Clean up - unregister both buffers | COMMENT |
| LOW | docs/source/deployment/ssd/ssd-offload.md | 20 | ### Step 1: Create the SSD storage directory | COMMENT |
| LOW | docs/source/deployment/ssd/ssd-offload.md | 26 | ### Step 2: Start the master | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 235 | // Step 1: Submit on "RDMA" — should fail (proxy injects fault) | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 239 | // Step 2: Failover logic (mirrors resubmitTransferTask) | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 247 | // Step 3: Submit on "TCP" — should succeed | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 251 | // Step 4: Verify completion | COMMENT |
| LOW | …e-transfer-engine/tent/src/runtime/admission_queue.cpp | 323 | // Step 3: an owner predicted to miss its deadline is dropped (not | COMMENT |
| LOW | …ude/cachelib_memory_allocator/include/fmt/format-inl.h | 2080 | // Step 1: integer promotion & Schubfach multiplier calculation. | COMMENT |
| LOW | …ude/cachelib_memory_allocator/include/fmt/format-inl.h | 2123 | // Step 2: Try larger divisor; remove trailing zeros if necessary | COMMENT |
| LOW | …ude/cachelib_memory_allocator/include/fmt/format-inl.h | 2159 | // Step 3: Find the significand with the smaller divisor | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 53 | // Step 1: Create a store handle. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 65 | // Step 2: Connect to the metadata server and transport layer. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 93 | // Step 3: Put a key/value pair (copies data into the store). | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 106 | // Step 4: Check existence. | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 113 | // Step 5: Get size. | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 119 | // Step 6: Retrieve the value. | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 128 | // Step 7: Put with explicit replication config. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 145 | // Step 8: Remove the keys. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 156 | // Step 9: Demonstrate error handling for a missing key. | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1300 | // Step 1: Simulate cache miss — get a free block | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1304 | // Step 2: Write data directly into the block (simulating TransferRead | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1309 | // Step 3: Set metadata and insert into LRU | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1314 | // Step 4: Re-acquire ref via GetHotKey | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1320 | // Step 5: Create BufferHandle in view mode | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1117 | // Step 1: Mount segment and create a completed MEMORY replica. | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1136 | // Step 2: Mount local disk segment and add LOCAL_DISK replica via | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1164 | // Step 3: Remove the object (removes both MEMORY and LOCAL_DISK replicas). | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1179 | // Step 4: Test SSD hit path by creating an object with only a LOCAL_DISK | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 382 | // Step 2: Create copy task via master | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 390 | // Step 3: Wait for task to be fetched and executed by the assigned client | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 395 | // Step 4: Copy adds the target and preserves the source replica. | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 398 | // Step 5: Verify data integrity. | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 438 | // Step 2: Create move task via master | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 446 | // Step 3: Wait for task to be fetched and executed by the assigned client | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 451 | // Step 4: Move adds the target and removes the source replica. | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 454 | // Step 5: Verify data integrity. | COMMENT |
| LOW | mooncake-store/tests/task_integration_test.cpp | 358 | // Step 1: Put data on client1 | COMMENT |
| LOW | mooncake-store/tests/task_integration_test.cpp | 414 | // Step 1: Put data on client1 | COMMENT |
| LOW | mooncake-store/tests/task_integration_test.cpp | 797 | // Step 1: Put multiple keys on client1 | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1350 | // Step 1: Create a snapshot using a service | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1359 | // Step 2: Create a new service with restore + backup_dir set | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1388 | // Step 1: Create a snapshot using a service | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1397 | // Step 2: Create a new service with restore but NO backup_dir | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1593 | // Step 2: Persist state | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1599 | // Step 3: Restore into a new service | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1693 | // Step 2: Persist state | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1699 | // Step 3: Restore into a new service | COMMENT |
| 13 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 722 | # Step 1: All ranks participate in first collective | COMMENT |
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 727 | # Step 2: Broken rank exits after first collective | COMMENT |
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 732 | # Step 3: Survivors wait for broken rank to exit | COMMENT |
| LOW⚡ | mooncake-pg/tests/test_pg_elastic.py | 735 | # Step 4: Survivors run collective without broken rank | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 235 | // Step 1: Submit on "RDMA" — should fail (proxy injects fault) | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 239 | // Step 2: Failover logic (mirrors resubmitTransferTask) | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 247 | // Step 3: Submit on "TCP" — should succeed | COMMENT |
| LOW⚡ | …oncake-transfer-engine/tent/tests/fault_proxy_test.cpp | 251 | // Step 4: Verify completion | COMMENT |
| LOW | …e-transfer-engine/tent/src/runtime/admission_queue.cpp | 323 | // Step 3: an owner predicted to miss its deadline is dropped (not | COMMENT |
| LOW | mooncake-store/include/client_metric.h | 248 | // For dynamic metrics, we need to check if there are any labels with | COMMENT |
| LOW | …ude/cachelib_memory_allocator/include/fmt/format-inl.h | 2080 | // Step 1: integer promotion & Schubfach multiplier calculation. | COMMENT |
| LOW | …ude/cachelib_memory_allocator/include/fmt/format-inl.h | 2123 | // Step 2: Try larger divisor; remove trailing zeros if necessary | COMMENT |
| LOW | …ude/cachelib_memory_allocator/include/fmt/format-inl.h | 2159 | // Step 3: Find the significand with the smaller divisor | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 53 | // Step 1: Create a store handle. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 65 | // Step 2: Connect to the metadata server and transport layer. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 93 | // Step 3: Put a key/value pair (copies data into the store). | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 106 | // Step 4: Check existence. | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 113 | // Step 5: Get size. | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 119 | // Step 6: Retrieve the value. | COMMENT |
| LOW⚡ | mooncake-store/rust/examples/basic_usage.rs | 128 | // Step 7: Put with explicit replication config. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 145 | // Step 8: Remove the keys. | COMMENT |
| LOW | mooncake-store/rust/examples/basic_usage.rs | 156 | // Step 9: Demonstrate error handling for a missing key. | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1300 | // Step 1: Simulate cache miss — get a free block | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1304 | // Step 2: Write data directly into the block (simulating TransferRead | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1309 | // Step 3: Set metadata and insert into LRU | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1314 | // Step 4: Re-acquire ref via GetHotKey | COMMENT |
| LOW⚡ | mooncake-store/tests/client_local_hot_cache_test.cpp | 1320 | // Step 5: Create BufferHandle in view mode | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1117 | // Step 1: Mount segment and create a completed MEMORY replica. | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1136 | // Step 2: Mount local disk segment and add LOCAL_DISK replica via | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1164 | // Step 3: Remove the object (removes both MEMORY and LOCAL_DISK replicas). | COMMENT |
| LOW | mooncake-store/tests/master_metrics_test.cpp | 1179 | // Step 4: Test SSD hit path by creating an object with only a LOCAL_DISK | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 382 | // Step 2: Create copy task via master | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 390 | // Step 3: Wait for task to be fetched and executed by the assigned client | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 395 | // Step 4: Copy adds the target and preserves the source replica. | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 398 | // Step 5: Verify data integrity. | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 438 | // Step 2: Create move task via master | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 446 | // Step 3: Wait for task to be fetched and executed by the assigned client | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 451 | // Step 4: Move adds the target and removes the source replica. | COMMENT |
| LOW⚡ | mooncake-store/tests/task_integration_test.cpp | 454 | // Step 5: Verify data integrity. | COMMENT |
| LOW | mooncake-store/tests/task_integration_test.cpp | 358 | // Step 1: Put data on client1 | COMMENT |
| LOW | mooncake-store/tests/task_integration_test.cpp | 414 | // Step 1: Put data on client1 | COMMENT |
| LOW | mooncake-store/tests/task_integration_test.cpp | 797 | // Step 1: Put multiple keys on client1 | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1350 | // Step 1: Create a snapshot using a service | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1359 | // Step 2: Create a new service with restore + backup_dir set | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1388 | // Step 1: Create a snapshot using a service | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1397 | // Step 2: Create a new service with restore but NO backup_dir | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1593 | // Step 2: Persist state | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1599 | // Step 3: Restore into a new service | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1693 | // Step 2: Persist state | COMMENT |
| LOW⚡ | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1699 | // Step 3: Restore into a new service | COMMENT |
| LOW | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1372 | // Step 3: Verify backup files were created in | COMMENT |
| LOW | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1409 | // Step 3: Verify NO backup directory was created | COMMENT |
| LOW | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1548 | // Step 1: Create service and add both clean and dirty data | COMMENT |
| LOW | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1611 | // Step 4: Verify non-COMPLETE replica was cleaned, complete one remains | COMMENT |
| LOW | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1622 | // Step 1: Create service with long lease TTL | COMMENT |
| LOW | …tore/tests/ha/snapshot/snapshot_child_process_test.cpp | 1711 | // Step 4: Verify normal data retained, expired-lease data cleaned | COMMENT |
| LOW | mooncake-store/src/storage_backend.cpp | 1718 | // Step 1: Build read plan by copying metadata under lock | COMMENT |
| LOW | mooncake-store/src/storage_backend.cpp | 1789 | // Step 2: Perform IO without holding any locks | COMMENT |
| LOW | mooncake-store/src/storage_backend.cpp | 3226 | // Step 1: Remove bucket from metadata maps under exclusive lock | COMMENT |
| LOW | mooncake-store/src/storage_backend.cpp | 3261 | // Step 2: Wait for in-flight reads to complete | COMMENT |
| 3 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/mooncake/cli_bench.py | 0 | main entry point for the mooncake_master command. simply runs the mooncake_master binary with all arguments passed throu | STRING |
| HIGH | python/mooncake/cli_client.py | 0 | main entry point for the mooncake_master command. simply runs the mooncake_master binary with all arguments passed throu | STRING |
| HIGH | python/mooncake/cli.py | 0 | main entry point for the mooncake_master command. simply runs the mooncake_master binary with all arguments passed throu | STRING |
| HIGH | mooncake-wheel/tests/test_dummy_client.py | 0 | test class for single store operations (no replication). | STRING |
| HIGH | …ncake-wheel/tests/test_distributed_object_store_cxl.py | 0 | test class for single store operations (no replication). | STRING |
| HIGH | mooncake-wheel/tests/test_distributed_object_store.py | 0 | test class for single store operations (no replication). | STRING |
| HIGH | mooncake-wheel/tests/test_dummy_client.py | 0 | test basic put/get/exist operations through the python interface. | STRING |
| HIGH | …ncake-wheel/tests/test_distributed_object_store_cxl.py | 0 | test basic put/get/exist operations through the python interface. | STRING |
| HIGH | mooncake-wheel/tests/test_distributed_object_store.py | 0 | test basic put/get/exist operations through the python interface. | STRING |
| HIGH | mooncake-wheel/tests/test_dummy_client.py | 0 | test batch is_exist operations through the python interface. | STRING |
| HIGH | …ncake-wheel/tests/test_distributed_object_store_cxl.py | 0 | test batch is_exist operations through the python interface. | STRING |
| HIGH | mooncake-wheel/tests/test_distributed_object_store.py | 0 | test batch is_exist operations through the python interface. | STRING |
| HIGH | mooncake-wheel/tests/test_dummy_client.py | 0 | end-to-end fuzz test comparing distributed store behavior with dict. performs ~1000 random operations (put, get, remove) | STRING |
| HIGH | …ncake-wheel/tests/test_distributed_object_store_cxl.py | 0 | end-to-end fuzz test comparing distributed store behavior with dict. performs ~1000 random operations (put, get, remove) | STRING |
| HIGH | mooncake-wheel/tests/test_distributed_object_store.py | 0 | end-to-end fuzz test comparing distributed store behavior with dict. performs ~1000 random operations (put, get, remove) | STRING |
| HIGH | mooncake-wheel/tests/test_dummy_client.py | 0 | test replicateconfig class creation and property access. | STRING |
| HIGH | …ncake-wheel/tests/test_distributed_object_store_cxl.py | 0 | test replicateconfig class creation and property access. | STRING |
| HIGH | mooncake-wheel/tests/test_distributed_object_store.py | 0 | test replicateconfig class creation and property access. | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/mooncake/mooncake_ssd_unregister.py | 20 | CODE | |
| LOW | python/mooncake/mooncake_ssd_unregister.py | 84 | CODE | |
| LOW | python/mooncake/mooncake_ssd_unregister.py | 129 | CODE | |
| LOW | python/mooncake/mooncake_ep_buffer.py | 730 | CODE | |
| LOW | python/mooncake/mooncake_ep_buffer.py | 948 | CODE | |
| LOW | python/mooncake/spdk_tgt_create.py | 72 | CODE | |
| LOW | python/mooncake/mooncake_config.py | 127 | CODE | |
| LOW | python/mooncake/mooncake_ssd_register.py | 21 | CODE | |
| LOW | python/mooncake/mooncake_ssd_register.py | 93 | CODE | |
| LOW | python/mooncake/mooncake_ssd_register.py | 138 | CODE | |
| LOW | python/tests/unit/test_mooncake_config.py | 465 | CODE | |
| LOW | python/tests/ep/ep_test_utils.py | 156 | CODE | |
| LOW | python/tests/ep/test_regmr_overhead.py | 174 | CODE | |
| LOW | python/tests/ep/test_mooncake_ep.py | 17 | CODE | |
| LOW | …e-reshard/python/mooncake/reshard/weight/validation.py | 433 | CODE | |
| LOW | …eshard/python/mooncake/reshard/weight/_store/upload.py | 308 | CODE | |
| LOW | …-reshard/python/mooncake/reshard/weight/_store/load.py | 98 | CODE | |
| LOW | …d/python/mooncake/reshard/weight/_planner/ownership.py | 96 | CODE | |
| LOW | …n/mooncake/reshard/weight/_planner/bound_validation.py | 256 | CODE | |
| LOW | …eshard/python/mooncake/reshard/weight/_planner/core.py | 146 | CODE | |
| LOW | …ard/python/mooncake/reshard/weight/_planner/binding.py | 125 | CODE | |
| LOW | …ard/python/mooncake/reshard/weight/_planner/binding.py | 314 | CODE | |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/transfer.py | 185 | CODE | |
| LOW | …-reshard/python/mooncake/reshard/kv_cache/placement.py | 209 | CODE | |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/executor.py | 113 | CODE | |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/resolved.py | 232 | CODE | |
| LOW | …ython/mooncake/reshard/transfer_engine/registration.py | 493 | CODE | |
| LOW | …ython/mooncake/reshard/transfer_engine/registration.py | 579 | CODE | |
| LOW | …/python/mooncake/reshard/transfer_engine/completion.py | 439 | CODE | |
| LOW | …reshard/tests/kv_cache/test_runtime_transfer_native.py | 132 | CODE | |
| LOW | …oncake-reshard/tests/kv_cache/test_runtime_transfer.py | 44 | CODE | |
| LOW | …oncake-reshard/tests/kv_cache/test_runtime_transfer.py | 124 | CODE | |
| LOW | mooncake-wheel/setup.py | 28 | CODE | |
| LOW | mooncake-wheel/mooncake/_partial_read.py | 15 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 2021 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 2517 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 2722 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 2840 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 3083 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 6038 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 6937 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 735 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 932 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 1308 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 1521 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 1750 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 3830 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 4253 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 4953 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 755 | CODE | |
| LOW | mooncake-wheel/mooncake/dataproto_catalog.py | 435 | CODE | |
| LOW | mooncake-wheel/mooncake/dataproto_catalog.py | 483 | CODE | |
| LOW | mooncake-wheel/mooncake/mooncake_store_service.py | 93 | CODE | |
| LOW | mooncake-wheel/mooncake/mooncake_store_service.py | 129 | CODE | |
| LOW | mooncake-wheel/mooncake/mooncake_store_service.py | 285 | CODE | |
| LOW | mooncake-wheel/tests/test_dummy_client.py | 145 | CODE | |
| LOW | mooncake-wheel/tests/test_dummy_client.py | 1225 | CODE | |
| LOW | mooncake-wheel/tests/test_structured_object_store.py | 201 | CODE | |
| LOW | …ncake-wheel/tests/test_distributed_object_store_cxl.py | 521 | CODE | |
| LOW | mooncake-wheel/tests/test_cuda_fabric_compat.py | 15 | CODE | |
| 36 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/mooncake/buffer_pool.py | 12 | __all__ = ["BufferPool", "RegisteredBufferPool"] | CODE |
| LOW | python/mooncake/mooncake_config.py | 70 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/mooncake/__init__.py | 9 | __all__ = ["BufferPool", "RegisteredBufferPool"] | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 704 | def update_ep_member(self) -> None: | CODE |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 1359 | __all__ = ["ElasticBuffer", "EPHandle", "EventOverlap"] | CODE |
| LOW | mooncake-reshard/python/mooncake/reshard/lifetime.py | 131 | __all__ = [ | CODE |
| LOW | mooncake-reshard/python/mooncake/reshard/_typing.py | 10 | __all__ = ["TypeAlias"] | CODE |
| LOW | mooncake-reshard/python/mooncake/reshard/__init__.py | 10 | __all__ = [ | CODE |
| LOW | mooncake-reshard/python/mooncake/reshard/geometry.py | 258 | __all__ = [ | CODE |
| LOW | …oncake-reshard/python/mooncake/reshard/weight/store.py | 18 | __all__ = [ | CODE |
| LOW | …ake-reshard/python/mooncake/reshard/weight/lifetime.py | 12 | __all__ = [ | CODE |
| LOW | …cake-reshard/python/mooncake/reshard/weight/planner.py | 34 | __all__ = [ | CODE |
| LOW | …ke-reshard/python/mooncake/reshard/weight/_lifetime.py | 276 | __all__ = [ | CODE |
| LOW | …ake-reshard/python/mooncake/reshard/weight/manifest.py | 19 | __all__ = [ | CODE |
| LOW | …ake-reshard/python/mooncake/reshard/weight/__init__.py | 71 | __all__ = [ | CODE |
| LOW | …cake-reshard/python/mooncake/reshard/weight/runtime.py | 80 | __all__ = ["WeightRuntimeBindingManifest"] | CODE |
| LOW | …ake-reshard/python/mooncake/reshard/weight/topology.py | 152 | __all__ = ["ParallelTopology", "TopologyParticipant"] | CODE |
| LOW | mooncake-reshard/python/mooncake/reshard/weight/te.py | 18 | __all__ = [ | CODE |
| LOW | mooncake-reshard/python/mooncake/reshard/weight/part.py | 86 | __all__ = ["WeightPlacementPart"] | CODE |
| LOW | …/python/mooncake/reshard/weight/_store/registration.py | 302 | __all__ = ["StoreBufferRegistration", "StoreRegistrationLease"] | CODE |
| LOW | …reshard/python/mooncake/reshard/weight/_store/store.py | 236 | __all__ = ["WeightStore", "WeightStoreError"] | CODE |
| LOW | …shard/python/mooncake/reshard/weight/_store/backend.py | 251 | __all__ = [ | CODE |
| LOW | …hard/python/mooncake/reshard/weight/_store/__init__.py | 21 | __all__ = [ | CODE |
| LOW | …rd/python/mooncake/reshard/weight/_store/entrypoint.py | 25 | __all__ = ["begin_weight_snapshot"] | CODE |
| LOW | …ard/python/mooncake/reshard/weight/_store/contracts.py | 193 | __all__ = [ | CODE |
| LOW | …eshard/python/mooncake/reshard/weight/_store/writer.py | 227 | __all__ = [ | CODE |
| LOW | …hard/python/mooncake/reshard/weight/_store/snapshot.py | 73 | __all__ = ["WeightSnapshotAdapter", "WeightSnapshotDescriptor"] | CODE |
| LOW | …ard/python/mooncake/reshard/weight/_te/registration.py | 14 | __all__ = [ | CODE |
| LOW | …reshard/python/mooncake/reshard/weight/_te/lifetime.py | 12 | __all__ = [ | CODE |
| LOW | …shard/python/mooncake/reshard/weight/_te/completion.py | 12 | __all__ = [ | CODE |
| LOW | …reshard/python/mooncake/reshard/weight/_te/__init__.py | 13 | __all__ = [ | CODE |
| LOW | …d/python/mooncake/reshard/weight/_planner/ownership.py | 213 | __all__ = [ | CODE |
| LOW | …rd/python/mooncake/reshard/weight/_planner/__init__.py | 31 | __all__ = [ | CODE |
| LOW | …reshard/python/mooncake/reshard/weight/_planner/api.py | 160 | __all__ = [ | CODE |
| LOW | …on/mooncake/reshard/weight/_planner/bound_contracts.py | 646 | __all__ = [ | CODE |
| LOW | …d/python/mooncake/reshard/weight/_planner/contracts.py | 804 | __all__ = [ | CODE |
| LOW | …d/python/mooncake/reshard/weight/_planner/fragments.py | 179 | __all__ = [ | CODE |
| LOW | …ard/python/mooncake/reshard/weight/_planner/binding.py | 627 | __all__ = [ | CODE |
| LOW | …-reshard/python/mooncake/reshard/contracts/__init__.py | 27 | __all__ = [ | CODE |
| LOW | …ncake-reshard/python/mooncake/reshard/contracts/ids.py | 26 | __all__ = [ | CODE |
| LOW | …ke-reshard/python/mooncake/reshard/kv_cache/planner.py | 483 | __all__ = [ | CODE |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/manifest.py | 25 | __all__ = [ | CODE |
| LOW | …reshard/python/mooncake/reshard/kv_cache/plan_serde.py | 192 | __all__ = ["kv_cache_logical_plan_from_json", "kv_cache_logical_plan_to_json"] | CODE |
| LOW | …cake-reshard/python/mooncake/reshard/kv_cache/serde.py | 501 | __all__ = [ | CODE |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/__init__.py | 69 | __all__ = [ | CODE |
| LOW | …cake-reshard/python/mooncake/reshard/kv_cache/types.py | 183 | __all__ = [ | CODE |
| LOW | …ke-reshard/python/mooncake/reshard/kv_cache/runtime.py | 114 | __all__ = [ | CODE |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/topology.py | 124 | __all__ = ["KVCacheTopology", "KVCacheTopologyParticipant"] | CODE |
| LOW | …-reshard/python/mooncake/reshard/kv_cache/placement.py | 331 | __all__ = ["KVCachePlacementManifest", "assemble_kv_cache_placement"] | CODE |
| LOW | …ncake-reshard/python/mooncake/reshard/kv_cache/part.py | 71 | __all__ = ["KVCachePlacementPart"] | CODE |
| LOW | …ke-reshard/python/mooncake/reshard/kv_cache/binding.py | 170 | __all__ = ["validate_runtime_binding", "validate_runtime_bindings"] | CODE |
| LOW | …e-reshard/python/mooncake/reshard/kv_cache/snapshot.py | 138 | __all__ = ["KVCacheSnapshotDescriptor", "SnapshotId"] | CODE |
| LOW | …ard/python/mooncake/reshard/kv_cache/snapshot_serde.py | 117 | __all__ = ["kv_cache_snapshot_from_json", "kv_cache_snapshot_to_json"] | CODE |
| LOW | …rd/python/mooncake/reshard/transfer_engine/lifetime.py | 11 | __all__ = [ | CODE |
| LOW | …rd/python/mooncake/reshard/transfer_engine/__init__.py | 25 | __all__ = [ | CODE |
| LOW | mooncake-wheel/mooncake/vllm_v1_proxy_server.py | 16 | logger = logging.getLogger(__name__) | CODE |
| LOW | mooncake-wheel/mooncake/__init__.py | 9 | __all__ = ["BufferPool", "RegisteredBufferPool"] | CODE |
| LOW | mooncake-wheel/mooncake/dataproto_catalog.py | 11 | logger = logging.getLogger(__name__) | CODE |
| LOW | docs/source/conf.py | 24 | logger = logging.getLogger(__name__) | CODE |
| LOW | benchmarks/storage_benchmark_v1/__init__.py | 20 | __all__ = [ | CODE |
| 8 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | python/mooncake/spdk_tgt_create.py | 220 | class=$(cat "$dev/class" 2>/dev/null || true) | CODE |
| HIGH⚡ | python/mooncake/spdk_tgt_create.py | 226 | driver=$(basename "$(readlink "$dev/driver" 2>/dev/null)" 2>/dev/null || true) | CODE |
| HIGH⚡ | python/mooncake/spdk_tgt_create.py | 226 | driver=$(basename "$(readlink "$dev/driver" 2>/dev/null)" 2>/dev/null || true) | CODE |
| HIGH | python/mooncake/spdk_tgt_create.py | 237 | real_device=$(readlink -f "$block/device" 2>/dev/null || true) | CODE |
| HIGH | python/mooncake/spdk_tgt_create.py | 296 | driver=$(basename "$(readlink "/sys/bus/pci/devices/$pci/driver" 2>/dev/null)" 2>/dev/null || true) | CODE |
| HIGH | python/mooncake/spdk_tgt_create.py | 296 | driver=$(basename "$(readlink "/sys/bus/pci/devices/$pci/driver" 2>/dev/null)" 2>/dev/null || true) | CODE |
| HIGH | scripts/test_engram_store.py | 53 | "cd build && cmake .. -DWITH_STORE=ON && make -j 128" | CODE |
| HIGH⚡ | scripts/tone_tests/tests/test_suite_layout.py | 25 | "declare -f launch_sglang_server >/dev/null; " | CODE |
| HIGH | …nsfer-engine/example/efa_per_transfer_latency_bench.py | 69 | "| xargs -r kill 2>/dev/null; sleep 1; echo done" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/tests/ep/test_elastic_buffer_recovery.py | 19 | # Reuse the source-tree PG harness without copying its process lifecycle logic. | COMMENT |
| MEDIUM⚡ | mooncake-wheel/setup.py | 22 | # packaging ≥20 provides a robust glibc detector used by pip/build | COMMENT |
| MEDIUM | mooncake-wheel/mooncake/mooncake_connector_v1.py | 435 | # Tasks can await async events, so a surplus (2x is a robust heuristic) | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_ssd_offload_in_evict.py | 173 | """Print comprehensive statistics for the test.""" | STRING |
| MEDIUM | …-transfer-engine/tent/tests/metrics_recording_test.cpp | 101 | // tests are robust to singleton state accumulated by prior tests. | COMMENT |
| MEDIUM | mooncake-store/tests/stress_cluster_benchmark.py | 124 | """Calculate and return comprehensive performance statistics.""" | STRING |
| MEDIUM | mooncake-store/tests/stress_cluster_benchmark.py | 331 | """Print comprehensive performance statistics in a structured format.""" | STRING |
| MEDIUM | mooncake-store/benchmarks/batch_remove_benchmark.py | 12 | # Run comprehensive tests | STRING |
| MEDIUM | mooncake-store/src/client_service.cpp | 2411 | // Helper methods for robust state management | COMMENT |
| MEDIUM | mooncake-store/src/client_service.cpp | 2657 | // Process individual responses with robust error handling | COMMENT |
| MEDIUM | mooncake-store/src/client_service.cpp | 2756 | // Process individual responses with robust error handling | COMMENT |
| MEDIUM | mooncake-store/src/transfer_task.cpp | 329 | // to fully utilize the available ssd bandwidth, we use a default of 4 worker | COMMENT |
| MEDIUM | mooncake-store/src/common/s3_helper.cpp | 336 | // the network For GB-sized files, 2 concurrent downloads can fully utilize | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | mooncake-wheel/pyproject.toml | 3 | # This file is built from this directory; scripts/build_wheel.sh `cd`s | COMMENT |
| MEDIUM | …ncake-wheel/tests/test_distributed_object_store_cxl.py | 77 | # Create a new store instance with zero local buffer size | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_safetensor_functions.py | 56 | # Create a test tensor | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_distributed_object_store.py | 110 | # Create a new store instance with zero local buffer size | COMMENT |
| MEDIUM | mooncake-wheel/tests/test_put_get_tensor.py | 33 | # Define a test class for serialization | COMMENT |
| MEDIUM | scripts/test_copy_move_api.py | 162 | # Create a coordinator client to run tests | COMMENT |
| MEDIUM | scripts/ascend/dependencies_ascend_installation.sh | 17 | # Define a function to handle the git clone operation | COMMENT |
| MEDIUM | scripts/ascend/dependencies_ascend.sh | 27 | # Define a function to handle the git clone operation | COMMENT |
| MEDIUM | scripts/e2e/python/toy_proxy_server.py | 1 | # This file is from the vllm community: ./tests/v1/kv_connector/nixl_integration/toy_proxy_server.py | COMMENT |
| MEDIUM | mooncake-store/tests/e2e/run_oplog_batch_cluster.sh | 458 | # This file is generated by this script with shell-escaped values. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | dependencies.sh | 319 | # Check if .gitmodules exists | COMMENT |
| LOW | python/mooncake/spdk_tgt_create.py | 340 | # Check if tgt is already running | COMMENT |
| LOW | python/mooncake/mooncake_ssd_register.py | 268 | # Check if the error is due to the segment already existing on the server | COMMENT |
| LOW | python/tests/ep/test_regmr_overhead.py | 367 | # Check if distributed environment is already initialized | COMMENT |
| LOW⚡ | python/tests/ep/test_regmr_overhead.py | 425 | # Check if we should run with multiprocessing (for distributed tests) | COMMENT |
| LOW | python/tests/integration/test_cli.py | 14 | # Check if mooncake_master is in PATH | COMMENT |
| LOW | python/tests/integration/test_cli.py | 77 | # Check if process is running | COMMENT |
| LOW | benchmarks/storage_benchmark_v1/benchmark.py | 879 | # Print results | COMMENT |
| LOW⚡ | scripts/test_installation.sh | 76 | # Check if the mooncake_master entry point is installed and executable | COMMENT |
| LOW⚡ | scripts/test_installation.sh | 81 | # Check if the mooncake_client entry point is installed and executable | COMMENT |
| LOW⚡ | scripts/test_installation.sh | 86 | # Check if the transfer_engine_bench entry point is installed and executable | COMMENT |
| LOW | scripts/run_tests.sh | 162 | # Check if MOONCAKE_STORAGE_ROOT_DIR is set and not empty | COMMENT |
| LOW | scripts/code_format.sh | 367 | # Check if file actually changed | COMMENT |
| LOW | scripts/tone_tests/scripts/common.sh | 57 | # Check if sglang-router is needed and missing | COMMENT |
| LOW | scripts/rocm_tests/scripts/common.sh | 224 | # Check if sglang-router is needed and missing | COMMENT |
| LOW | .github/workflows/ci_ascend.yml | 218 | # Check if master is running | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | mooncake-pg/benchmark/pgbench.py | 525 | # Aggregate times as requested | COMMENT |
| HIGH | mooncake-store/tests/offset_allocator_test.cpp | 1266 | // ========== EDGE CASE TESTS, Generated by AI ========== | COMMENT |
| HIGH | mooncake-store/tests/offset_allocator_test.cpp | 1409 | // ========== BIN SYSTEM TESTS, Generated by AI ========== | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | benchmarks/storage_benchmark_v1/layout/mla.py | 126 | Get MLA model configuration by name Args: model_name: Model identifier (e.g., 'glm5', 'kimi-k2.6') Ret | STRING |
| HIGH | benchmarks/storage_benchmark_v1/layout/mla.py | 144 | Create an MLALayout instance from model configuration Args: model_config: Model configuration dictionary wi | STRING |
| HIGH | scripts/ascend/perf/hccl_tools.py | 26 | parse args . Args: Returns: args. Examples: >>> parse_args() | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | README.md | 36 | - **Aug 24, 2026**: [AgentX / InferenceX v3](https://newsletter.semianalysis.com/p/agentx-inferencexv3-does-cuda-moat) h | CODE |
| MEDIUM | README.md | 190 | - **Distributed KV cache pooling and sharing**: [Mooncake Store extends vLLM](https://vllm.ai/blog/2026-05-06-mooncake-s | CODE |
| MEDIUM | …s/source/deployment/mooncake-store-deployment-guide.md | 123 | The simplest deployment, as shown in [Quick Start](#quick-start). A single `mooncake_master` orchestrates clients over T | CODE |
| MEDIUM | docs/source/performance/vllm/vllm-v1-mooncake-store.md | 11 | ## Speeding up real agentic traces | COMMENT |
| MEDIUM | mooncake-transfer-engine/tent/tests/CMakeLists.txt | 578 | # ProgressWorker skeleton test: covers default-off behavior, event-driven | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/mooncake/mooncake_elastic_buffer.py | 347 | CODE | |
| LOW | python/mooncake/mooncake_elastic_buffer.py | 934 | CODE | |
| LOW | …e-reshard/python/mooncake/reshard/weight/_te/reader.py | 93 | CODE | |
| LOW | …eshard/tests/model_weight_placement_binding/helpers.py | 96 | CODE | |
| LOW | mooncake-reshard/tests/model_weight_planner/helpers.py | 68 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 785 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 818 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 906 | CODE | |
| LOW | mooncake-wheel/mooncake/structured_object_store.py | 932 | CODE | |
| LOW | mooncake-pg/tests/pg_test_utils.py | 190 | CODE | |
| LOW | mooncake-ep/benchmarks/ep_benchmark/metrics.py | 62 | CODE | |
| LOW | benchmarks/storage_benchmark_v1/benchmark.py | 452 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/code_format.sh | 9 | # Usage: | COMMENT |
| LOW | scripts/run_standalone_store_e2e.sh | 4 | # Usage: | COMMENT |