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

fix: reserve extra size for high priority request in priority queue

Browse Source
This commit is contained in:
obdev
2023-08-11 03:12:44 +00:00
committed by ob-robot
parent 019cb496f5
commit 14e357b6c5
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
deps/oblib/src/lib/queue/ob_priority_queue.h vendored
View File

@ -129,7 +129,15 @@ public:
int push(ObLink* data, int priority)
{
int ret = OB_SUCCESS;
if (ATOMIC_FAA(&size_, 1) > limit_) {
int64_t extra;
if (priority < HIGH_PRIOS) {
extra = 2048;
} else if (priority < NORMAL_PRIOS + HIGH_PRIOS) {
extra = 1024;
} else {
extra = 0;
}
if (ATOMIC_FAA(&size_, 1) > limit_ + extra) {
ret = OB_SIZE_OVERFLOW;
} else if (OB_UNLIKELY(NULL == data) || OB_UNLIKELY(priority < 0) || OB_UNLIKELY(priority >= PRIO_CNT)) {
ret = OB_INVALID_ARGUMENT;