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

add wait guard to allow 509 tenant queue dynamic grow and shrink

Browse Source
This commit is contained in:
oceanoverflow
2023-08-31 03:40:42 +00:00
committed by ob-robot
parent 03b37d3730
commit 337b77b6e7
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/storage/ob_storage_rpc.cpp
View File

@ -27,9 +27,11 @@
#include "storage/tablet/ob_tablet_iterator.h" #include "storage/tablet/ob_tablet_iterator.h"
#include "storage/tablet/ob_tablet.h" #include "storage/tablet/ob_tablet.h"
#include "storage/high_availability/ob_storage_ha_utils.h" #include "storage/high_availability/ob_storage_ha_utils.h"
#include "lib/thread/thread.h"
namespace oceanbase namespace oceanbase
{ {
using namespace lib;
using namespace common; using namespace common;
using namespace share; using namespace share;
using namespace obrpc; using namespace obrpc;
@ -1230,6 +1232,7 @@ int ObStorageStreamRpcP<RPC_CODE>::flush_and_wait()
ret = OB_NOT_INIT; ret = OB_NOT_INIT;
STORAGE_LOG(WARN, "bandwidth_throttle_ must not null", K(ret)); STORAGE_LOG(WARN, "bandwidth_throttle_ must not null", K(ret));
} else { } else {
Thread::WaitGuard guard(Thread::WAIT_FOR_IO_EVENT);
if (OB_SUCCESS != (tmp_ret = bandwidth_throttle_->limit_out_and_sleep( if (OB_SUCCESS != (tmp_ret = bandwidth_throttle_->limit_out_and_sleep(
this->result_.get_position(), last_send_time_, max_idle_time))) { this->result_.get_position(), last_send_time_, max_idle_time))) {
STORAGE_LOG(WARN, "failed limit out band", K(tmp_ret)); STORAGE_LOG(WARN, "failed limit out band", K(tmp_ret));