diff --git a/deps/oblib/src/lib/wait_event/ob_wait_event.h b/deps/oblib/src/lib/wait_event/ob_wait_event.h index 26dbe8311..efbc978c8 100644 --- a/deps/oblib/src/lib/wait_event/ob_wait_event.h +++ b/deps/oblib/src/lib/wait_event/ob_wait_event.h @@ -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) diff --git a/src/storage/backup/ob_backup_ctx.cpp b/src/storage/backup/ob_backup_ctx.cpp index cfee2085c..0435bee21 100644 --- a/src/storage/backup/ob_backup_ctx.cpp +++ b/src/storage/backup/ob_backup_ctx.cpp @@ -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))) { diff --git a/src/storage/backup/ob_backup_reader.cpp b/src/storage/backup/ob_backup_reader.cpp index a78251433..8274868b2 100644 --- a/src/storage/backup/ob_backup_reader.cpp +++ b/src/storage/backup/ob_backup_reader.cpp @@ -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; diff --git a/src/storage/backup/ob_backup_utils.cpp b/src/storage/backup/ob_backup_utils.cpp index 4d59cc9af..7df2031ea 100644 --- a/src/storage/backup/ob_backup_utils.cpp +++ b/src/storage/backup/ob_backup_utils.cpp @@ -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;