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

Add ctx id from connect by allocator.

Browse Source
This commit is contained in:
obdev
2022-11-23 12:11:59 +00:00
committed by wangzelin.wzl
parent e1f90f057e
commit 3e788f5391
3 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/sql/engine/connect_by/ob_cnnt_by_pump.cpp
View File

@ -248,6 +248,7 @@ int ObConnectByOpPump::init(const ObNLConnectBySpec &connect_by, ObNLConnectByOp
} else { } else {
uint64_t tenant_id = eval_ctx.exec_ctx_.get_my_session()->get_effective_tenant_id(); uint64_t tenant_id = eval_ctx.exec_ctx_.get_my_session()->get_effective_tenant_id();
allocator_.set_tenant_id(tenant_id); allocator_.set_tenant_id(tenant_id);
allocator_.set_ctx_id(ObCtxIds::WORK_AREA);
connect_by_prior_exprs_ = &connect_by.connect_by_prior_exprs_; connect_by_prior_exprs_ = &connect_by.connect_by_prior_exprs_;
eval_ctx_ = &eval_ctx; eval_ctx_ = &eval_ctx;
connect_by_ = &connect_by_op; connect_by_ = &connect_by_op;

4
src/sql/engine/connect_by/ob_cnnt_by_pump.h
View File

@ -56,6 +56,10 @@ private:
{ {
allocator_.set_tenant_id(tenant_id); allocator_.set_tenant_id(tenant_id);
} }
void set_ctx_id(int64_t ctx_id)
{
allocator_.set_ctx_id(ctx_id);
}
private: private:
common::ObArenaAllocator allocator_; common::ObArenaAllocator allocator_;
int64_t alloc_cnt_; int64_t alloc_cnt_;

1
src/sql/engine/connect_by/ob_cnnt_by_pump_bfs.cpp
View File

@ -279,6 +279,7 @@ int ObConnectByOpBFSPump::init(ObNLConnectByWithIndexSpec &connect_by,
} else { } else {
uint64_t tenant_id = eval_ctx.exec_ctx_.get_my_session()->get_effective_tenant_id(); uint64_t tenant_id = eval_ctx.exec_ctx_.get_my_session()->get_effective_tenant_id();
allocator_.set_tenant_id(tenant_id); allocator_.set_tenant_id(tenant_id);
allocator_.set_ctx_id(ObCtxIds::WORK_AREA);
connect_by_ = &connect_by_op; connect_by_ = &connect_by_op;
connect_by_prior_exprs_ = &connect_by.connect_by_prior_exprs_; connect_by_prior_exprs_ = &connect_by.connect_by_prior_exprs_;
left_prior_exprs_ = &connect_by.left_prior_exprs_; left_prior_exprs_ = &connect_by.left_prior_exprs_;