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

opt ObSQLSessionInfo

Browse Source
This commit is contained in:
tushicheng
2023-08-01 14:54:15 +00:00
committed by ob-robot
parent 222de8ce6a
commit 3b07f6c3d0
4 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
deps/oblib/src/lib/allocator/ob_slice_alloc.h vendored
View File

@ -236,6 +236,12 @@ public:
h ^= h >> 33; h ^= h >> 33;
return h; return h;
} }
static int32_t get_blk_size(int32_t slice_size, int32_t slice_cnt)
{
int32_t isize = (int32_t)lib::align_up2(sizeof(Item) + slice_size, 16);
int32_t blk_size = (isize + sizeof(void*)) * slice_cnt + sizeof(ObBlockSlicer);
return blk_size;
}
Item* alloc_item() { Item* alloc_item() {
Item* ret = NULL; Item* ret = NULL;
ret = alloc_stock()? (Item*)flist_.pop(): NULL; ret = alloc_stock()? (Item*)flist_.pop(): NULL;

5
deps/oblib/src/lib/objectpool/ob_concurrency_objpool.h vendored
View File

@ -45,9 +45,10 @@ class ObFixedClassAllocator
public: public:
using object_type = T; using object_type = T;
public: public:
ObFixedClassAllocator(const ObMemAttr &attr, int64_t nway) ObFixedClassAllocator(const ObMemAttr &attr, int64_t nway, int32_t slice_cnt = 0)
: allocator_(sizeof(T) + sizeof(ObClassMeta), attr, : allocator_(sizeof(T) + sizeof(ObClassMeta), attr,
choose_blk_size(sizeof(T) + sizeof(ObClassMeta))) 0 == slice_cnt ? choose_blk_size(sizeof(T) + sizeof(ObClassMeta)) :
ObBlockSlicer::get_blk_size(sizeof(T) + sizeof(ObClassMeta), slice_cnt))
{ {
allocator_.set_nway(static_cast<int32_t>(nway)); allocator_.set_nway(static_cast<int32_t>(nway));
} }

4
src/sql/session/ob_sql_session_mgr.cpp
View File

@ -97,7 +97,7 @@ int64_t ObTenantSQLSessionMgr::SessionPool::count() const
ObTenantSQLSessionMgr::ObTenantSQLSessionMgr(const int64_t tenant_id) ObTenantSQLSessionMgr::ObTenantSQLSessionMgr(const int64_t tenant_id)
: tenant_id_(tenant_id), : tenant_id_(tenant_id),
session_allocator_(lib::ObMemAttr(tenant_id, "SQLSessionInfo"), MTL_CPU_COUNT()) session_allocator_(lib::ObMemAttr(tenant_id, "SQLSessionInfo"), MTL_CPU_COUNT(), 4)
{} {}
ObTenantSQLSessionMgr::~ObTenantSQLSessionMgr() ObTenantSQLSessionMgr::~ObTenantSQLSessionMgr()
@ -106,7 +106,7 @@ ObTenantSQLSessionMgr::~ObTenantSQLSessionMgr()
int ObTenantSQLSessionMgr::init() int ObTenantSQLSessionMgr::init()
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (OB_FAIL(session_pool_.init(MTL_IS_MINI_MODE() ? 32 : SessionPool::POOL_CAPACIPY))) { if (OB_FAIL(session_pool_.init(SessionPool::POOL_CAPACIPY))) {
LOG_WARN("fail to init session pool", K(tenant_id_), K(ret)); LOG_WARN("fail to init session pool", K(tenant_id_), K(ret));
} }
return ret; return ret;

2
src/sql/session/ob_sql_session_mgr.h
View File

@ -308,7 +308,7 @@ private:
class SessionPool class SessionPool
{ {
public: public:
static const int64_t POOL_CAPACIPY = 512; static const int64_t POOL_CAPACIPY = 32;
public: public:
SessionPool(); SessionPool();
int init(const int64_t capacity); int init(const int64_t capacity);