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

Add lbt info when throttle more than one mintue

Browse Source
This commit is contained in:
ZenoWang 2024-02-08 04:42:09 +00:00 committed by ob-robot
parent 154f795315
commit 949705a060
1 changed files with 21 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/share/throttle/ob_share_resource_throttle_tool.ipp
View File

@ -187,16 +187,26 @@ int64_t ObShareResourceThrottleTool<FakeAllocator, Args...>::expected_wait_time(
return expected_wait_time; return expected_wait_time;
} }
#define PRINT_THROTTLE_WARN \ #define PRINT_THROTTLE_WARN \
do { \ do { \
const int64_t WARN_LOG_INTERVAL = 60L * 1000L * 1000L /* one minute */; \ const int64_t WARN_LOG_INTERVAL = 1LL * 60L * 1000L * 1000L /* one minute */; \
if (sleep_time > (WARN_LOG_INTERVAL) && TC_REACH_TIME_INTERVAL(WARN_LOG_INTERVAL)) { \ if (sleep_time > (WARN_LOG_INTERVAL) && TC_REACH_TIME_INTERVAL(WARN_LOG_INTERVAL)) { \
SHARE_LOG(WARN, \ SHARE_LOG(WARN, \
"[Throttling] Attention!! Sleep More Than One Minute!!", \ "[Throttling] Attention!! Sleep More Than One Minute!!", \
K(sleep_time), \ "Throttle Unit Name", \
K(left_interval), \ ALLOCATOR::throttle_unit_name(), \
K(expected_wait_t)); \ K(sleep_time), \
} \ K(left_interval), \
K(expected_wait_t)); \
if (!has_printed_lbt) { \
has_printed_lbt = true; \
SHARE_LOG(WARN, \
"[Throttling] (report write throttle info) LBT Info", \
"Throttle Unit Name", \
ALLOCATOR::throttle_unit_name(), \
K(lbt())); \
} \
} \
} while (0) } while (0)
#define PRINT_THROTTLE_STATISTIC \ #define PRINT_THROTTLE_STATISTIC \
@ -226,6 +236,7 @@ void ObShareResourceThrottleTool<FakeAllocator, Args...>::do_throttle(const int6
// exit directly // exit directly
} else if (is_throttling<ALLOCATOR>(share_ti_guard, module_ti_guard)) { } else if (is_throttling<ALLOCATOR>(share_ti_guard, module_ti_guard)) {
// loop to do throttle // loop to do throttle
bool has_printed_lbt = false;
while (still_throttling<ALLOCATOR>(share_ti_guard, module_ti_guard) && left_interval > 0) { while (still_throttling<ALLOCATOR>(share_ti_guard, module_ti_guard) && left_interval > 0) {
int64_t expected_wait_t = min(left_interval, expected_wait_time<ALLOCATOR>(share_ti_guard, module_ti_guard)); int64_t expected_wait_t = min(left_interval, expected_wait_time<ALLOCATOR>(share_ti_guard, module_ti_guard));
if (expected_wait_t < 0) { if (expected_wait_t < 0) {