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

add build.sh clangd

Browse Source
This commit is contained in:
xuhuleon
2024-04-15 15:45:35 +00:00
committed by ob-robot
parent 8924e7291b
commit d6bfde0355
4 changed files with 150 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/rootserver/ob_balance_task_execute_service.cpp
View File

@ -343,10 +343,10 @@ int ObBalanceTaskExecuteService::execute_task_()
ObTimeoutCtx timeout_ctx;
const int64_t balance_task_execute_timeout = GCONF.internal_sql_execute_timeout + 100 * 1000 * 1000L; // +100s
DEBUG_SYNC(BEFORE_EXECUTE_BALANCE_TASK);
if (OB_FAIL(trans.start(sql_proxy_, tenant_id_))) {
LOG_WARN("failed to start trans", KR(ret), K(tenant_id_));
} else if (OB_FAIL(ObShareUtil::set_default_timeout_ctx(timeout_ctx, balance_task_execute_timeout))) {
if (OB_FAIL(ObShareUtil::set_default_timeout_ctx(timeout_ctx, balance_task_execute_timeout))) {
LOG_WARN("failed to get rs default timeout ctx", KR(ret));
} else if (OB_FAIL(trans.start(sql_proxy_, tenant_id_))) {
LOG_WARN("failed to start trans", KR(ret), K(tenant_id_));
} else if (OB_FAIL(get_balance_job_task_for_update_(task, job, task_in_trans, trans))) {
LOG_WARN("failed to get job", KR(ret), K(task));
} else if (task_in_trans.get_task_status().is_finish_status()) {

8
src/share/balance/ob_balance_task_table_operator.cpp
View File

@ -17,6 +17,7 @@
#include "lib/mysqlclient/ob_mysql_result.h"//MySQLResult
#include "lib/mysqlclient/ob_mysql_proxy.h"//MySQLResult
#include "lib/mysqlclient/ob_mysql_transaction.h"//ObMySQLTrans
#include "lib/utility/ob_tracepoint.h" // ERRSIM_POINT_DEF
#include "share/inner_table/ob_inner_table_schema.h"//ALL_BALANCE_TASK_TNAME
#include "share/ob_dml_sql_splicer.h"//ObDMLSqlSplicer
#include "share/balance/ob_balance_job_table_operator.h"//job_status
@ -604,6 +605,8 @@ int ObBalanceTaskTableOperator::start_transfer_task(const uint64_t tenant_id,
return ret;
}
ERRSIM_POINT_DEF(EN_FINISH_TRANSFER_TASK_COST_TOO_MUCH_TIME);
int ObBalanceTaskTableOperator::finish_transfer_task(
const ObBalanceTask &balance_task,
const ObTransferTaskID transfer_task_id,
@ -670,6 +673,11 @@ int ObBalanceTaskTableOperator::finish_transfer_task(
all_part_transferred = true;
}
// only for test
if (EN_FINISH_TRANSFER_TASK_COST_TOO_MUCH_TIME) {
ob_usleep(31 * 1000 * 1000L); // default internal_sql_execute_timeout + 1s
}
return ret;
}
//maybe in trans TODO