Skip to content

Remove multi-log-stream architecture #1049

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
footka merged 1 commit into from
Jul 16, 2026
Merged

Remove multi-log-stream architecture #1049

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
53 changes: 2 additions & 51 deletions .github/script/seekdb/scripts/mysqltest_for_seekdb.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -301,18 +301,6 @@ EOF
fi
echo "$conf" > $HOME/seekdb/tools/deploy/config.yaml

if [[ $WITH_SHARED_STORAGE == "1" ]]
then
# shared_storage 需要在global修改相关的mode
share_storage_workdir="$(date +%s)-$(uuidgen)"
first_global_line_count=`sed -n '/global:/=' $HOME/seekdb/tools/deploy/config.yaml | head -n 1`
set +x
sed -i "${first_global_line_count}a\ mode: 'shared_storage'\n\
shared_storage: \"oss://oss-436751-0701-all-test/$FARM2_RUN_USER/$share_storage_workdir?host=oss-cn-hangzhou.aliyuncs.com&access_id=${SENSITIVE_TEST_OSS_ID_FOR_OBJECT_STORAGE_FOR_TOTAL}&access_key=${SENSITIVE_TEST_OSS_KEY_FOR_OBJECT_STORAGE_FOR_TOTAL}&max_iops=0&max_bandwidth=0B&scope=region\"" $HOME/seekdb/tools/deploy/config.yaml
sed -i "s/datafile_size: '20G'/datafile_size: '200G'/g" $HOME/seekdb/tools/deploy/config.yaml
set -x
fi

if [[ $SHARED_STORAGE_MODE == "1" ]]
then
# shared_storage 需要在global修改相关的mode
Expand All @@ -327,10 +315,7 @@ EOF
shared_storage: \"s3://farm-test/mysqltest/$share_storage_workdir/clog_and_data?host=http://$MINIO_IP:9000&access_id=minioadmin&access_key=minioadmin&s3_region=us-east-1&max_iops=10000&max_bandwidth=1GB&scope=region\"" $HOME/seekdb/tools/deploy/config.yaml
fi

if [[ ! $WITH_SHARED_STORAGE == "1" ]]
then
cat $HOME/seekdb/tools/deploy/config.yaml
fi
cat $HOME/seekdb/tools/deploy/config.yaml
}

function obd_prepare_bin {
Expand Down Expand Up @@ -650,26 +635,6 @@ function obd_run_mysqltest {
mv compare.out $HOME/mysqltest${submarker}_compare_output.$SLICE_IDX
echo "finish!"
return $ret
elif [[ $WITH_SHARED_STORAGE == "1" ]]
then
# 把sensitive_test目录下的测试集合移动到tools/deploy/mysql_test
# 并且创建一个新的目录用来表示单独的测试
if [[ ! -d $HOME/seekdb/sensitive_test/mysql_test ]]
then
return 0
fi
need_mv_dirs=`ls -1 $HOME/seekdb/sensitive_test/mysql_test/test_suite|xargs`
run_suites=""
for need_mv_dir in $need_mv_dirs
do
new_dir=$HOME/seekdb/tools/deploy/mysql_test/test_suite/shared_storage__${need_mv_dir}
run_suites="${run_suites}shared_storage__${need_mv_dir},"
mkdir -p $new_dir
cp -r $HOME/seekdb/sensitive_test/mysql_test/test_suite/$need_mv_dir/* $new_dir
done
run_suites=`echo $run_suites | awk '{print substr($0, 1, length($0)-1)}'`
mysqltest_cmd="$obd test mysqltest $ob_name $SERVER_ARGS --mysqltest-bin=./mysqltest --obclient-bin=./obclient $COLLECT_ARG --init-sql-dir=$HOME/seekdb/tools/deploy --log-dir=./var/log $REBOOT_TIMEOUT $VERBOSE_ARG $EXTRA_ARGS_WITHOUT_CASE --suite=$run_suites"
$mysqltest_cmd $INIT_FLIES $SCHE_ARGS 2>&1 | tee compare.out && ( exit ${PIPESTATUS[0]})
else
if [[ -f $HOME/seekdb/tools/deploy/error_log_filter.json && ( $BRANCH == 'master' || $BRANCH == "4_2_x_release" ) && "$FROM_FARM" == '1' ]]
then
Expand Down Expand Up @@ -709,12 +674,6 @@ function obd_collect_log {
mkdir -p collected_log/mysqltest_rec_log
find $DATA_PATH -name 'core[.-]*' | xargs -i cp {} collected_log
[[ "$OBD_HOME" != "" ]] && mv $OBD_HOME/.obd/log/* collected_log/obd_log/
set +x
if [[ $WITH_SHARED_STORAGE == "1" ]]
then
sed -i "s/${SENSITIVE_TEST_OSS_KEY_FOR_OBJECT_STORAGE_FOR_TOTAL}//" collected_log/obd_log/obd
fi
set -x
mv seekdb/tools/deploy/var/log/* collected_log/mysqltest_log/
mv seekdb/tools/deploy/var/rec_log/* collected_log/mysqltest_rec_log/
mv collected_log collected_log_$SLICE_IDX
Expand Down Expand Up @@ -751,14 +710,6 @@ function run {
([[ -f $HOME/seekdb/deps/3rd/oceanbase.el7.x86_64.deps ]] && [[ "$(grep 'ob-deploy' $HOME/seekdb/deps/3rd/oceanbase.el7.x86_64.deps )" != "" ]]) ||
([[ -f $HOME/seekdb/deps/init/oceanbase.el7.x86_64.deps ]] && [[ "$(grep 'ob-deploy' $HOME/seekdb/deps/init/oceanbase.el7.x86_64.deps )" != "" ]])
then
if [[ $WITH_SHARED_STORAGE == "1" ]]
then
# 单独判断下是否有对应的case集合
if [[ ! -d $HOME/seekdb/sensitive_test/mysql_test ]]
then
return 0
fi
fi
timeout=18000
[[ "$SPECIAL_RUN" == "1" ]] && timeout=72000
obd_prepare_env &&
Expand Down Expand Up @@ -796,4 +747,4 @@ function run {

}

run "$@"
run "$@"
24 changes: 0 additions & 24 deletions deps/oblib/src/common/meta_programming/ob_type_traits.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,10 +36,6 @@ namespace mds
class BufferCtx;
}
}
namespace transaction
{
class ObMulSourceDataNotifyArg;
}
namespace common
{
namespace meta
Expand Down Expand Up @@ -139,7 +135,6 @@ REGISTER_FUNCTION_TRAIT(compare)
REGISTER_FUNCTION_TRAIT(swap)
REGISTER_FUNCTION_TRAIT(check_can_do_tx_end)
REGISTER_FUNCTION_TRAIT(check_can_replay_commit)
REGISTER_FUNCTION_TRAIT(on_commit_for_old_mds)
REGISTER_FUNCTION_TRAIT(mds_serialize)
REGISTER_FUNCTION_TRAIT(mds_deserialize)
REGISTER_FUNCTION_TRAIT(mds_get_serialize_size)
Expand Down Expand Up @@ -333,13 +328,6 @@ typename std::enable_if<OB_TRAIT_HAS_CHECK_CAN_REPLAY_COMMIT(CLASS), bool>::type
#define ENABLE_IF_NOT_HAS_CHECK_CAN_REPLAY_COMMIT(CLASS) \
typename std::enable_if<!OB_TRAIT_HAS_CHECK_CAN_REPLAY_COMMIT(CLASS), bool>::type = true

#define OB_TRAIT_MDS_COMMIT_FOR_OLD_MDS(CLASS) \
::oceanbase::common::meta::has_on_commit_for_old_mds<DECAY(CLASS), int(const char *, const int64_t, const transaction::ObMulSourceDataNotifyArg &)>::value
#define ENABLE_IF_MDS_COMMIT_FOR_OLD_MDS(CLASS) \
typename std::enable_if<OB_TRAIT_MDS_COMMIT_FOR_OLD_MDS(CLASS), bool>::type = true
#define ENABLE_IF_NOT_MDS_COMMIT_FOR_OLD_MDS(CLASS) \
typename std::enable_if<!OB_TRAIT_MDS_COMMIT_FOR_OLD_MDS(CLASS), bool>::type = true

#define OB_TRAIT_IS_SAME_CLASS(CLASS, DEST_CLASS) \
std::is_same<DECAY(CLASS), DECAY(DEST_CLASS)>::value
#define ENABLE_IF_IS_SAME_CLASS(CLASS, DEST_CLASS) \
Expand Down Expand Up @@ -383,18 +371,6 @@ struct MdsCheckCanReplayWrapper {
}
};

template <typename T>
struct MdsCommitForOldMdsWrapper {
template <typename CLASS = T, ENABLE_IF_MDS_COMMIT_FOR_OLD_MDS(CLASS)>
static int on_commit_for_old_mds(const char *buf, const int64_t buf_len, const transaction::ObMulSourceDataNotifyArg &arg) {
return T::on_commit_for_old_mds(buf, buf_len, arg);
}
template <typename CLASS = T, ENABLE_IF_NOT_MDS_COMMIT_FOR_OLD_MDS(CLASS)>
static int on_commit_for_old_mds(const char *, const int64_t, const transaction::ObMulSourceDataNotifyArg &) {
return OB_SUCCESS;
}
};

}
}
}
Expand Down
27 changes: 7 additions & 20 deletions deps/oblib/src/common/ob_common_types.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -62,10 +62,9 @@ struct ObQueryFlag
#define OBSF_BIT_IS_SELECT_FOLLOWER 1
#define OBSF_BIT_ENABLE_LOB_PREFETCH 1
#define OBSF_BIT_IS_BARE_ROW_SCAN 1
#define OBSF_BIT_MR_MV_SCAN 2
#define OBSF_BIT_IS_PLAIN_INSERT 1
#define OBSF_BIT_SNAPSHOT_OPT 1
#define OBSF_BIT_SKIP_RUNNING_TX 1
#define OBSF_BIT_RESERVED 19
#define OBSF_BIT_RESERVED 21

static const uint64_t OBSF_MASK_SCAN_ORDER = (0x1UL << OBSF_BIT_SCAN_ORDER) - 1;
static const uint64_t OBSF_MASK_DAILY_MERGE = (0x1UL << OBSF_BIT_DAILY_MERGE) - 1;
Expand Down Expand Up @@ -96,7 +95,7 @@ struct ObQueryFlag
static const uint64_t OBSF_MASK_IS_SELECT_FOLLOWER = (0x1UL << OBSF_BIT_IS_SELECT_FOLLOWER) - 1;
static const uint64_t OBSF_MASK_ENABLE_LOB_PREFETCH = (0x1UL << OBSF_BIT_ENABLE_LOB_PREFETCH) - 1;
static const uint64_t OBSF_MASK_IS_DIRECT_SCAN = (0x1UL << OBSF_BIT_IS_BARE_ROW_SCAN) - 1;
static const uint64_t OBSF_MASK_IS_PLAIN_INSERT = (0x1UL << OBSF_BIT_IS_PLAIN_INSERT) - 1;
static const uint64_t OBSF_MASK_SNAPSHOT_OPT = (0x1UL << OBSF_BIT_SNAPSHOT_OPT) - 1;
static const uint64_t OBSF_MASK_SKIP_RUNNING_TX = (0x1UL << OBSF_BIT_SKIP_RUNNING_TX) - 1;


Expand Down Expand Up @@ -127,12 +126,6 @@ struct ObQueryFlag
ReservedMode = 2,
};

enum MRMVScanMode
{
NormalMode = 0,
RefreshMode = 1,
RealTimeMode = 2,
};
union
{
uint64_t flag_;
Expand Down Expand Up @@ -173,8 +166,7 @@ struct ObQueryFlag
uint64_t is_mds_query_ : OBSF_BIT_IS_MDS_QUERY;
uint64_t enable_lob_prefetch_ : OBSF_BIT_ENABLE_LOB_PREFETCH;
uint64_t is_bare_row_scan_ : OBSF_BIT_IS_BARE_ROW_SCAN; // 1: to scan mult version row directly without compact.
uint64_t mr_mv_scan_ : OBSF_BIT_MR_MV_SCAN; // 0: normal table scan. 1. major refresh mview base table scan in refresh 2. major refresh rt-mview base table scan
uint64_t is_plain_insert_gts_opt_ : OBSF_BIT_IS_PLAIN_INSERT;
uint64_t use_snapshot_opt_ : OBSF_BIT_SNAPSHOT_OPT;
uint64_t skip_running_tx_ : OBSF_BIT_SKIP_RUNNING_TX; // 1: skip RUNNING transactions (e.g., for fork operations)
uint64_t reserved_ : OBSF_BIT_RESERVED;
};
Expand Down Expand Up @@ -274,8 +266,8 @@ struct ObQueryFlag
inline bool is_select_follower() const { return is_select_follower_; }
inline void set_enable_lob_prefetch() { enable_lob_prefetch_ = true; }
inline bool enable_lob_prefetch() const { return enable_lob_prefetch_; }
inline void set_plain_insert_gts_opt() { is_plain_insert_gts_opt_ = true; }
inline bool is_plain_insert_gts_opt() const { return is_plain_insert_gts_opt_; }
inline void set_snapshot_opt() { use_snapshot_opt_ = true; }
inline bool is_snapshot_opt() const { return use_snapshot_opt_; }
inline void disable_cache()
{
set_not_use_row_cache();
Expand All @@ -285,10 +277,6 @@ struct ObQueryFlag
}
inline void set_is_new_query_range() { is_new_query_range_ = true; }
inline bool is_new_query_range() const { return is_new_query_range_; }
inline bool is_mr_mview_refresh_base_scan() const { return RefreshMode == mr_mv_scan_; }
inline bool is_mr_rt_mview_base_scan() const { return RealTimeMode == mr_mv_scan_; }
inline bool is_mr_mview_query() const { return is_mr_mview_refresh_base_scan() || is_mr_rt_mview_base_scan(); }

TO_STRING_KV("scan_order", scan_order_,
"daily_merge", daily_merge_,
"rmmb_optimize", rmmb_optimize_,
Expand Down Expand Up @@ -321,8 +309,7 @@ struct ObQueryFlag
"is_select_follower", is_select_follower_,
"enable_lob_prefetch", enable_lob_prefetch_,
"is_bare_row_scan", is_bare_row_scan_,
"mr_mv_scan", mr_mv_scan_,
"is_plain_insert_gts_opt", is_plain_insert_gts_opt_,
"is_snapshot_opt", use_snapshot_opt_,
"skip_running_tx", skip_running_tx_,
"reserved", reserved_);
OB_UNIS_VERSION(1);
Expand Down
7 changes: 3 additions & 4 deletions deps/oblib/src/common/object/ob_object.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -922,13 +922,12 @@ struct ObMemLobReadSnapshot
struct ObMemLobLocationInfo
{
ObMemLobLocationInfo(){}
ObMemLobLocationInfo(int64_t table_id, int64_t ls_id, ObCollationType collation_id) :
tablet_id_(table_id), ls_id_(ls_id), cid_(collation_id)
ObMemLobLocationInfo(int64_t table_id, ObCollationType collation_id) :
tablet_id_(table_id), cid_(collation_id)
{}
TO_STRING_KV(K_(tablet_id), K_(ls_id), K_(cid));
TO_STRING_KV(K_(tablet_id), K_(cid));

int64_t tablet_id_;
int64_t ls_id_;
ObCollationType cid_; // charset for dbmslob
char data_[0];
};
Expand Down
43 changes: 1 addition & 42 deletions deps/oblib/src/lib/ob_define.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -571,12 +571,6 @@ const int64_t OB_MAX_SERVER_SESSION_CNT = 32767;
const int64_t OB_MAX_SERVER_TENANT_CNT = 5; // for sys,500,508,509
const int64_t OB_RECYCLE_MACRO_BLOCK_DURATION = 10 * 60 * 1000 * 1000LL; // 10 minutes
const int64_t OB_MINOR_FREEZE_TEAM_UP_INTERVAL = 2LL * 60 * 60 * 1000 * 1000; // 2 hours
// for define
const int64_t OB_MAX_SPECIAL_LS_NUM = 1; // 1 for sys ls
const int64_t OB_MAX_LS_NUM_PER_TENANT_PER_SERVER_CAN_BE_SET = 1024; // the maximum of _max_ls_cnt_per_server
const int64_t OB_MAX_LS_NUM_PER_TENANT_PER_SERVER = (10 * (OB_MAX_SPECIAL_LS_NUM + OB_MAX_MEMBER_NUMBER) > OB_MAX_LS_NUM_PER_TENANT_PER_SERVER_CAN_BE_SET ?
OB_MAX_LS_NUM_PER_TENANT_PER_SERVER_CAN_BE_SET : 10 * (OB_MAX_SPECIAL_LS_NUM + OB_MAX_MEMBER_NUMBER)); // magnification is 10x
const int64_t OB_MAX_LS_NUM_PER_TENANT_PER_SERVER_FOR_SMALL_TENANT = 1; // the tenant that smaller than 4G will be limit to 1
const int64_t OB_MAX_TIME = 3020399000000;
// Max add partition member timeout.
// Used to make sure no member added after lease expired + %OB_MAX_ADD_MEMBER_TIMEOUT
Expand Down Expand Up @@ -714,28 +708,10 @@ const uint64_t OB_ACTION_FLAG_COLUMN_ID = OB_ALL_MAX_COLUMN_ID
// internal compaction trans seq
const int64_t DELETE_INSERT_TRANS_SEQUENCE = ((__INT64_C(1LL << 62)) + 1);

// materialized view log
const uint64_t OB_MLOG_SEQ_NO_COLUMN_ID = OB_ALL_MAX_COLUMN_ID
- OB_END_RESERVED_COLUMN_ID_NUM + 2; /* 65521 */
const uint64_t OB_MLOG_DML_TYPE_COLUMN_ID = OB_ALL_MAX_COLUMN_ID
- OB_END_RESERVED_COLUMN_ID_NUM + 3; /* 65522 */
const uint64_t OB_MLOG_OLD_NEW_COLUMN_ID = OB_ALL_MAX_COLUMN_ID
- OB_END_RESERVED_COLUMN_ID_NUM + 4; /* 65523 */
const uint64_t OB_MLOG_ROWID_COLUMN_ID = OB_ALL_MAX_COLUMN_ID
- OB_END_RESERVED_COLUMN_ID_NUM + 5; /* 65524 */
const uint64_t OB_MIN_MLOG_SPECIAL_COLUMN_ID = OB_MLOG_SEQ_NO_COLUMN_ID;
const uint64_t OB_MAX_MLOG_SPECIAL_COLUMN_ID = OB_MLOG_ROWID_COLUMN_ID;

const char *const OB_MLOG_SEQ_NO_COLUMN_NAME = "SEQUENCE$$";
const char *const OB_MLOG_DML_TYPE_COLUMN_NAME = "DMLTYPE$$";
const char *const OB_MLOG_OLD_NEW_COLUMN_NAME = "OLD_NEW$$";
const char *const OB_MLOG_ROWID_COLUMN_NAME = "M_ROW$$";

const uint64_t OB_MAX_TMP_COLUMN_ID = OB_ALL_MAX_COLUMN_ID
- OB_END_RESERVED_COLUMN_ID_NUM;
// pseudo column id used in special table scan
const uint64_t OB_COUNT_AGG_PD_COLUMN_ID = INT32_MAX - 1;
const uint64_t OB_MAJOR_REFRESH_MVIEW_OLD_NEW_COLUMN_ID = INT32_MAX - 2;

const int64_t OB_MAX_AUTOINC_SEQ_VALUE = (1LL << 40) - 1; // max value for 40bit

Expand All @@ -753,10 +729,6 @@ const char *const OB_HIDDEN_LINE_NUMBER_COLUMN_NAME = "__line_number"; // used f

// internal index prefix
const char *const OB_INDEX_PREFIX = "__idx_";
// internal materialized view log prefix
const char *const OB_MLOG_PREFIX_MYSQL = "mlog$_";
const char *const OB_TMP_MLOG_PREFIX_MYSQL = "tmlog$_";

// internal user
const char *const OB_INTERNAL_USER = "__ob_server";

Expand Down Expand Up @@ -978,7 +950,6 @@ const int64_t MAX_ENABLED_ROLES = 148;
// table id range definition //
////////////////////////////////////////////////////////////
const uint64_t OB_MIN_GENERATED_COLUMN_ID = 2000;
const uint64_t OB_MIN_MV_COLUMN_ID = 10000;
const uint64_t OB_MIN_SHADOW_COLUMN_ID = 32767;
const uint64_t OB_MAX_SYS_POOL_ID = 100;

Expand Down Expand Up @@ -1639,21 +1610,9 @@ OB_INLINE uint64_t combine_two_ids(uint64_t high_id, uint64_t low_id)

const char *const OB_RANDOM_PRIMARY_ZONE = "RANDOM";

OB_INLINE bool is_mlog_reference_column(const uint64_t column_id)
{
return (common::OB_MLOG_ROWID_COLUMN_ID == column_id);
}

OB_INLINE bool is_mlog_special_column(const uint64_t column_id)
{
return (column_id >= common::OB_MIN_MLOG_SPECIAL_COLUMN_ID
&& column_id <= common::OB_MAX_MLOG_SPECIAL_COLUMN_ID);
}

OB_INLINE bool is_shadow_column(const uint64_t column_id)
{
return (column_id > common::OB_MIN_SHADOW_COLUMN_ID)
&& !is_mlog_special_column(column_id);
return column_id > common::OB_MIN_SHADOW_COLUMN_ID;
}

OB_INLINE bool is_bootstrap_resource_pool(const uint64_t resource_pool_id)
Expand Down
13 changes: 6 additions & 7 deletions deps/oblib/src/lib/ob_name_id_def.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ DEF_NAME(id, "id")
DEF_NAME(start_trans, "start transaction")
DEF_NAME(register_timeout_task, "register timeout task")
DEF_NAME(unregister_timeout_task, "unregister timeout task")
DEF_NAME(start_part, "start participant")
DEF_NAME(start_part, "start write participant")
DEF_NAME(trans_id, "transaction id")
DEF_NAME(local_task_completed, "local task completed")
DEF_NAME(remote_task_completed, "remote task completed")
Expand Down Expand Up @@ -280,7 +280,6 @@ DEF_NAME(id, "id")
DEF_NAME(handle_tx_commit_result, "handle tx commit result")
DEF_NAME(exec_commit_cb, "exec commit callback")
DEF_NAME(get_read_snapshot, "get read snapshot")
DEF_NAME(get_ls_read_snapshot, "get ls read snapshot")
DEF_NAME(register_snapshot, "register snapshot to txn")
DEF_NAME(unregister_snapshot, "register snapshot to txn")
DEF_NAME(release_snapshot, "release snapshot")
Expand Down Expand Up @@ -479,7 +478,7 @@ DEF_NAME(id, "id")
DEF_NAME(logic_clock, "the logical clock")
DEF_NAME(tx_free_route_update_static, "txn free route update static state")
DEF_NAME(tx_free_route_update_dynamic, "txn free route update dynamic state")
DEF_NAME(tx_free_route_update_participants, "txn free route update participants state")
DEF_NAME(tx_free_route_update_write_participant, "txn free route update write participant state")
DEF_NAME(tx_free_route_update_extra, "txn free route update extra state")
DEF_NAME(tx_free_route_send_state, "txn free route send state")
DEF_NAME(tx_free_route_recv_state, "txn free route receive state")
Expand Down Expand Up @@ -722,7 +721,7 @@ DEF_NAME(id, "id")
DEF_NAME_PAIR(parse_job, "parse job")
DEF_NAME_PAIR(do_open_plan, "do open plan")
DEF_NAME_PAIR(sql_start_stmt, "sql start stmt")
DEF_NAME_PAIR(sql_start_participant, "sql start participant")
DEF_NAME_PAIR(sql_start_participant, "sql start write participant")
DEF_NAME_PAIR(kv_get, "kv get")
DEF_NAME_PAIR(plc_get_from_cache, "plc get from cache")
DEF_NAME_PAIR(plc_serialize, "plc serialize")
Expand All @@ -731,7 +730,7 @@ DEF_NAME(id, "id")
DEF_NAME_PAIR(exec_remote_plan, "exec remote plan")
DEF_NAME_PAIR(exec_mini_plan, "exec mini plan")

DEF_NAME_PAIR(end_participant, "start_end_participant")
DEF_NAME_PAIR(end_participant, "start_end_write_participant")
DEF_NAME_PAIR(close_plan, "start_close_plan")
DEF_NAME_PAIR(auto_end_plan, "start_auto_end_plan")
DEF_NAME_PAIR(storage_table_scan, "table scan")
Expand Down Expand Up @@ -763,8 +762,8 @@ DEF_NAME(id, "id")
DEF_NAME_PAIR(T_end_trans, "transaction: end transaction")
DEF_NAME_PAIR(T_start_stmt, "transaction: start statement")
DEF_NAME_PAIR(T_end_stmt, "transaction: end statement")
DEF_NAME_PAIR(T_start_part, "transaction: start participant")
DEF_NAME_PAIR(T_end_part, "transaction: end participant")
DEF_NAME_PAIR(T_start_part, "transaction: start write participant")
DEF_NAME_PAIR(T_end_part, "transaction: end write participant")
DEF_NAME_PAIR(T_part_destroy, "transaction: part_trans_ctx destroy")
DEF_NAME_PAIR(T_destroy_callback, "transaction: destroy callback")
DEF_NAME_PAIR(E_analysis_plan, "executor: analysis plan")
Expand Down
Loading
Loading