Distributed transactional key-value database, originally created to complement TiDB
This report summarizes scanner evidence for tikv/tikv, a Rust project with 16,931 GitHub stars. SynthScan examined 733,696 lines of code across 1476 source files, recording 972 pattern matches distributed across 17 syntactic categories. The legacy adjusted pattern signal is 2.2 (Low 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.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 877 finding(s).
Are imports declared and package/API names verified? 88 finding(s).
Are wrappers, guards, and repeated structures necessary? 18 finding(s).
Which changes need focused human review? 972 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 972 distinct pattern matches across 17 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 | Cargo.toml | 221 | tempdir = { path = "patches/tempdir" } | COMMENT |
| LOW | deny.toml | 61 | ignore = [ | COMMENT |
| LOW | deny.toml | 81 | # Ignore RUSTSEC-2026-0174, as it does not introduce safety issues, only | COMMENT |
| LOW | deny.toml | 101 | # panics are enabled and `std::panic::catch_unwind` is used with key types | COMMENT |
| LOW | cmd/tikv-ctl/src/cmd.rs | 421 | }, | COMMENT |
| LOW | cmd/tikv-ctl/src/cmd.rs | 541 | /// output file path | COMMENT |
| LOW | cmd/tikv-ctl/src/cmd.rs | 581 | data_dir: String, | COMMENT |
| LOW | cmd/tikv-ctl/src/cmd.rs | 601 | #[clap(long, default_value = "symlink")] | COMMENT |
| LOW | cmd/tikv-ctl/src/cmd.rs | 821 | )] | COMMENT |
| LOW | tests/failpoints/mod.rs | 1 | // Copyright 2017 TiKV Project Authors. Licensed under Apache-2.0. | COMMENT |
| LOW | tests/failpoints/cases/test_snap.rs | 1181 | // k2 (split point) | COMMENT |
| LOW | tests/failpoints/cases/test_hibernate.rs | 361 | rx.recv_timeout(Duration::from_secs(1)).unwrap(), | COMMENT |
| LOW | tests/failpoints/cases/test_conf_change.rs | 201 | cluster.must_put(key, value); | COMMENT |
| LOW | tests/failpoints/cases/test_replica_read.rs | 341 | router.send_raft_message(read_index_msg).unwrap(); | COMMENT |
| LOW | tests/failpoints/cases/test_disk_snap_br.rs | 1 | // Copyright 2023 TiKV Project Authors. Licensed under Apache-2.0. | COMMENT |
| LOW | tests/failpoints/cases/test_in_memory_engine.rs | 321 | COMMENT | |
| LOW | tests/failpoints/cases/test_engine.rs | 61 | // note: before rocksdb/pull/347, lock is called before on_memtable_sealed. | COMMENT |
| LOW | tests/failpoints/cases/test_split_region.rs | 581 | // [k2, +∞) │ │ │ │ │ │ | COMMENT |
| LOW | tests/failpoints/cases/test_split_region.rs | 1441 | fail::remove("on_apply_batch_split"); | COMMENT |
| LOW | tests/failpoints/cases/test_early_apply.rs | 101 | /// between restarting. However, this guarantee can be broken by | COMMENT |
| LOW | tests/failpoints/cases/test_replica_stale_read.rs | 221 | COMMENT | |
| LOW | tests/failpoints/cases/test_replica_stale_read.rs | 381 | // The round now handles the election tick and then the region update; the | COMMENT |
| LOW | tests/failpoints/cases/test_sst_ingest.rs | 21 | use test_raftstore::*; | COMMENT |
| LOW | tests/failpoints/cases/test_storage.rs | 2381 | } | COMMENT |
| LOW | tests/failpoints/cases/test_merge.rs | 761 | pd_client.must_merge(left.get_id(), right.get_id()); | COMMENT |
| LOW | tests/failpoints/cases/test_merge.rs | 961 | // Write data for waiting the merge to rollback easily | COMMENT |
| LOW | tests/failpoints/cases/test_merge.rs | 1841 | // commit merge at the same time before this fix which corrupt the region. | COMMENT |
| LOW | tests/failpoints/cases/test_merge.rs | 2061 | COMMENT | |
| LOW | tests/failpoints/cases/test_stale_read.rs | 261 | assert_ne!(leader1.get_store_id(), leader1000.get_store_id()); | COMMENT |
| LOW | tests/failpoints/cases/test_stale_read.rs | 281 | // Region 1000 F L F | COMMENT |
| LOW | tests/integrations/raftstore/test_snap.rs | 281 | must_get_equal(&cluster.get_engine(3), b"k11", b"v11"); | COMMENT |
| LOW | tests/integrations/raftstore/test_stale_peer.rs | 21 | /// - Peer B gets down. And then A adds D, E, F into the cluster. | COMMENT |
| LOW | tests/integrations/raftstore/test_stale_peer.rs | 101 | let mut cluster = new_server_cluster(0, count); | COMMENT |
| LOW | tests/integrations/raftstore/test_unsafe_recovery.rs | 1381 | assert_eq!(cluster.must_get(b"k4"), Some(b"v4".to_vec())); | COMMENT |
| LOW | tests/integrations/raftstore/test_lease_read.rs | 21 | // A helper function for testing the lease reads and lease renewing. | COMMENT |
| LOW | tests/integrations/raftstore/test_lease_read.rs | 661 | /// 1. Add heartbeat msg filter. | COMMENT |
| LOW | tests/integrations/raftstore/test_bootstrap.rs | 281 | let msg = PeerMsg::FlushBeforeClose { tx }; | COMMENT |
| LOW | tests/integrations/storage/test_titan.rs | 301 | // L5: [delete(a_7)] | COMMENT |
| LOW | tests/integrations/storage/test_storage.rs | 921 | COMMENT | |
| LOW | etc/config-template.toml | 1 | ## TiKV config template | COMMENT |
| LOW | etc/config-template.toml | 21 | ## Use abort when TiKV panic. By default TiKV will use _exit() on panic, in that case | COMMENT |
| LOW | etc/config-template.toml | 41 | ## this threshold, it can squeeze some internal components (e.g. evicting cached Raft entries) | COMMENT |
| LOW | etc/config-template.toml | 61 | # background-read-bandwidth = "0B" | COMMENT |
| LOW | etc/config-template.toml | 81 | ## max log file keep days | COMMENT |
| LOW | etc/config-template.toml | 101 | COMMENT | |
| LOW | etc/config-template.toml | 121 | ## The following configurations only take effect when `use-unified-pool` is false. | COMMENT |
| LOW | etc/config-template.toml | 141 | ## Size of the stack for each thread in the thread pool. | COMMENT |
| LOW | etc/config-template.toml | 161 | # max-tasks-per-worker-normal = 2000 | COMMENT |
| LOW | etc/config-template.toml | 181 | ## overload, and so which ones it throttles and deprioritizes. | COMMENT |
| LOW | etc/config-template.toml | 201 | ## immediately. | COMMENT |
| LOW | etc/config-template.toml | 221 | ## background requests. Use it to stop a large background scan, such as the scan phase of a | COMMENT |
| LOW | etc/config-template.toml | 241 | ## other background reads. Point gets that TiKV merges from a `BatchCommands` stream are | COMMENT |
| LOW | etc/config-template.toml | 261 | ## Listening address. | COMMENT |
| LOW | etc/config-template.toml | 281 | ## Size of the thread pool for the gRPC server. | COMMENT |
| LOW | etc/config-template.toml | 301 | COMMENT | |
| LOW | etc/config-template.toml | 321 | ## By default, it will be set to 12.5% of the available memory of TiKV. | COMMENT |
| LOW | etc/config-template.toml | 341 | ## region thread and other thread of delay-insensitive tasks. | COMMENT |
| LOW | etc/config-template.toml | 361 | ## The number of slots in Scheduler latches, which controls write concurrency. | COMMENT |
| LOW | etc/config-template.toml | 381 | ## `max(reserve-space, capacity * 5%)` will be reserved exactly. | COMMENT |
| LOW | etc/config-template.toml | 401 | ## Set to 0 to disable this feature if you want to panic immediately when encountering such an error. | COMMENT |
| 753 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | components/pd_client/src/client_v2.rs | 499 | let env = self.raw_client.core.context.connector.env.clone(); | CODE |
| CRITICAL⚡ | components/raftstore/src/store/fsm/store.rs | 1147 | self.previous_append = self.poll_ctx.raft_metrics.ready.append.get(); | CODE |
| CRITICAL⚡ | components/raftstore/src/store/fsm/store.rs | 1148 | self.previous_message = self.poll_ctx.raft_metrics.ready.message.get(); | CODE |
| CRITICAL⚡ | components/raftstore/src/store/fsm/store.rs | 1149 | self.previous_snapshot = self.poll_ctx.raft_metrics.ready.snapshot.get(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/store.rs | 2583 | self.ctx.raft_metrics.message_dropped.stale_msg.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/store.rs | 2732 | self.ctx.raft_metrics.message_dropped.region_overlap.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 783 | self.ctx.raft_metrics.message_dropped.step_local_msg.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 949 | self.ctx.raft_metrics.ready.propose_delay.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1036 | target_index: self.fsm.peer.raft_group.raft.raft_log.last_index(), | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1077 | target_index: self.fsm.peer.raft_group.raft.raft_log.last_index(), | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1131 | self.fsm.peer.raft_group.raft.raft_log.last_index() | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1169 | let target_index = self.fsm.peer.raft_group.raft.raft_log.last_index(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1293 | let pending_admin = self.fsm.peer.raft_group.raft.has_pending_conf() | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1866 | self.fsm.peer.raft_group.raft.election_timeout() * 2 | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1872 | } else if self.fsm.peer.raft_group.raft.promotable() | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1887 | self.fsm.peer.raft_group.raft.randomized_election_timeout() | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 1921 | if self.fsm.peer.raft_group.raft.r.raft_log.last_index() | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2008 | self.fsm.peer.raft_group.raft.set_check_quorum(true); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2050 | self.fsm.peer.raft_group.raft.set_check_quorum(false); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2098 | self.fsm.peer.raft_group.raft.set_check_quorum(true); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2100 | if self.fsm.peer.raft_group.raft.promotable() { | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2180 | for (id, vote) in self.fsm.peer.raft_group.raft.prs().votes() { | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2406 | self.ctx.raft_metrics.ready.has_ready_region.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2821 | self.ctx.raft_metrics.propose.unsafe_read_index.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2955 | self.ctx.raft_metrics.message_dropped.disk_full.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 2966 | self.ctx.raft_metrics.message_dropped.non_witness.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3078 | self.ctx.raft_metrics.message_dropped.stale_msg.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3247 | for (peer_id, p) in self.fsm.peer.raft_group.raft.prs().iter() { | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3326 | self.fsm.peer.raft_group.raft.ping(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3534 | self.ctx.raft_metrics.message_dropped.stale_msg.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3563 | None => self.ctx.raft_metrics.message_dropped.applying_snap.inc(), | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3670 | self.ctx.raft_metrics.message_dropped.stale_msg.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3781 | self.ctx.raft_metrics.message_dropped.region_no_peer.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3811 | self.ctx.raft_metrics.message_dropped.stale_msg.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3846 | self.ctx.raft_metrics.message_dropped.region_overlap.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 3909 | self.ctx.raft_metrics.message_dropped.region_overlap.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 4193 | None => self.ctx.raft_metrics.message_dropped.applying_snap.inc(), | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 4559 | if cp.index >= self.fsm.peer.raft_group.raft.raft_log.first_index() { | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 4768 | let mut pessimistic_locks = self.fsm.peer.txn_ext.pessimistic_locks.write(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 5547 | let mut pessimistic_locks = self.fsm.peer.txn_ext.pessimistic_locks.write(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 5670 | self.fsm.peer.raft_group.raft.clear_commit_group(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 5671 | self.fsm.peer.raft_group.raft.assign_commit_groups(gb); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 5842 | let first_index = self.fsm.peer.raft_group.raft.r.raft_log.first_index(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6018 | self.ctx.raft_metrics.invalid_proposal.force_leader.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6048 | self.ctx.raft_metrics.invalid_proposal.not_leader.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6060 | self.ctx.raft_metrics.invalid_proposal.witness.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6077 | self.ctx.raft_metrics.invalid_proposal.witness.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6084 | self.ctx.raft_metrics.invalid_proposal.non_witness.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6113 | self.ctx.raft_metrics.invalid_proposal.stale_command.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6125 | self.ctx.raft_metrics.invalid_proposal.epoch_not_match.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6374 | for (peer_id, p) in self.fsm.peer.raft_group.raft.prs().iter() { | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6438 | self.ctx.raft_metrics.raft_log_gc_skipped.reserve_log.inc(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 6544 | self.fsm.peer.request_index = self.fsm.peer.raft_group.raft.raft_log.last_index(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 7227 | let mut pessimistic_locks = self.fsm.peer.txn_ext.pessimistic_locks.write(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 7238 | let transferring_leader = self.fsm.peer.raft_group.raft.lead_transferee.is_some(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 7497 | let mut pessimistic_locks = self.fsm.peer.txn_ext.pessimistic_locks.write(); | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 7585 | if self.fsm.peer.consistency_state.hash.is_empty() { | CODE |
| CRITICAL | components/raftstore/src/store/fsm/peer.rs | 7613 | && !self.fsm.peer.consistency_state.hash.is_empty() | CODE |
| CRITICAL | components/raftstore-v2/src/operation/query/mod.rs | 91 | self.store_ctx.raft_metrics.propose.local_read.inc(); | CODE |
| CRITICAL | components/server/src/server2.rs | 547 | self.core.config.resource_metering.precision.as_millis(), | CODE |
| 24 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | etc/config-template.toml | 17 | ## Enable io snoop which utilize eBPF to get accurate disk io of TiKV | COMMENT |
| MEDIUM | …mponents/raftstore/src/coprocessor/split_check/keys.rs | 164 | // if bucket checker using scan is added, to utilize the scan, | COMMENT |
| MEDIUM | components/raftstore/src/store/config.rs | 343 | /// from entry cache, if they utilize memory more than | COMMENT |
| MEDIUM | components/raftstore/src/store/fsm/peer.rs | 4644 | // to utilize `collect_pending_peers` in `heartbeat_pd` to avoid | COMMENT |
| MEDIUM | components/snap_recovery/src/data_resolver.rs | 191 | // batch) a more robust test need to figure out what is best. | COMMENT |
| MEDIUM | components/resolved_ts/src/resolver.rs | 97 | // The region read progress used to utilize `resolved_ts` to serve stale read request | COMMENT |
| MEDIUM | components/causal_ts/src/tso.rs | 136 | /// 2. Fully utilize cached TSO when some regions require latest TSO (e.g. in | COMMENT |
| MEDIUM | components/tidb_query_aggr/src/lib.rs | 85 | // However current aggregation executor cannot utilize it. | COMMENT |
| MEDIUM | scripts/check-bins.py | 4 | # utilize sse4.2 extensions. | COMMENT |
| MEDIUM | src/server/config.rs | 248 | /// or dropped, if they utilize memory more than | COMMENT |
| MEDIUM | src/server/gc_worker/compaction_filter.rs | 825 | // won't utilize much CPU. So always perform GC at the bottommost level | COMMENT |
| MEDIUM | src/storage/txn/actions/common.rs | 39 | // Note that the scan can also utilize `last_change`. So once it finds a LOCK | COMMENT |
| MEDIUM | src/storage/mvcc/reader/scanner/backward.rs | 303 | // we don't need to seek any more and we can just utilize `last_version`. | COMMENT |
| MEDIUM | src/storage/raw/store.rs | 24 | // TODO: refactor to utilize generic type `KvFormat` and eliminate matching | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tests/failpoints/cases/test_snap.rs | 1184 | // ───────────────────┼────────────────── | COMMENT |
| MEDIUM⚡ | tests/failpoints/cases/test_split_region.rs | 578 | // ┌───────────┐ ┌───────────┐ ┌───────────┐ | COMMENT |
| MEDIUM⚡ | tests/failpoints/cases/test_split_region.rs | 582 | // ───────────────────┼───────────┼──┼───────────┼──┼───────────┼── | COMMENT |
| MEDIUM⚡ | tests/failpoints/cases/test_split_region.rs | 586 | // └───────────┘ └───────────┘ └───────────┘ | COMMENT |
| MEDIUM⚡ | components/backup-stream/src/metrics.rs | 20 | // ┌─────────┐ ┌────────┐ ┌───────┐ | COMMENT |
| MEDIUM⚡ | components/backup-stream/src/metrics.rs | 21 | // │ RUNNING ├──────► PAUSED ├──────► ERROR │ | COMMENT |
| MEDIUM⚡ | components/backup-stream/src/metrics.rs | 23 | // └───────────────┴───────────────┘ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2473 | // Step 1: T1 acquires an exclusive lock. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2476 | // Step 2: T2 (legacy) tries to acquire an exclusive lock, gets blocked. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2498 | // Step 3: T3 (resumable) tries to acquire an exclusive lock, gets blocked. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2502 | // Step 4: Release T1's exclusive lock. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2507 | // Step 5: T4 acquires a shared lock before T3 resumes. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2511 | // Step 6: Remove the pause to allow delayed wake up, T3 will be woken up | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2516 | // Step 7: Now T3's AcquirePessimisticLockResumed is about to execute. | COMMENT |
| LOW | tests/integrations/server/raft_client.rs | 509 | // Step 1: Send messages to establish connections for stores 1, 2, 3 | COMMENT |
| LOW | tests/integrations/server/raft_client.rs | 534 | // Step 2: Add more stores (4, 5) to test dynamic store detection | COMMENT |
| LOW | src/storage/mvcc/reader/scanner/forward.rs | 233 | // In SI, we need to check if the lock will cause conflict. | COMMENT |
| LOW | src/storage/mvcc/reader/scanner/forward.rs | 251 | // key that does not have a write. In SI, we need to check if the | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2473 | // Step 1: T1 acquires an exclusive lock. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2476 | // Step 2: T2 (legacy) tries to acquire an exclusive lock, gets blocked. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2498 | // Step 3: T3 (resumable) tries to acquire an exclusive lock, gets blocked. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2502 | // Step 4: Release T1's exclusive lock. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2507 | // Step 5: T4 acquires a shared lock before T3 resumes. | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2511 | // Step 6: Remove the pause to allow delayed wake up, T3 will be woken up | COMMENT |
| LOW⚡ | tests/failpoints/cases/test_storage.rs | 2516 | // Step 7: Now T3's AcquirePessimisticLockResumed is about to execute. | COMMENT |
| LOW | tests/integrations/server/raft_client.rs | 509 | // Step 1: Send messages to establish connections for stores 1, 2, 3 | COMMENT |
| LOW | tests/integrations/server/raft_client.rs | 534 | // Step 2: Add more stores (4, 5) to test dynamic store detection | COMMENT |
| LOW | components/raftstore/src/store/fsm/peer.rs | 3992 | // NOTE: This method is used by both the leader and the follower. | COMMENT |
| LOW | …onents/tidb_query_datatype/src/codec/mysql/time/mod.rs | 546 | /// NOTE: This function assumes that `fsp` is in range: [0, 6]. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | components/raftstore-v2/src/worker/pd/split.rs | 169 | // TODO: implement half split | COMMENT |
| LOW | components/tidb_query_datatype/src/codec/datum.rs | 1027 | // TODO: implement datum write here. | COMMENT |
| LOW | components/tidb_query_datatype/src/codec/datum.rs | 1074 | // TODO: implement here after we implement datum write | COMMENT |
| LOW | …ents/tidb_query_datatype/src/codec/data_type/vector.rs | 283 | // TODO: implement here after we implement set encoding | COMMENT |
| LOW | …ents/tidb_query_datatype/src/codec/data_type/vector.rs | 356 | // TODO: implement here after we implement set encoding | COMMENT |
| LOW | …ents/tidb_query_datatype/src/codec/data_type/vector.rs | 473 | // TODO: implement set encoding | COMMENT |
| LOW | src/server/gc_worker/compaction_filter.rs | 84 | //TODO: Add test case to check the correctness of GC_COMPACTION_FAILURE | COMMENT |
| LOW | src/server/gc_worker/compaction_filter.rs | 107 | //TODO: Add test case to check the correctness of GC_COMPACTION_MVCC_ROLLBACK | COMMENT |
| LOW | src/server/gc_worker/compaction_filter.rs | 115 | //TODO: Add test case to check the correctness of GC_COMPACTION_FILTER_ORPHAN_VERSIONS | COMMENT |
| LOW | src/server/gc_worker/compaction_filter.rs | 139 | //TODO: Add test case to check the correctness of GC_COMPACTION_FILTER_MVCC_DELETION_WASTED | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | metrics/grafana/common.py | 1016 | # Fix grafana heatmap migration panic if options is null. | COMMENT |
| HIGH | metrics/grafana/common.py | 1195 | "matcher": {"id": "byName", "options": "Last (not null)"}, | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | metrics/grafana/common.py | 162 | def skip_default_instance_selector(self) -> "Expr": | CODE |
| LOW | metrics/grafana/common.py | 1050 | def graph_panel_histogram_quantiles( | CODE |
| LOW | metrics/grafana/common.py | 1146 | def heatmap_panel_graph_panel_histogram_quantile_pairs( | CODE |
| LOW⚡ | scripts/check-build-opts.py | 67 | def cargo_check_test_engines_ext(kv_engine, raft_engine): | CODE |
| LOW⚡ | scripts/check-build-opts.py | 70 | def cargo_test_test_engines_ext(kv_engine, raft_engine): | CODE |
| LOW⚡ | scripts/check-build-opts.py | 73 | def cargo_run_test_engines_ext(cmd, extra_args, kv_engine, raft_engine): | CODE |
| LOW | scripts/check-bins.py | 95 | def is_openssl_vendored_enabled(features): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …tstore-v2/src/operation/command/admin/merge/prepare.rs | 228 | /// - Target region epoch as requested is identical with the local version. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | etc/config-template.toml | 362 | ## In most cases you can use the default value. When importing data, you can set it to a larger | COMMENT |
| MEDIUM | components/raftstore/src/store/config.rs | 641 | // the log commit duration is less than 1s. Feel free to adjust | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | metrics/grafana/common.py | 757 | CODE | |
| LOW | metrics/grafana/common.py | 815 | CODE | |
| LOW | metrics/grafana/common.py | 847 | CODE | |
| LOW | metrics/grafana/common.py | 901 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | etc/config-template.toml | 383 | ## Set it to 0 will cause no space is reserved at all. It's generally used for tests. | COMMENT |
| LOW | etc/config-template.toml | 389 | ## Set it to 0 will cause no space is reserved at all. It's generally used for tests. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | doc/maintenance-guides/components/server.md | 11 | ### Bootstrap orchestration view | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | metrics/grafana/common.py | 1 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/check-bins.py | 27 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/storage/txn/actions/cleanup.rs | 219 | must_prewrite_put(engine, key, b"dummy_value", key, gc_fence.prev()); | CODE |