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

fix ObIOBenchController core

Browse Source
This commit is contained in:
zhjc1124 2024-12-17 10:45:19 +00:00 committed by ob-robot
parent 18fbe3c59e
commit dd30da929d
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/share/io/ob_io_calibration.cpp
View File

@ -501,6 +501,12 @@ int ObIOBenchController::start_io_bench()
ret = OB_SUCCESS;
}
} else {
if (-1 != tg_id_) {
TG_STOP(tg_id_);
TG_WAIT(tg_id_);
TG_DESTROY(tg_id_);
tg_id_ = -1;
}
if (OB_FAIL(TG_CREATE(TGDefIDs::IO_BENCHMARK, tg_id_))) {
LOG_WARN("create tg failed", K(ret));
} else if (OB_FAIL(TG_SET_RUNNABLE_AND_START(tg_id_, *this))) {
@ -620,7 +626,6 @@ void ObIOBenchController::run1()
ret_code_ = ret;
finish_ts_ = ObTimeUtility::fast_current_time();
TG_DESTROY(tg_id_);
}
int64_t ObIOBenchController::get_start_timestamp()