AI Slop Code Risk Monitor

oceanbase/oceanbase

SlopCodeMonitor badge for oceanbase/oceanbase Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).

OceanBase is the unified distributed database for the AI era — open-source, multi-model, one engine for your most demanding workloads.

1.5 Low pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

This report summarizes scanner evidence for oceanbase/oceanbase, a C++ project with 10,360 GitHub stars. SynthScan examined 6,582,509 lines of code across 14623 source files, recording 6739 pattern matches distributed across 17 syntactic categories. The legacy adjusted pattern signal is 1.5 (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.

1.5
Adjusted Signal
1.5
Raw Pattern Score
100%
Time Factor
2026-10-31
Last Push
10.4K
Stars
C++
Language
6.6M
Lines of Code
14.6K
Files
6.7K
Pattern Hits
2026-10-31
Scan Date
0.03
HC Hit Rate

Risk Review · Payload v1

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.

Cognitive Ownership Risk 4.5/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 6048 finding(s).

Hallucinated Dependency & Supply Chain Risk 1.4/100 · LOW

Are imports declared and package/API names verified? 287 finding(s).

Agent Over-Engineering Ratio 1.4/100 · LOW

Are wrappers, guards, and repeated structures necessary? 609 finding(s).

PR Review Velocity Impact 7.0/100 · LOW

Which changes need focused human review? 6739 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

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.

Severity Breakdown

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.

CRITICAL 148HIGH 239MEDIUM 152LOW 6200

Directory Score Breakdown

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.

Pattern Findings

The scanner identified 6739 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.

Over-Commented Block5257 hits · 4878 pts
SeverityFileLineSnippetContext
LOWunittest/pl/test_dbms_xmldom.cpp21#ifdef OB_BUILD_ORACLE_PLCOMMENT
LOWunittest/pl/test_pl_utils.h1/**COMMENT
LOWunittest/archive/test_archive_overwrite.cpp1/**COMMENT
LOWunittest/logminer/ob_log_miner_test_utils.h61#endifCOMMENT
LOWunittest/rootserver/test_ls_balance_helper.cpp1/**COMMENT
LOWunittest/rootserver/test_ls_balance_helper.cpp561 }COMMENT
LOWunittest/rootserver/test_freeze_info_manager.cpp1/**COMMENT
LOWunittest/rootserver/test_server_manager.cpp1/**COMMENT
LOWunittest/rootserver/test_server_manager.cpp601// lq.zone_ = "2";COMMENT
LOWunittest/rootserver/test_server_manager.cpp621// ASSERT_EQ(OB_SERVER_ZONE_NOT_MATCH, server_manager_.start_server(lq.server_, "5"));COMMENT
LOWunittest/rootserver/test_server_manager.cpp641//COMMENT
LOWunittest/rootserver/test_server_manager.cpp661// ASSERT_EQ(OB_SERVER_ZONE_NOT_MATCH, server_manager_.delete_server(to_array(lq.server_), not_match_zone));COMMENT
LOWunittest/rootserver/test_server_manager.cpp681// ASSERT_EQ(OB_SERVER_ZONE_NOT_MATCH, server_manager_.delete_server(to_array(lq.server_), not_exist_zone));COMMENT
LOWunittest/rootserver/test_ddl_operator.cpp1/**COMMENT
LOWunittest/rootserver/test_ddl_operator.cpp401 ASSERT_EQ(OB_SUCCESS, schema_guard2.get_table_id(pre_tenant_id_,COMMENT
LOWunittest/rootserver/test_ddl_operator.cpp441 //ASSERT_EQ(OB_SUCCESS, schema_manager->check_database_exist(COMMENT
LOWunittest/rootserver/test_ddl_operator.cpp461 //ObSchemaGetterGuard schema_guard;COMMENT
LOWunittest/rootserver/test_ddl_operator.cpp481 ////schema_manager = multi_schema_service_.get_schema_manager_by_version();COMMENT
LOWunittest/rootserver/test_major_freeze_launcher.cpp1/**COMMENT
LOWunittest/rootserver/test_dump_inner_table_schema.cpp1/**COMMENT
LOWunittest/rootserver/test_zone_manager.cpp1/**COMMENT
LOWunittest/rootserver/test_zone_manager.cpp201COMMENT
LOW…st/rootserver/test_rs_event_history_table_operator.cpp1/**COMMENT
LOWunittest/rootserver/test_alter_table_helper.cpp181 // Even with valid column ops, partition check should make it falseCOMMENT
LOWunittest/rootserver/test_alter_table_helper.cpp741// Fix #5: foreign_key_checks = false (explicit SET foreign_key_checks=0)COMMENT
LOWunittest/rootserver/test_zone_merge_manager.cpp1/**COMMENT
LOWunittest/rootserver/test_zone_merge_manager.cpp101// ASSERT_EQ(OB_SUCCESS, zone_merge_mgr_.reload());COMMENT
LOWunittest/rootserver/test_ob_backup_task_scheduler.cpp1/**COMMENT
LOWunittest/observer/test_inner_sql_result.cpp1/**COMMENT
LOWunittest/observer/net/test_rpc_frame_util.h1/**COMMENT
LOWunittest/observer/net/test_net_thread_count.cpp1/**COMMENT
LOWunittest/storage/test_multiple_multi_scan_merge.cpp1/**COMMENT
LOWunittest/storage/test_tablet_table_store.cpp1/**COMMENT
LOWunittest/storage/test_dml_common.h1/**COMMENT
LOWunittest/storage/test_dml_common.h21#include "share/ob_rpc_struct.h"COMMENT
LOWunittest/storage/test_i_store.cpp101}COMMENT
LOWunittest/storage/schema_utils.h1/**COMMENT
LOWunittest/storage/ob_truncate_info_helper.cpp1// Copyright (c) 2025 OceanBaseCOMMENT
LOW…storage/test_sn_ls_restore_check_tablet_checkpoint.cpp1/**COMMENT
LOWunittest/storage/test_io_manager_v1.cpp1/**COMMENT
LOWunittest/storage/test_io_manager_v1.cpp21#include "lib/thread/thread_pool.h"COMMENT
LOWunittest/storage/test_io_manager_v1.cpp861// {COMMENT
LOWunittest/storage/test_io_manager_v1.cpp881// io_config.unit_config_.weight_ = 100;COMMENT
LOWunittest/storage/test_io_manager_v1.cpp901// ASSERT_NE(nullptr, io_request);COMMENT
LOWunittest/storage/test_tablet_helper.h1/**COMMENT
LOWunittest/storage/test_fts_property.cpp1/**COMMENT
LOWunittest/storage/test_io_manager.cpp1/**COMMENT
LOWunittest/storage/test_io_manager.cpp801 // io manager not init, skip this testCOMMENT
LOWunittest/storage/test_io_manager.cpp841// static void SetUpTestCase()COMMENT
LOWunittest/storage/test_io_manager.cpp861// const uint64_t tenant_id = OB_SERVER_TENANT_ID;COMMENT
LOWunittest/storage/test_io_manager.cpp881// ObRefHolder<ObTenantIOManager> tenant_holder;COMMENT
LOWunittest/storage/test_io_manager.cpp901// void *result_buf = tenant_holder.get_ptr()->io_allocator_.alloc(sizeof(ObIOResult));COMMENT
LOWunittest/storage/mock_ob_tenant_storage.h1/**COMMENT
LOWunittest/storage/test_fts_plugin.cpp1/**COMMENT
LOWunittest/storage/test_fts_plugin.cpp301// public:COMMENT
LOWunittest/storage/test_fts_plugin.cpp321// cs_(nullptr),COMMENT
LOWunittest/storage/test_fts_plugin.cpp341//{COMMENT
LOWunittest/storage/test_fts_plugin.cpp361// ASSERT_TRUE(nullptr != plugin->desc_);COMMENT
LOWunittest/storage/test_fts_plugin.cpp381// int64_t size = -1;COMMENT
LOWunittest/storage/test_fts_plugin.cpp401//COMMENT
5197 more matches not shown…
Hallucination Indicators148 hits · 1640 pts
SeverityFileLineSnippetContext
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1003 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1011 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1019 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1026 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 4);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1067 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1074 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1081 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1087 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1094 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1100 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1140 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1149 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1155 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1162 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1168 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1212 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1222 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1228 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1236 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1242 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1249 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1255 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1299 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1309 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1315 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1323 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1329 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1336 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1342 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 2);CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1639 EXPECT_FALSE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2));CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1646 EXPECT_FALSE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2));CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1652 EXPECT_FALSE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2));CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1660 EXPECT_TRUE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2));CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1665 EXPECT_TRUE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2));CODE
CRITICAL⚡unittest/logservice/test_log_config_mgr.cpp1672 EXPECT_TRUE(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(addr2));CODE
CRITICALunittest/logservice/test_log_config_mgr.cpp1043 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICALunittest/logservice/test_log_config_mgr.cpp1050 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 1);CODE
CRITICALunittest/logservice/test_log_config_mgr.cpp1117 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3);CODE
CRITICALunittest/logservice/test_log_config_mgr.cpp1124 EXPECT_EQ(cm.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number(), 3);CODE
CRITICALunittest/logservice/test_log_config_mgr.cpp1372 EXPECT_EQ(OB_SUCCESS, cm.log_ms_meta_.curr_.config_.learnerlist_.add_learner(ObMember(addr4, -1)));CODE
CRITICALunittest/logservice/test_log_config_mgr.cpp2062 EXPECT_EQ(OB_SUCCESS, cm.log_ms_meta_.curr_.config_.learnerlist_.add_server(ObAddr(ip_type, addr_str, port - i)));CODE
CRITICAL⚡unittest/logservice/test_log_meta.cpp169 log_meta1.log_config_meta_.curr_.config_.log_sync_memberlist_.add_member(ObMember(ObAddr(ip_type, addr_str, port - iCODE
CRITICAL⚡unittest/logservice/test_log_meta.cpp170 log_meta1.log_config_meta_.prev_.config_.log_sync_memberlist_.add_member(ObMember(ObAddr(ip_type, addr_str, port - iCODE
CRITICAL⚡unittest/logservice/test_log_meta.cpp177 log_meta1.log_config_meta_.curr_.config_.learnerlist_.add_server(ObAddr(ip_type, addr_str, port - i));CODE
CRITICALmittest/logservice/test_ob_simple_log_arb.cpp680 EXPECT_FALSE(palf_list[leader_idx]->get_palf_handle_impl()->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlistCODE
CRITICALmittest/logservice/test_ob_simple_log_arb.cpp681 EXPECT_TRUE(palf_list[another_f_idx]->get_palf_handle_impl()->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberliCODE
CRITICALmittest/logservice/test_ob_simple_log_arb.cpp811 EXPECT_EQ(2, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.get_member_number()CODE
CRITICALmittest/logservice/test_ob_simple_log_disk_hang.cpp365 EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_memCODE
CRITICALmittest/logservice/test_ob_simple_log_disk_hang.cpp370 EXPECT_UNTIL_EQ(0, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_memberCODE
CRITICALmittest/logservice/test_ob_simple_log_disk_hang.cpp382 EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_memCODE
CRITICALmittest/logservice/test_ob_simple_log_disk_hang.cpp447 EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_memCODE
CRITICALmittest/logservice/test_ob_simple_log_disk_hang.cpp456 EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_memCODE
CRITICALmittest/logservice/test_ob_simple_log_disk_hang.cpp469 EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_memCODE
CRITICALmittest/logservice/test_ob_simple_log_disk_hang.cpp478 EXPECT_UNTIL_EQ(true, leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.degraded_learnerlist_.get_memCODE
CRITICALmittest/logservice/test_ob_simple_log_arb_mock_ele.cpp107 EXPECT_FALSE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr))CODE
CRITICALmittest/logservice/test_ob_simple_log_arb_mock_ele.cpp108 EXPECT_TRUE(b_handle->palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addrCODE
CRITICALmittest/logservice/test_ob_simple_log_arb_mock_ele.cpp131 EXPECT_FALSE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr))CODE
CRITICALmittest/logservice/test_ob_simple_log_arb_mock_ele.cpp170 EXPECT_TRUE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr));CODE
CRITICALmittest/logservice/test_ob_simple_log_arb_mock_ele.cpp221 EXPECT_FALSE(leader.palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addr))CODE
CRITICALmittest/logservice/test_ob_simple_log_arb_mock_ele.cpp222 EXPECT_TRUE(b_handle->palf_handle_impl_->config_mgr_.log_ms_meta_.curr_.config_.log_sync_memberlist_.contains(b_addrCODE
88 more matches not shown…
Cross-File Repetition224 hits · 1120 pts
SeverityFileLineSnippetContext
HIGHtools/upgrade/upgrade_pre.py0select distinct value from oceanbase.gv$ob_parameters where name='min_observer_version'STRING
HIGHtools/upgrade/actions.py0select distinct value from oceanbase.gv$ob_parameters where name='min_observer_version'STRING
HIGHtools/upgrade/upgrade_post.py0select distinct value from oceanbase.gv$ob_parameters where name='min_observer_version'STRING
HIGHtools/upgrade/upgrade_pre.py0select value from oceanbase.__all_sys_parameter where name = 'enable_ddl'STRING
HIGHtools/upgrade/actions.py0select value from oceanbase.__all_sys_parameter where name = 'enable_ddl'STRING
HIGHtools/upgrade/upgrade_post.py0select value from oceanbase.__all_sys_parameter where name = 'enable_ddl'STRING
HIGHtools/upgrade/upgrade_pre.py0select distinct(substring_index(build_version, '_', 1)) from __all_serverSTRING
HIGHtools/upgrade/upgrade_checker.py0select distinct(substring_index(build_version, '_', 1)) from __all_serverSTRING
HIGHtools/upgrade/actions.py0select distinct(substring_index(build_version, '_', 1)) from __all_serverSTRING
HIGHtools/upgrade/upgrade_post.py0select distinct(substring_index(build_version, '_', 1)) from __all_serverSTRING
HIGHtools/upgrade/upgrade_pre.py0select * from oceanbase.{0} where name = '{1}' and value = '{2}'STRING
HIGHtools/upgrade/upgrade_post.py0select * from oceanbase.{0} where name = '{1}' and value = '{2}'STRING
HIGHtools/upgrade/actions.py0select * from oceanbase.{0} where name = '{1}' and value = '{2}'STRING
HIGHtools/upgrade/upgrade_pre.py0select count(*) as cnt from oceanbase.{0} where name = '{1}' and value != '{2}'{3}STRING
HIGHtools/upgrade/upgrade_post.py0select count(*) as cnt from oceanbase.{0} where name = '{1}' and value != '{2}'{3}STRING
HIGHtools/upgrade/actions.py0select count(*) as cnt from oceanbase.{0} where name = '{1}' and value != '{2}'{3}STRING
HIGHtools/upgrade/upgrade_pre.py0select distinct value from __all_virtual_sys_parameter_stat where name='min_observer_version'STRING
HIGHtools/upgrade/actions.py0select distinct value from __all_virtual_sys_parameter_stat where name='min_observer_version'STRING
HIGHtools/upgrade/upgrade_post.py0select distinct value from __all_virtual_sys_parameter_stat where name='min_observer_version'STRING
HIGHtools/upgrade/upgrade_pre.py0select distinct tenant_id from oceanbase.__all_tenant order by tenant_id descSTRING
HIGHtools/upgrade/actions.py0select distinct tenant_id from oceanbase.__all_tenant order by tenant_id descSTRING
HIGHtools/upgrade/upgrade_health_checker.py0select distinct tenant_id from oceanbase.__all_tenant order by tenant_id descSTRING
HIGHtools/upgrade/upgrade_post.py0select distinct tenant_id from oceanbase.__all_tenant order by tenant_id descSTRING
HIGHtools/upgrade/upgrade_pre.py0select svr_ip, svr_port, value from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level'STRING
HIGHtools/upgrade/upgrade_post.py0select svr_ip, svr_port, value from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level'STRING
HIGHtools/upgrade/tenant_upgrade_action.py0select svr_ip, svr_port, value from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level'STRING
HIGHtools/upgrade/upgrade_pre.py0select count(*) cnt from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' and value = 'info'STRING
HIGHtools/upgrade/upgrade_post.py0select count(*) cnt from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' and value = 'info'STRING
HIGHtools/upgrade/tenant_upgrade_action.py0select count(*) cnt from oceanbase.__all_virtual_sys_parameter_stat where name = 'syslog_level' and value = 'info'STRING
HIGHtools/upgrade/upgrade_pre.py0select job_status from oceanbase.__all_rootservice_job where job_type = '{0}' order by job_id desc limit 1STRING
HIGHtools/upgrade/upgrade_post.py0select job_status from oceanbase.__all_rootservice_job where job_type = '{0}' order by job_id desc limit 1STRING
HIGHtools/upgrade/tenant_upgrade_action.py0select job_status from oceanbase.__all_rootservice_job where job_type = '{0}' order by job_id desc limit 1STRING
HIGHtools/upgrade/upgrade_pre.py0select job_status, rs_svr_ip, rs_svr_port, gmt_create from oceanbase.__all_rootservice_job where job_type = '{0}' and joSTRING
HIGHtools/upgrade/upgrade_post.py0select job_status, rs_svr_ip, rs_svr_port, gmt_create from oceanbase.__all_rootservice_job where job_type = '{0}' and joSTRING
HIGHtools/upgrade/tenant_upgrade_action.py0select job_status, rs_svr_ip, rs_svr_port, gmt_create from oceanbase.__all_rootservice_job where job_type = '{0}' and joSTRING
HIGHtools/upgrade/upgrade_pre.py0select count(*) from oceanbase.__all_virtual_core_meta_table where role = 1 and svr_ip = '{0}' and svr_port = {1}STRING
HIGHtools/upgrade/upgrade_post.py0select count(*) from oceanbase.__all_virtual_core_meta_table where role = 1 and svr_ip = '{0}' and svr_port = {1}STRING
HIGHtools/upgrade/tenant_upgrade_action.py0select count(*) from oceanbase.__all_virtual_core_meta_table where role = 1 and svr_ip = '{0}' and svr_port = {1}STRING
HIGHtools/upgrade/upgrade_pre.py0select count(*) from oceanbase.__all_rootservice_event_history where gmt_create > '{0}' and event = 'full_rootservice'STRING
HIGHtools/upgrade/upgrade_post.py0select count(*) from oceanbase.__all_rootservice_event_history where gmt_create > '{0}' and event = 'full_rootservice'STRING
HIGHtools/upgrade/tenant_upgrade_action.py0select count(*) from oceanbase.__all_rootservice_event_history where gmt_create > '{0}' and event = 'full_rootservice'STRING
HIGHtools/upgrade/upgrade_pre.py0select count(*) as cnt from oceanbase.__all_virtual_sys_parameter_stat where name = '{0}' and value != '{1}'STRING
HIGHtools/upgrade/upgrade_post.py0select count(*) as cnt from oceanbase.__all_virtual_sys_parameter_stat where name = '{0}' and value != '{1}'STRING
HIGHtools/upgrade/upgrade_checker.py0select count(*) as cnt from oceanbase.__all_virtual_sys_parameter_stat where name = '{0}' and value != '{1}'STRING
HIGHtools/upgrade/upgrade_pre.py0select distinct value from gv$ob_parameters where name='min_observer_version'STRING
HIGHtools/upgrade/upgrade_checker.py0select distinct value from gv$ob_parameters where name='min_observer_version'STRING
HIGHtools/upgrade/upgrade_post.py0select distinct value from gv$ob_parameters where name='min_observer_version'STRING
HIGHtools/upgrade/upgrade_pre.py0select distinct value from oceanbase.__all_virtual_tenant_parameter_info where name='compatible'STRING
HIGHtools/upgrade/upgrade_checker.py0select distinct value from oceanbase.__all_virtual_tenant_parameter_info where name='compatible'STRING
HIGHtools/upgrade/upgrade_post.py0select distinct value from oceanbase.__all_virtual_tenant_parameter_info where name='compatible'STRING
HIGHtools/upgrade/upgrade_pre.py0select count(1) as unsync_cnt from gv$ob_log_stat where in_sync = 'no'STRING
HIGHtools/upgrade/upgrade_checker.py0select count(1) as unsync_cnt from gv$ob_log_stat where in_sync = 'no'STRING
HIGHtools/upgrade/upgrade_post.py0select count(1) as unsync_cnt from gv$ob_log_stat where in_sync = 'no'STRING
HIGHtools/upgrade/upgrade_pre.py0select count(1) as cnt from dba_ob_tenant_jobs where job_status='inprogress' and result_code is nullSTRING
HIGHtools/upgrade/upgrade_checker.py0select count(1) as cnt from dba_ob_tenant_jobs where job_status='inprogress' and result_code is nullSTRING
HIGHtools/upgrade/upgrade_post.py0select count(1) as cnt from dba_ob_tenant_jobs where job_status='inprogress' and result_code is nullSTRING
HIGHtools/upgrade/upgrade_pre.py0select count(1) as rebalance_task_cnt from cdb_ob_ls_replica_tasksSTRING
HIGHtools/upgrade/upgrade_checker.py0select count(1) as rebalance_task_cnt from cdb_ob_ls_replica_tasksSTRING
HIGHtools/upgrade/upgrade_post.py0select count(1) as rebalance_task_cnt from cdb_ob_ls_replica_tasksSTRING
HIGHtools/upgrade/upgrade_pre.py0select count(1) from cdb_ob_major_compaction where (global_broadcast_scn > last_scn or status != 'idle')STRING
164 more matches not shown…
Decorative Section Separators114 hits · 482 pts
SeverityFileLineSnippetContext
MEDIUM⚡…est/storage/multi_data_source/test_mds_table_flush.cpp93// ┌──────────┐ │ ┌──────────┐ ┌──COMMENT
MEDIUM⚡…est/storage/multi_data_source/test_mds_table_flush.cpp94// MdsUnit<DummyKey, ExampleUserData1> │(MAX, 500]│◄─┼──────────────────────┤[300, 250]│◄──────────────────────────┤(1COMMENT
MEDIUM⚡…est/storage/multi_data_source/test_mds_table_flush.cpp95// └──────────┘ │ └──────────┘ └──COMMENT
MEDIUM⚡…est/storage/multi_data_source/test_mds_table_flush.cpp100// │ ┌──────────┐ ┌──────────┐COMMENT
MEDIUM⚡…est/storage/multi_data_source/test_mds_table_flush.cpp101// MdsUnit<DummyKey, ExampleUserData2> │ │[400, 350]│◄──────────────────────────┤[225, 200]│COMMENT
MEDIUM⚡…est/storage/multi_data_source/test_mds_table_flush.cpp102// │ └──────────┘ └──────────┘COMMENT
MEDIUMdeps/oblib/src/lib/compress/zstd_1_3_8/CMakeLists.txt1# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/zstd_1_3_8/CMakeLists.txt3# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/lz4/CMakeLists.txt1# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/lz4/CMakeLists.txt3# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/zstd_1_5_7/CMakeLists.txt1# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/zstd_1_5_7/CMakeLists.txt3# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/snappy/CMakeLists.txt1# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/snappy/CMakeLists.txt3# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/zstd/CMakeLists.txt1# ============================================================COMMENT
MEDIUMdeps/oblib/src/lib/compress/zstd/CMakeLists.txt3# ============================================================COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h6// ┌─────────────┐Upgrade ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h7// │ObUniqueGuard├───────►│ObSharedGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h8// └─────────────┘ └──▲──────┬───┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h12// ┌─┴──────▼──┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h14// └───────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h16// ┌─────────────┐ Transfer Ownership ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h17// │ObUniqueGuard│◄──────────────────►│ObUniqueGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h18// └─────────────┘ └─────────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h20// ┌─────────────┐ Share Ownership ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h21// │ObSharedGuard│◄───────────────►│ObSharedGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h22// └─────────────┘ └─────────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h24// ┌───────────┐ Observe the same object ┌───────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h25// │ObWeakGuard│◄───────────────────────►│ObWeakGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_unique_guard.h26// └───────────┘ └───────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h6// ┌─────────────┐Upgrade ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h7// │ObUniqueGuard├───────►│ObSharedGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h8// └─────────────┘ └──▲──────┬───┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h12// ┌─┴──────▼──┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h14// └───────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h16// ┌─────────────┐ Transfer Ownership ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h17// │ObUniqueGuard│◄──────────────────►│ObUniqueGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h18// └─────────────┘ └─────────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h20// ┌─────────────┐ Share Ownership ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h21// │ObSharedGuard│◄───────────────►│ObSharedGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h22// └─────────────┘ └─────────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h24// ┌───────────┐ Observe the same object ┌───────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h25// │ObWeakGuard│◄───────────────────────►│ObWeakGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_shared_guard.h26// └───────────┘ └───────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h6// ┌─────────────┐Upgrade ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h7// │ObUniqueGuard├───────►│ObSharedGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h8// └─────────────┘ └──▲──────┬───┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h12// ┌─┴──────▼──┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h14// └───────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h16// ┌─────────────┐ Transfer Ownership ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h17// │ObUniqueGuard│◄──────────────────►│ObUniqueGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h18// └─────────────┘ └─────────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h20// ┌─────────────┐ Share Ownership ┌─────────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h21// │ObSharedGuard│◄───────────────►│ObSharedGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h22// └─────────────┘ └─────────────┘COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h24// ┌───────────┐ Observe the same object ┌───────────┐COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h25// │ObWeakGuard│◄───────────────────────►│ObWeakGuard│COMMENT
MEDIUM⚡deps/oblib/src/lib/guard/ob_weak_guard.h26// └───────────┘ └───────────┘COMMENT
MEDIUM⚡src/storage/ob_partition_range_spliter.cpp293 // ──────────────────────────────COMMENT
MEDIUM⚡src/storage/ob_partition_range_spliter.cpp298 // Info 2: split_rowkey────────────┘ │COMMENT
54 more matches not shown…
Verbosity Indicators265 hits · 455 pts
SeverityFileLineSnippetContext
LOWunittest/storage/test_storage_schema.cpp420 // Step 1: Build a base table schema with virtual columnsCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp446 // Step 2: Init storage schema from base table schemaCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp454 // Step 3: Simulate update_column_cnt_and_schema_version from memtableCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp459 // Step 4: Build the new table schema with one more stored column (DDL add column)COMMENT
LOW⚡unittest/storage/test_storage_schema.cpp480 // Step 5: Call update_column_info — this is the function under testCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp484 // Step 6: Verify the fixCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1323 // Step 1: B and C join RTO groupCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1354 // Step 2: B out (timeout/stale)COMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1384 // Step 3: B in, C outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1414 // Step 4: B outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1440 // Step 5: B, C inCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1489 // Step 6: A, C join RTO groupCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1522 // Step 7: C outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1552 // Step 8: C in, A outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1582 // Step 9: C outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1607 // Step 10: A, C inCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp402 // Step 1: B and C join RTO groupCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp417 // Step 2: B out (timeout/stale)COMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp433 // Step 3: B in, C outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp449 // Step 4: B outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp460 // Step 5: B, C inCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp490 // Step 6: A, C join RTO groupCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp506 // Step 7: C outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp522 // Step 8: C in, A outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp538 // Step 9: C outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp549 // Step 10: A, C inCOMMENT
LOW…t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp927 // Step 1: 解析 authentication_string,得到 salt、rounds、hashCOMMENT
LOW…t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp941 // Step 2: OB 生成 hashCOMMENT
LOW…t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp953 // Step 3: 提取 digest 做对比COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h190 // Step 1: Collect sort key expressions (sk_exprs_) from ORDER BYCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h302 // Step 2: Collect child output expressions (column expressions from table)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h316 // Step 3: Append child output columns, mirroring append_child_output_no_dup().COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h348 // Step 4: Initialize spec arraysCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h371 // Step 5: Set output_ to sk_exprs_ + addon_exprs_ (what sort operator actually outputs)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h389 // Step 6: Add sk_exprs to calc_exprs_ so they get cleared between batchesCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h405 // Step 7: Decide SingleColCompare optimization, mirroring CGCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h209 // Step 1: Allocate specCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h217 // Step 2: Set basic fieldsCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h225 // Step 3: Set children pointerCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h239 // Step 4: Extract equal conditions from ON clauseCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h290 // Step 5: Initialize equal_cond_infos_COMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h298 // Step 6: Initialize left/right_child_fetcher_all_exprs_COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h314 // Step 7: Append left/right child output to fetcher_all_exprsCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h326 // Step 8: Process each equal conditionCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h473 // Step 9: Set merge_directions_ matching the sort order of input dataCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h231 // Step 1: Create MockDtlChannelCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h241 // Step 2: Configure ObPxSqcMeta with minimal settingsCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_datahub.h257 // Step 3: Create ObPxSubCoord using placement newCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h270 // Step 4: Initialize sqc_proxy_'s msg_ready_cond_ to avoid blocking in wait_whole_msgCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h279 // Step 5: Create ObPxSqcHandlerCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_datahub.h292 // Step 6: Register sqc_handler with exec_ctxCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h779 // Step 1: Get OpInput (calls create_input which may be overridden)COMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h782 // Step 2: Allocate operatorCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h790 // Step 3: Set children pointerCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h1349 // Step 1: Register mock table schemaCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h1356 // Step 2: Build SQL stringCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h1359 // Step 3: Resolve SQLCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_base.h1324 // Step 0: Set SQL mode (must be set before init)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_base.h1419 // Step 4: Generate expressions via CG (frame layout follows expr_cg_rich_format_)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_base.h1600 // Step 6: Collect LIMIT/OFFSET exprsCOMMENT
205 more matches not shown…
Structural Annotation Overuse260 hits · 447 pts
SeverityFileLineSnippetContext
LOWunittest/storage/test_storage_schema.cpp420 // Step 1: Build a base table schema with virtual columnsCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp446 // Step 2: Init storage schema from base table schemaCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp454 // Step 3: Simulate update_column_cnt_and_schema_version from memtableCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp459 // Step 4: Build the new table schema with one more stored column (DDL add column)COMMENT
LOW⚡unittest/storage/test_storage_schema.cpp480 // Step 5: Call update_column_info — this is the function under testCOMMENT
LOW⚡unittest/storage/test_storage_schema.cpp484 // Step 6: Verify the fixCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1323 // Step 1: B and C join RTO groupCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1354 // Step 2: B out (timeout/stale)COMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1384 // Step 3: B in, C outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1414 // Step 4: B outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1440 // Step 5: B, C inCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1489 // Step 6: A, C join RTO groupCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1522 // Step 7: C outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1552 // Step 8: C in, A outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1582 // Step 9: C outCOMMENT
LOW…est/logservice/test_ob_log_submit_log_rate_limiter.cpp1607 // Step 10: A, C inCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp402 // Step 1: B and C join RTO groupCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp417 // Step 2: B out (timeout/stale)COMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp433 // Step 3: B in, C outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp449 // Step 4: B outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp460 // Step 5: B, C inCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp490 // Step 6: A, C join RTO groupCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp506 // Step 7: C outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp522 // Step 8: C in, A outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp538 // Step 9: C outCOMMENT
LOW…ittest/logservice/test_ob_log_replay_process_cache.cpp549 // Step 10: A, C inCOMMENT
LOW…t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp927 // Step 1: 解析 authentication_string,得到 salt、rounds、hashCOMMENT
LOW…t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp941 // Step 2: OB 生成 hashCOMMENT
LOW…t/sql/encryption/test_ob_sha256_crypt_mysql_compat.cpp953 // Step 3: 提取 digest 做对比COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h190 // Step 1: Collect sort key expressions (sk_exprs_) from ORDER BYCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h302 // Step 2: Collect child output expressions (column expressions from table)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h316 // Step 3: Append child output columns, mirroring append_child_output_no_dup().COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h348 // Step 4: Initialize spec arraysCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h371 // Step 5: Set output_ to sk_exprs_ + addon_exprs_ (what sort operator actually outputs)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h389 // Step 6: Add sk_exprs to calc_exprs_ so they get cleared between batchesCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_sort.h405 // Step 7: Decide SingleColCompare optimization, mirroring CGCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h209 // Step 1: Allocate specCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h217 // Step 2: Set basic fieldsCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h225 // Step 3: Set children pointerCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h239 // Step 4: Extract equal conditions from ON clauseCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h290 // Step 5: Initialize equal_cond_infos_COMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_merge_join.h298 // Step 6: Initialize left/right_child_fetcher_all_exprs_COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h314 // Step 7: Append left/right child output to fetcher_all_exprsCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h326 // Step 8: Process each equal conditionCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_merge_join.h473 // Step 9: Set merge_directions_ matching the sort order of input dataCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h231 // Step 1: Create MockDtlChannelCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h241 // Step 2: Configure ObPxSqcMeta with minimal settingsCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_datahub.h257 // Step 3: Create ObPxSubCoord using placement newCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h270 // Step 4: Initialize sqc_proxy_'s msg_ready_cond_ to avoid blocking in wait_whole_msgCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_datahub.h279 // Step 5: Create ObPxSqcHandlerCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_datahub.h292 // Step 6: Register sqc_handler with exec_ctxCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h779 // Step 1: Get OpInput (calls create_input which may be overridden)COMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h782 // Step 2: Allocate operatorCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h790 // Step 3: Set children pointerCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h1349 // Step 1: Register mock table schemaCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h1356 // Step 2: Build SQL stringCOMMENT
LOW⚡unittest/sql/engine/op_tests/ob_op_test_base.h1359 // Step 3: Resolve SQLCOMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_base.h1324 // Step 0: Set SQL mode (must be set before init)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_base.h1419 // Step 4: Generate expressions via CG (frame layout follows expr_cg_rich_format_)COMMENT
LOWunittest/sql/engine/op_tests/ob_op_test_base.h1600 // Step 6: Collect LIMIT/OFFSET exprsCOMMENT
200 more matches not shown…
Hyper-Verbose Identifiers203 hits · 201 pts
SeverityFileLineSnippetContext
LOWreplace_license.py72def replace_doubleslash_comments(content):CODE
LOWunittest/sql/optimizer/cost_model_utils/plot_multi.py13def extract_int_info_from_line(line):CODE
LOW…ttest/sql/optimizer/cost_model_utils/plot_demension.py14def extract_int_info_from_line(line):CODE
LOWunittest/sql/optimizer/storage_perf/plot_multi.py13def extract_int_info_from_line(line):CODE
LOWunittest/sql/optimizer/storage_perf/plot_demension.py14def extract_int_info_from_line(line):CODE
LOWunittest/sql/external_table/gen_parquet_test_data.py40def gen_bloom_filter_smoking_test(spark, tmp_dir, table_name, mysql_test_name=None):CODE
LOWunittest/sql/external_table/gen_parquet_test_data.py59def gen_bloom_filter_all_numerics(spark, tmp_dir, table_name):CODE
LOWunittest/sql/external_table/gen_parquet_test_data.py94def gen_bloom_filter_all_other_types(spark, tmp_dir, table_name):CODE
LOWunittest/sql/external_table/gen_parquet_test_data.py131def gen_multi_stripes_with_simple_types(spark, tmp_dir, table_name):CODE
LOWunittest/sql/external_table/gen_orc_test_data.py39def gen_bloom_filter_smoking_test(spark, tmp_dir, table_name):CODE
LOWunittest/sql/external_table/gen_orc_test_data.py55def gen_bloom_filter_all_numerics(spark, tmp_dir, table_name):CODE
LOWunittest/sql/external_table/gen_orc_test_data.py88def gen_bloom_filter_all_other_types(spark, tmp_dir, table_name):CODE
LOWunittest/sql/external_table/gen_orc_test_data.py121def gen_multi_stripes_with_simple_types(spark, tmp_dir, table_name):CODE
LOW⚡tools/upgrade/upgrade_pre.py2352#def check_not_supported_tenant_name(query_cur):COMMENT
LOW⚡tools/upgrade/upgrade_pre.py2361#def check_log_transport_compress_func(query_cur):COMMENT
LOW⚡tools/upgrade/upgrade_pre.py2367#def check_table_compress_func(query_cur):COMMENT
LOW⚡tools/upgrade/upgrade_pre.py2373#def check_table_api_transport_compress_func(query_cur):COMMENT
LOW⚡tools/upgrade/upgrade_pre.py2380#def check_tenant_clone_job_exist(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py35#def get_current_cluster_version():COMMENT
LOWtools/upgrade/upgrade_pre.py66#def get_rollback_sql_file_lines_str():COMMENT
LOWtools/upgrade/upgrade_pre.py78#def dump_rollback_sql_to_file(rollback_sql_filename):COMMENT
LOWtools/upgrade/upgrade_pre.py139#def set_default_timeout_by_tenant(cur, timeout, timeout_per_tenant, min_timeout):COMMENT
LOWtools/upgrade/upgrade_pre.py232#def check_server_version_by_cluster(cur):COMMENT
LOWtools/upgrade/upgrade_pre.py983#def set_session_timeout_for_upgrade(cur, time):COMMENT
LOWtools/upgrade/upgrade_pre.py1293#def regenerate_upgrade_script():COMMENT
LOWtools/upgrade/upgrade_pre.py1576#def check_can_run_upgrade_job(cur, job_name):COMMENT
LOWtools/upgrade/upgrade_pre.py2208#def check_is_primary_zone_distributed(primary_zone_str):COMMENT
LOWtools/upgrade/upgrade_pre.py2225#def check_tenant_primary_zone(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2244#def modify_server_permanent_offline_time(cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2400#def check_tenant_snapshot_task_exist(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2420#def check_variable_binlog_row_image(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2440#def check_oracle_standby_replication_exist(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2479#def check_disk_space_for_mds_sstable_compat(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2498#def do_check_disk_space_for_compat(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2591#def get_max_extension_support():COMMENT
LOWtools/upgrade/upgrade_pre.py2626#def check_direct_load_job_exist(cur, query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2634#def check_enable_logonly_replica(cur, query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2645#def check_cs_encoding_arch_dependency_compatiblity(query_cur, cpu_arch):COMMENT
LOWtools/upgrade/upgrade_pre.py2715#def check_cos_archive_and_backup(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py2786#def check_vector_index_exist_on_column_table(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py3245#def set_default_timeout_by_tenant(query_cur, timeout, timeout_per_tenant, min_timeout):COMMENT
LOWtools/upgrade/upgrade_pre.py3261#def check_server_version_by_zone(query_cur, zone):COMMENT
LOWtools/upgrade/upgrade_pre.py3360#def check_cluster_version_for_vector_index(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py3395#def query_vector_index_info_all(query_cur, valid_tablets):COMMENT
LOWtools/upgrade/upgrade_pre.py3404#def query_valid_vector_index_tablets(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py3437#def filter_valid_vector_index_tablets(results, valid_tablets):COMMENT
LOWtools/upgrade/upgrade_pre.py3488#def get_expected_replica_count(query_cur):COMMENT
LOWtools/upgrade/upgrade_pre.py3523#def group_by_tenant_and_tablet(results):COMMENT
LOWtools/upgrade/upgrade_pre.py3556#def calc_vector_index_wait_seconds(replicas):COMMENT
LOWtools/upgrade/upgrade_pre.py3565#def check_tenant_hnsw_index_loaded(tenant_id, tablets, incr_history, tenant_ls_replica_count):COMMENT
LOWtools/upgrade/upgrade_pre.py3773#def get_vector_index_loaded_count(tenant_stats):COMMENT
LOWtools/upgrade/upgrade_pre.py3779#def get_vector_index_status_signature(tenant_stats):COMMENT
LOWtools/upgrade/upgrade_pre.py3794#def check_vector_index_loaded(query_cur, zone, timeout):COMMENT
LOWtools/upgrade/upgrade_pre.py3875#def check_vector_index_loaded_one_round(grouped, tenant_expected_replica_count, incr_history, current_round, max_round)COMMENT
LOWtools/upgrade/reset_upgrade_scripts.py30def regenerate_upgrade_script():CODE
LOW⚡tools/upgrade/upgrade_checker.py658def check_not_supported_tenant_name(query_cur):CODE
LOW⚡tools/upgrade/upgrade_checker.py667def check_log_transport_compress_func(query_cur):CODE
LOW⚡tools/upgrade/upgrade_checker.py673def check_table_compress_func(query_cur):CODE
LOW⚡tools/upgrade/upgrade_checker.py679def check_table_api_transport_compress_func(query_cur):CODE
LOW⚡tools/upgrade/upgrade_checker.py686def check_tenant_clone_job_exist(query_cur):CODE
143 more matches not shown…
Excessive Try-Catch Wrapping65 hits · 86 pts
SeverityFileLineSnippetContext
MEDIUMtools/upgrade/upgrade_checker.py39def exec_sql(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/upgrade_checker.py52def exec_query(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/upgrade_checker.py1155def do_check(my_host, my_port, my_user, my_passwd, timeout, upgrade_params, cpu_CODE
LOWtools/upgrade/upgrade_checker.py49 except Exception as e:CODE
LOWtools/upgrade/upgrade_checker.py63 except Exception as e:CODE
LOWtools/upgrade/upgrade_checker.py1201 except Exception as e:STRING
LOWtools/upgrade/upgrade_checker.py1210 except Exception as e:STRING
LOWtools/upgrade/upgrade_checker.py1239 except Exception as e:STRING
MEDIUMtools/upgrade/actions.py386def exec_sql(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/actions.py399def exec_query(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/actions.py418def exec_ddl(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/actions.py431def exec_query(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/actions.py441def exec_update(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/actions.py551def fetch_tenant_ids(query_cur):CODE
LOWtools/upgrade/actions.py396 except Exception as e:CODE
LOWtools/upgrade/actions.py410 except Exception as e:CODE
LOWtools/upgrade/actions.py423 except Exception as e:CODE
LOWtools/upgrade/actions.py436 except Exception as e:CODE
LOWtools/upgrade/actions.py446 except Exception as e:CODE
LOWtools/upgrade/actions.py558 except Exception as e:CODE
MEDIUMtools/upgrade/upgrade_health_checker.py34def exec_sql(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/upgrade_health_checker.py47def exec_query(self, sql, print_when_succ = True):CODE
MEDIUMtools/upgrade/upgrade_health_checker.py297def fetch_tenant_ids(query_cur):CODE
MEDIUMtools/upgrade/upgrade_health_checker.py423def check_cluster_version_for_vector_index(query_cur):CODE
MEDIUMtools/upgrade/upgrade_health_checker.py992def do_check(my_host, my_port, my_user, my_passwd, upgrade_params, timeout,CODE
LOW⚡tools/upgrade/upgrade_health_checker.py544 except Exception as e:CODE
LOW⚡tools/upgrade/upgrade_health_checker.py560 except Exception as e:CODE
LOWtools/upgrade/upgrade_health_checker.py44 except Exception as e:CODE
LOWtools/upgrade/upgrade_health_checker.py58 except Exception as e:CODE
LOWtools/upgrade/upgrade_health_checker.py304 except Exception as e:CODE
LOWtools/upgrade/upgrade_health_checker.py442 except Exception as e:CODE
LOWtools/upgrade/upgrade_health_checker.py1015 except Exception as e:CODE
LOWtools/upgrade/upgrade_health_checker.py1024 except Exception as e:CODE
LOWtools/upgrade/upgrade_health_checker.py1053 except Exception as e:CODE
LOWtools/upgrade/do_upgrade_pre.py101 except Exception as e:CODE
LOWtools/upgrade/do_upgrade_pre.py114 except Exception as e:CODE
LOWtools/upgrade/do_upgrade_pre.py154 except Exception as e:CODE
MEDIUMtools/upgrade/do_upgrade_pre.py57def do_upgrade(my_host, my_port, my_user, my_passwd, timeout, my_module_set, upgCODE
LOWtools/upgrade/upgrade_post_checker.py144 except Exception as e:CODE
MEDIUMtools/upgrade/upgrade_post_checker.py133def do_check(conn, cur, query_cur, timeout):CODE
LOWtools/upgrade/do_upgrade_post.py112 except Exception as e:CODE
LOWtools/upgrade/do_upgrade_post.py125 except Exception as e:CODE
LOWtools/upgrade/do_upgrade_post.py165 except Exception as e:CODE
MEDIUMtools/upgrade/do_upgrade_post.py59def do_upgrade(my_host, my_port, my_user, my_passwd, timeout, my_module_set, upgCODE
LOWtools/upgrade/tenant_upgrade_action.py40 except Exception as e:CODE
LOWtools/upgrade/tenant_upgrade_action.py144 except Exception as e:CODE
LOWtools/upgrade/tenant_upgrade_action.py175 except Exception as e:CODE
LOWtools/upgrade/tenant_upgrade_action.py236 except Exception as e:CODE
LOWtools/upgrade/tenant_upgrade_action.py261 except Exception as e:CODE
MEDIUMtools/upgrade/tenant_upgrade_action.py29def upgrade_syslog_level(conn, cur):CODE
MEDIUMtools/upgrade/tenant_upgrade_action.py127def get_max_used_job_id(cur):CODE
MEDIUMtools/upgrade/tenant_upgrade_action.py148def check_can_run_upgrade_job(cur, job_name):CODE
MEDIUMtools/upgrade/tenant_upgrade_action.py179def check_upgrade_job_result(cur, job_name, timeout, max_used_job_id):CODE
MEDIUMtools/upgrade/tenant_upgrade_action.py240def run_upgrade_job(conn, cur, job_name, timeout):CODE
LOW.github/obfarm/obfarm.py124 except Exception:CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py65 except Exception as e:CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py83 except Exception as e:CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py113 except Exception as e:CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py135 except Exception as e:CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py152 except Exception as e:CODE
5 more matches not shown…
Fake / Example Data75 hits · 82 pts
SeverityFileLineSnippetContext
LOW⚡mittest/mtlenv/test_htable_lock.cpp221 ObString fake_key = ObString::make_string("k1");CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp222 ObHTableLockKey lock_key(fake_table_id, fake_key);CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp232 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle1));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp233 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle2));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp288 ObString fake_key = ObString::make_string("k1");CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp289 ObHTableLockKey lock_key(fake_table_id, fake_key);CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp299 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle1));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp300 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp305 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle2));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp318 ObString fake_key = ObString::make_string("k1");CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp319 ObHTableLockKey lock_key(fake_table_id, fake_key);CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp326 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp329 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp335 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp336 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle2));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp340 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp344 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp351 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp352 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lockCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp355 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp362 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp363 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lockCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp366 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle));CODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp372 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lCODE
LOW⚡mittest/mtlenv/test_htable_lock.cpp373 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lockCODE
LOWmittest/mtlenv/test_htable_lock.cpp137 ObString fake_key = ObString::make_string("k1");CODE
LOWmittest/mtlenv/test_htable_lock.cpp142 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle));CODE
LOWmittest/mtlenv/test_htable_lock.cpp247 ObString fake_key = ObString::make_string("k1");CODE
LOWmittest/mtlenv/test_htable_lock.cpp248 ObHTableLockKey lock_key(fake_table_id, fake_key);CODE
LOWmittest/mtlenv/test_htable_lock.cpp259 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lock_handle1));CODE
LOWmittest/mtlenv/test_htable_lock.cpp260 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lCODE
LOWmittest/mtlenv/test_htable_lock.cpp273 ASSERT_EQ(OB_SUCCESS, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::EXCLUSIVE, *lock_handle1));CODE
LOWmittest/mtlenv/test_htable_lock.cpp274 ASSERT_EQ(OB_TRY_LOCK_ROW_CONFLICT, HTABLE_LOCK_MGR->lock_row(fake_table_id, fake_key, ObHTableLockMode::SHARED, *lockCODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp344 common::ObString dummy_key;CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp355 dummy_key,CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp385 ret = tablet->read_raw_data(allocator_, mds_unit_id, dummy_key, snapshot, timeout_us, kv);CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp454 common::ObString dummy_key;CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp465 dummy_key,CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp708 common::ObString dummy_key;CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp728 dummy_key,CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp804 dummy_key,CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp841 dummy_key,CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp990 common::ObString dummy_key;CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp1017 dummy_key,CODE
LOWmittest/mtlenv/storage/test_mds_table_scan.cpp1331 common::ObString dummy_key;CODE
LOWdeps/oblib/src/lib/oblog/ob_log_print_kv.h800#define LOG_KVS(...) "placeholder" LOG_KVS_(ARGS_NUM(__VA_ARGS__), __VA_ARGS__)COMMENT
LOWdeps/oblib/src/lib/oblog/ob_log_print_kv.h838#define LOG_VALUES(...) "placeholder" LOG_VALUES_(ARGS_NUM(__VA_ARGS__), __VA_ARGS__)COMMENT
LOWsrc/pl/ob_pl_code_generator.cpp9890 ObLLVMValue dummy_value;CODE
LOWsrc/pl/ob_pl_code_generator.cpp9891 if (OB_FAIL(vars_.push_back(dummy_value))) {CODE
LOWsrc/plugin/legacy/external_table/ob_external_filter.h45 static constexpr const char *QUESTION_MARK_PLACEHOLDER_FIELD_NAME = "placeholder";CODE
LOWsrc/storage/tablet/ob_tablet_block_aggregated_info.cpp238 MacroBlockId dummy_id;CODE
LOWsrc/storage/tablet/ob_tablet_full_memory_mds_data.cpp236 mds::DummyKey dummy_key;CODE
LOWsrc/storage/tablet/ob_tablet_full_memory_mds_data.cpp237 if (OB_FAIL(key.init(table_id, unit_id, dummy_key, allocator))) {CODE
LOWsrc/storage/tablet/ob_tablet_full_memory_mds_data.cpp375 mds::DummyKey dummy_key;CODE
LOWsrc/storage/tablet/ob_tablet_full_memory_mds_data.cpp376 if (OB_FAIL(key.init(table_id, unit_id, dummy_key, allocator))) {CODE
LOWsrc/storage/memtable/mvcc/ob_keybtree.cpp689 BtreeKey dummy_key;CODE
LOWsrc/storage/memtable/mvcc/ob_keybtree.cpp690 ret = split_child(old_node, pos, pos < 0 ? dummy_key : old_node->get_key(pos, &this->index_),CODE
LOWsrc/share/system_variable/ob_system_variable_init.json11711 "placeholder": falseCODE
LOWsrc/share/system_variable/ob_system_variable_init.json12031 "placeholder": trueCODE
LOWsrc/share/system_variable/gen_ob_sys_variables.py77ignored_attrs = ["publish_version", "info_cn", "background_cn", "ref_url", "placeholder"]CODE
15 more matches not shown…
Cross-Language Confusion14 hits · 55 pts
SeverityFileLineSnippetContext
HIGHsrc/storage/blocksstable/ob_storage_object_type_def.py1559 object_id.set_ss_fourth_id(!false && opt.ss_share_opt_.is_ls_inner_tablet_,CODE
HIGHsrc/share/system_variable/gen_ob_sys_variables.py376 cpp_file.write(" for (int64_t i = 0; OB_SUCC(ret) && false == name_exist && i < var_amount; ++i){\n")CODE
HIGHsrc/share/system_variable/gen_ob_sys_variables.py378 cpp_file.write(" ObSysVars[i].default_value_.assign_ptr(new_value.ptr(), new_value.length());\n")CODE
HIGHsrc/share/system_variable/gen_ob_sys_variables.py400 cpp_file.write(" for (int64_t i = 0; OB_SUCC(ret) && false == name_exist && i < var_amount; ++i){\n")CODE
HIGHsrc/share/system_variable/gen_ob_sys_variables.py402 cpp_file.write(" ObSysVars[i].base_value_.assign_ptr(new_value.ptr(), new_value.length());\n")CODE
HIGHsrc/share/system_variable/gen_ob_sys_variables.py861 return 0 <= store_idx && store_idx < ObSysVarFactory::ALL_SYS_VARS_COUNT;CODE
HIGHsrc/share/system_variable/gen_ob_sys_variables.py1051 } else if (-1 == store_idx && OB_FAIL(calc_sys_var_store_idx(sys_var_id, store_idx))) {CODE
HIGHsrc/share/system_variable/gen_ob_sys_variables.py1053 } else if (store_idx < 0 || store_idx >= ALL_SYS_VARS_COUNT) {CODE
HIGHsrc/share/inner_table/generate_inner_table_schema.py2468 h_f.write(" for (uint64_t i = 0; common::OB_INVALID_ID == idx && i < ARRAYSIZEOF(all_ora_mapping_virtual_tables); ++iSTRING
HIGHsrc/share/inner_table/generate_inner_table_schema.py2498 h_f.write(" if (pure_id > common::OB_MAX_MYSQL_VIRTUAL_TABLE_ID && pure_id < common::OB_MAX_VIRTUAL_TABLE_ID) {\n")STRING
HIGHsrc/share/inner_table/generate_inner_table_schema.py2518 h_f.write(" if (pure_id > common::OB_MAX_MYSQL_VIRTUAL_TABLE_ID && pure_id < common::OB_MAX_VIRTUAL_TABLE_ID) {\n")STRING
HIGHsrc/share/inner_table/generate_inner_table_schema.py2527 h_f.write(" for (int64_t i = 0; !bret && i < ARRAYSIZEOF(only_rs_vtables); ++i) {\n");STRING
HIGHsrc/share/inner_table/generate_inner_table_schema.py2538 h_f.write(" for (int64_t i = 0; !bret && i < ARRAYSIZEOF(cluster_distributed_vtables); ++i) {\n");STRING
HIGHsrc/share/inner_table/generate_inner_table_schema.py2549 h_f.write(" for (int64_t i = 0; !bret && i < ARRAYSIZEOF(tenant_distributed_vtables); ++i) {\n");STRING
Unused Imports50 hits · 45 pts
SeverityFileLineSnippetContext
LOWunittest/sql/external_table/gen_parquet_test_data.py19CODE
LOWunittest/sql/external_table/gen_orc_test_data.py18CODE
LOWtools/import_srs_data.py2CODE
LOWtools/import_srs_data.py3CODE
LOWtools/import_srs_data.py4CODE
LOWtools/import_srs_data.py5CODE
LOWtools/import_srs_data.py8CODE
LOWtools/import_time_zone_info.py2CODE
LOWtools/import_time_zone_info.py4CODE
LOWtools/import_time_zone_info.py5CODE
LOWtools/import_time_zone_info.py7CODE
LOWtools/upgrade/upgrade_pre.py4146CODE
LOWtools/upgrade/upgrade_pre.py4146CODE
LOWtools/upgrade/special_upgrade_action_pre.py4CODE
LOWtools/upgrade/special_upgrade_action_pre.py6CODE
LOWtools/upgrade/special_upgrade_action_pre.py7CODE
LOWtools/upgrade/special_upgrade_action_pre.py9CODE
LOWtools/upgrade/special_upgrade_action_pre.py10CODE
LOWtools/upgrade/special_upgrade_action_pre.py11CODE
LOWtools/upgrade/special_upgrade_action_pre.py12CODE
LOWtools/upgrade/special_upgrade_action_pre.py14CODE
LOWtools/upgrade/special_upgrade_action_pre.py15CODE
LOWtools/upgrade/special_upgrade_action_pre.py17CODE
LOWtools/upgrade/upgrade_checker.py4CODE
LOWtools/upgrade/upgrade_checker.py8CODE
LOWtools/upgrade/actions.py5CODE
LOWtools/upgrade/actions.py6CODE
LOWtools/upgrade/actions.py7CODE
LOWtools/upgrade/actions.py8CODE
LOWtools/upgrade/actions.py10CODE
LOWtools/upgrade/upgrade_health_checker.py4CODE
LOWtools/upgrade/upgrade_health_checker.py9CODE
LOWtools/upgrade/my_utils.py4CODE
LOWtools/upgrade/my_utils.py5CODE
LOWtools/upgrade/do_upgrade_pre.py7CODE
LOWtools/upgrade/upgrade_post_checker.py5CODE
LOWtools/upgrade/upgrade_post_checker.py6CODE
LOWtools/upgrade/upgrade_post_checker.py8CODE
LOWtools/upgrade/upgrade_post_checker.py9CODE
LOWtools/upgrade/do_upgrade_post.py7CODE
LOWtools/upgrade/do_upgrade_post.py10CODE
LOWtools/upgrade/upgrade_post.py4146CODE
LOWtools/upgrade/upgrade_post.py4146CODE
LOWtools/upgrade/tenant_upgrade_action.py7CODE
LOWtools/upgrade/tenant_upgrade_action.py8CODE
LOWtools/upgrade/tenant_upgrade_action.py9CODE
LOWtools/upgrade/tenant_upgrade_action.py11CODE
LOWtools/upgrade/tenant_upgrade_action.py12CODE
LOW.github/obfarm/obfarm.py2CODE
LOW.github/obfarm/obfarm.py3CODE
AI Slop Vocabulary13 hits · 37 pts
SeverityFileLineSnippetContext
MEDIUM…env/storage/blocksstable/ob_index_block_data_prepare.h1597 // The robust way is to use the end rowkey of the last macro meta in `partial_sstable_` as the boundary,COMMENT
MEDIUMdeps/oblib/src/common/row/ob_row_store.cpp707 if (block == blocks_.get_last()) { // to be robustCODE
MEDIUMdeps/oblib/src/lib/restore/ob_object_storage_base.h40// as COS cannot utilize OB's code directly, to avoid compilation errorsCOMMENT
MEDIUM…objit/deps/googletest/include/gtest/gtest-death-test.h146// This implementation is *not* meant to be as highly tuned or robustCOMMENT
MEDIUM…objit/deps/googletest/include/gtest/gtest-death-test.h218// In practice, this can be used to test functions that utilize theCOMMENT
MEDIUMsrc/storage/tx_table/ob_tx_table_define.h263 // these checks. To address this scenario, we utilize configuration settingsCOMMENT
MEDIUMsrc/storage/tx_table/ob_tx_table_define.h315 // these checks. To address this scenario, we utilize configuration settingsCOMMENT
MEDIUMsrc/logservice/libobcdc/src/ob_log_schema_getter.cpp560 // Essentially, in addition to the schema information for tables, the schema for databases and tenants currently only COMMENT
MEDIUMsrc/share/ob_rpc_struct.h9884 // Essentially, we can use ObIArray<ObNewRange> hereCOMMENT
MEDIUMsrc/share/wr/ob_wr_task.h198 // Therefore, lazy_snapshot_interval_min_ is added to utilize a lazy loading mode to avoid the issue.COMMENT
MEDIUMsrc/sql/rewrite/ob_transform_utils.cpp16653 // we store table indices instead of table item to leverage the consumptionCOMMENT
MEDIUMsrc/sql/optimizer/ob_logical_operator.h2020 bool is_local_order_by_das_; // local order originates from DAS scan, GI cannot leverage itCODE
MEDIUMsrc/sql/engine/expr/ob_expr_local_dynamic_filter.cpp178// just use pk increment value as hash val to leverage current logic of dynamic in filterCOMMENT
Deep Nesting40 hits · 30 pts
SeverityFileLineSnippetContext
LOWreplace_license.py25CODE
LOWreplace_license.py97CODE
LOWtools/import_time_zone_info.py26CODE
LOWtools/upgrade/upgrade_pre.py4167CODE
LOWtools/upgrade/reset_upgrade_scripts.py6CODE
LOWtools/upgrade/upgrade_checker.py350CODE
LOWtools/upgrade/upgrade_checker.py433CODE
LOWtools/upgrade/upgrade_checker.py531CODE
LOWtools/upgrade/upgrade_checker.py572CODE
LOWtools/upgrade/upgrade_checker.py594CODE
LOWtools/upgrade/upgrade_checker.py615CODE
LOWtools/upgrade/upgrade_checker.py686CODE
LOWtools/upgrade/upgrade_checker.py706CODE
LOWtools/upgrade/upgrade_checker.py726CODE
LOWtools/upgrade/upgrade_checker.py746CODE
LOWtools/upgrade/upgrade_checker.py951CODE
LOWtools/upgrade/upgrade_checker.py1021CODE
LOWtools/upgrade/upgrade_checker.py1092CODE
LOWtools/upgrade/actions.py172CODE
LOWtools/upgrade/actions.py248CODE
LOWtools/upgrade/upgrade_health_checker.py628CODE
LOWtools/upgrade/upgrade_health_checker.py813CODE
LOWtools/upgrade/upgrade_health_checker.py857CODE
LOWtools/upgrade/do_upgrade_pre.py118CODE
LOWtools/upgrade/upgrade_post_checker.py22CODE
LOWtools/upgrade/do_upgrade_post.py129CODE
LOWtools/upgrade/upgrade_post.py4167CODE
LOWtools/upgrade/gen_upgrade_scripts.py8CODE
LOWtools/upgrade/tenant_upgrade_action.py70CODE
LOWtools/upgrade/tenant_upgrade_action.py148CODE
LOWtools/upgrade/tenant_upgrade_action.py179CODE
LOW.github/obfarm/obfarm.py132CODE
LOWsrc/storage/blocksstable/generate_shared_object_type.py68CODE
LOWsrc/storage/blocksstable/generate_shared_object_type.py113CODE
LOWsrc/storage/blocksstable/generate_shared_object_type.py445CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py58CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py68CODE
LOWsrc/logservice/libobcdc/tests/rerun_obcdc_case.py118CODE
LOWsrc/share/inner_table/sys_package/syspack_codegen.py125CODE
LOWsrc/share/inner_table/sys_package/syspack_codegen.py93CODE
TODO Padding6 hits · 9 pts
SeverityFileLineSnippetContext
LOWsrc/observer/omt/ob_tenant_ai_service.cpp62 // TODO: implement after cache supportCOMMENT
LOWsrc/storage/meta_mem/ob_storage_meta_cache.cpp656 // TODO: implement batch read in shared block reader.COMMENT
LOW…/storage/blocksstable/encoding/ob_vector_decode_util.h122 // TODO: implement ?COMMENT
LOWsrc/storage/retrieval/ob_spiv_dim_iter.cpp274// TODO: implement agg_iter_COMMENT
LOWsrc/share/vector_index/ob_vector_embedding_handler.cpp1567 // TODO: implement thisCOMMENT
LOWsrc/sql/das/search/ob_das_match_query.h78 // TODO: implement cost computingCOMMENT
Empty Error Handlers1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHreplace_license.py43except (IOError, OSError):CODE
Slop Phrases2 hits · 4 pts
SeverityFileLineSnippetContext
MEDIUMsrc/storage/blocksstable/ob_storage_object_type_def.py5# you can add new storage object type hereCOMMENT
LOWsrc/storage/tx/ob_tx_api.cpp142 * don't forget to call release_tx before release callback's memoryCOMMENT
AI Structural Patterns2 hits · 2 pts
SeverityFileLineSnippetContext
LOWtools/ob_admin/ss_ob_admin.py64CODE
LOWtools/ob_admin/ss_ob_admin.py77CODE