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

set group id for ObThworker::run()

Browse Source
This commit is contained in:
zhjc1124 2024-11-21 06:45:29 +00:00 committed by ob-robot
parent f268b671ca
commit 216e42b4a0
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/observer/omt/ob_th_worker.cpp
View File

@ -430,6 +430,7 @@ void ObThWorker::run(int64_t idx)
int64_t tenant_id = -1;
int64_t req_recv_timestamp = -1;
int32_t worker_level = -1;
SET_GROUP_ID(get_group_id());
this->worker(tenant_id, req_recv_timestamp, worker_level);
}

5
src/share/rc/ob_tenant_base.cpp
View File

@ -313,8 +313,9 @@ int ObTenantBase::pre_run()
ObTenantEnv::set_tenant(this);
// register in tenant cgroup without modifying group_id
ObCgroupCtrl *cgroup_ctrl = get_cgroup();
if (OB_NOT_NULL(cgroup_ctrl)) {
ret = cgroup_ctrl->add_self_to_cgroup_(id_, GET_GROUP_ID());
if (OB_NOT_NULL(cgroup_ctrl) && cgroup_ctrl->is_valid()) {
// add thread to tenant OBCG_DEFAULT cgroup
ret = cgroup_ctrl->add_self_to_cgroup_(id_);
}
{
ThreadListNode *node = lib::Thread::current().get_thread_list_node();