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

adjust FETCH_LS_VIEW_INFO_TIMEOUT to 1min

Browse Source
This commit is contained in:
hamstersox 2023-07-04 02:12:28 +00:00 committed by ob-robot
parent e97d5f54bc
commit 95be350cd2
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/high_availability/ob_storage_ha_reader.h
View File

@ -679,7 +679,7 @@ public:
obrpc::ObCopyTabletInfo &tablet_info) override;
private:
static const int64_t FETCH_LS_VIEW_INFO_TIMEOUT = 10 * 60 * 1000 * 1000; // 10min // TODO(chongrong.th) change timeout to 1min later,
static const int64_t FETCH_LS_VIEW_INFO_TIMEOUT = 60 * 1000 * 1000; // 1min
bool is_inited_;
ObLSMetaPackage ls_meta_;
ObStorageStreamRpcReader<obrpc::OB_HA_FETCH_LS_VIEW> rpc_reader_;

6
src/storage/ob_storage_rpc.cpp
View File

@ -1466,7 +1466,9 @@ int ObFetchTabletInfoP::process()
LOG_INFO("start to fetch tablet info", K(arg_));
last_send_time_ = ObTimeUtility::current_time();
const int64_t cost_time = 10 * 1000 * 1000;
common::ObTimeGuard timeguard("ObFetchTabletInfoP", cost_time);
timeguard.click();
if (NULL == (buf = reinterpret_cast<char*>(allocator_.alloc(OB_MALLOC_BIG_BLOCK_SIZE)))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
STORAGE_LOG(WARN, "failed to alloc migrate data buffer.", K(ret));
@ -1511,6 +1513,7 @@ int ObFetchTabletInfoP::process()
STORAGE_LOG(WARN, "failed to get next tablet meta info", K(ret));
}
} else if (tablet_count >= MAX_TABLET_NUM) {
timeguard.click();
if (this->result_.get_position() > 0 && OB_FAIL(flush_and_wait())) {
LOG_WARN("failed to flush and wait", K(ret), K(tablet_info));
} else {
@ -1525,6 +1528,7 @@ int ObFetchTabletInfoP::process()
tablet_count++;
}
}
timeguard.click();
if (OB_SUCC(ret)) {
if (arg_.need_check_seq_) {
if (OB_FAIL(compare_ls_rebuild_seq(arg_.tenant_id_, arg_.ls_id_, arg_.ls_rebuild_seq_))) {