hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

rename IO_CONTROLLER_COND_WAIT in backup module

Browse Source
This commit is contained in:
Gmldry 2024-10-30 19:14:39 +00:00 committed by ob-robot
parent 686eaf7854
commit 077ec30af2
4 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/oblib/src/lib/wait_event/ob_wait_event.h vendored
View File

@ -94,6 +94,9 @@ WAIT_EVENT_DEF(BUILD_INDEX_SCHEDULER_COND_WAIT, 15126, "build index scheduler co
WAIT_EVENT_DEF(DAG_WORKER_COND_WAIT, 15132, "dag worker condition wait", "address", "", "", CONCURRENCY, false, true)
WAIT_EVENT_DEF(IO_CALLBACK_QUEUE_LOCK_WAIT, 15134, "io callback queue condition wait", "address", "", "", CONCURRENCY, true, true)
WAIT_EVENT_DEF(IO_CHANNEL_COND_WAIT, 15135, "io channel condition wait", "address", "", "", CONCURRENCY, true, true)
WAIT_EVENT_DEF(LS_BACKUP_CTX_COND_WAIT, 15155, "ls backup ctx condition wait", "address", "", "", CONCURRENCY, true, true)
WAIT_EVENT_DEF(SSTABLE_META_BACKUP_READER_COND_WAIT, 15156, "sstable meta backup reader condition wait", "address", "", "", CONCURRENCY, true, true)
WAIT_EVENT_DEF(BACKUP_MACRO_BLOCK_TASK_COND_WAIT, 15157, "backup macro blcok task condition wait", "address", "", "", CONCURRENCY, true, true)
WAIT_EVENT_DEF(BACKUP_TASK_SCHEDULER_COND_WAIT, 15158, "backup scheduler condition wait", "address", "", "", CONCURRENCY, true, true)
WAIT_EVENT_DEF(SLOG_CKPT_LOCK_WAIT, 15185, "slog checkpoint lock wait", "address", "", "", CONCURRENCY, true, false)
WAIT_EVENT_DEF(BACKUP_DATA_SERVICE_COND_WAIT, 15248, "backup data service condition wait", "address", "", "", CONCURRENCY, true, true)

2
src/storage/backup/ob_backup_ctx.cpp
View File

@ -1265,7 +1265,7 @@ int ObLSBackupCtx::open(
} else if (!param.is_valid() || !backup_data_type.is_valid()) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("get invalid args", K(ret), K(param), K(backup_data_type));
} else if (OB_FAIL(cond_.init(ObWaitEventIds::IO_CONTROLLER_COND_WAIT))) {
} else if (OB_FAIL(cond_.init(ObWaitEventIds::LS_BACKUP_CTX_COND_WAIT))) {
LOG_WARN("failed to init condition", K(ret));
} else if (OB_FAIL(tablet_stat_.init(
param.tenant_id_, param.backup_set_desc_.backup_set_id_, param.ls_id_, backup_data_type))) {

2
src/storage/backup/ob_backup_reader.cpp
View File

@ -662,7 +662,7 @@ int ObSSTableMetaBackupReader::init(const common::ObTabletID &tablet_id,
} else if (!tablet_id.is_valid()) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("get invalid argument", K(ret), K(tablet_id));
} else if (OB_FAIL(cond_.init(ObWaitEventIds::IO_CONTROLLER_COND_WAIT))) {
} else if (OB_FAIL(cond_.init(ObWaitEventIds::SSTABLE_META_BACKUP_READER_COND_WAIT))) {
LOG_WARN("failed to init condition", K(ret));
} else {
tablet_id_ = tablet_id;

2
src/storage/backup/ob_backup_utils.cpp
View File

@ -2798,7 +2798,7 @@ int ObBackupMacroBlockTaskMgr::init(const share::ObBackupDataType &backup_data_t
} else if (batch_size < 0) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("get invalid args", K(ret), K(batch_size));
} else if (OB_FAIL(cond_.init(ObWaitEventIds::IO_CONTROLLER_COND_WAIT))) {
} else if (OB_FAIL(cond_.init(ObWaitEventIds::BACKUP_MACRO_BLOCK_TASK_COND_WAIT))) {
LOG_WARN("failed to init condition", K(ret));
} else {
backup_data_type_ = backup_data_type;