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

[CP] reset get_sql_arena_allocator() after rpc callback finished

Browse Source
This commit is contained in:
obdev
2024-02-08 13:27:22 +00:00
committed by ob-robot
parent aec3d88de3
commit e3412f0371
2 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
deps/oblib/src/rpc/frame/ob_req_transport.cpp vendored
View File

@ -144,6 +144,7 @@ int async_cb(easy_request_t *r)
if (!OB_SUCC(ret)) { if (!OB_SUCC(ret)) {
LOG_WARN("process async request fail", K(r), K(ret), K(pcode)); LOG_WARN("process async request fail", K(r), K(ret), K(pcode));
} }
THIS_WORKER.get_sql_arena_allocator().reset();
const int64_t cur_time = ObTimeUtility::current_time(); const int64_t cur_time = ObTimeUtility::current_time();
const int64_t total_time = cur_time - start_time; const int64_t total_time = cur_time - start_time;

1
deps/oblib/src/rpc/obrpc/ob_poc_rpc_proxy.cpp vendored
View File

@ -157,6 +157,7 @@ int ObAsyncRespCallback::handle_resp(int io_err, const char* buf, int64_t sz)
} }
pool_.destroy(); pool_.destroy();
ObCurTraceId::reset(); ObCurTraceId::reset();
THIS_WORKER.get_sql_arena_allocator().reset();
const int64_t cur_time = ObTimeUtility::current_time(); const int64_t cur_time = ObTimeUtility::current_time();
const int64_t total_time = cur_time - start_time; const int64_t total_time = cur_time - start_time;
const int64_t decode_time = after_decode_time - start_time; const int64_t decode_time = after_decode_time - start_time;