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

[CP] [ReplayService] replaying of block_tx gc log should be controlled

Browse Source
This commit is contained in:
yyy-hust
2023-10-20 09:40:00 +00:00
committed by ob-robot
parent da3ce13d95
commit cf53caa65a
2 changed files with 34 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/logservice/ob_garbage_collector.cpp
View File

@ -359,7 +359,8 @@ ObGCHandler::ObGCHandler() : is_inited_(false),
ls_(NULL), ls_(NULL),
gc_seq_invalid_member_(-1), gc_seq_invalid_member_(-1),
gc_start_ts_(OB_INVALID_TIMESTAMP), gc_start_ts_(OB_INVALID_TIMESTAMP),
block_tx_ts_(OB_INVALID_TIMESTAMP) block_tx_ts_(OB_INVALID_TIMESTAMP),
block_log_debug_time_(OB_INVALID_TIMESTAMP)
{ {
} }
@ -375,6 +376,7 @@ void ObGCHandler::reset()
ls_ = NULL; ls_ = NULL;
gc_start_ts_ = OB_INVALID_TIMESTAMP; gc_start_ts_ = OB_INVALID_TIMESTAMP;
block_tx_ts_ = OB_INVALID_TIMESTAMP; block_tx_ts_ = OB_INVALID_TIMESTAMP;
block_log_debug_time_ = OB_INVALID_TIMESTAMP;
log_sync_stopped_ = false; log_sync_stopped_ = false;
is_inited_ = false; is_inited_ = false;
} }
@ -585,8 +587,34 @@ int ObGCHandler::replay(const void *buffer,
} else { } else {
WLockGuard wlock_guard(rwlock_); WLockGuard wlock_guard(rwlock_);
ObGCLSLOGType log_type = static_cast<ObGCLSLOGType>(gc_log.get_log_type()); ObGCLSLOGType log_type = static_cast<ObGCLSLOGType>(gc_log.get_log_type());
(void)update_ls_gc_state_after_submit_log_(log_type, scn); share::ObTenantRole::Role tenant_role = MTL_GET_TENANT_ROLE_CACHE();
CLOG_LOG(INFO, "replay gc log", K(log_type)); if (ObGCLSLOGType::BLOCK_TABLET_TRANSFER_IN == log_type) {
if (is_invalid_tenant(tenant_role) || is_standby_tenant(tenant_role)) {
//block_tx log in standby tenant should replay after tenant_readable_scn surpassed max_decided_scn of current ls
SCN ls_max_decided_scn;
SCN tenant_readable_scn;
ObLSID ls_id = ls_->get_ls_id();
if (OB_FAIL(ls_->get_max_decided_scn(ls_max_decided_scn))) {
CLOG_LOG(WARN, "get_max_decided_scn failed", K(ls_id));
} else if (OB_FAIL(get_tenant_readable_scn_(tenant_readable_scn))) {
CLOG_LOG(WARN, "get_tenant_readable_scn_ failed", K(ls_id));
} else if (ls_max_decided_scn.is_valid() && tenant_readable_scn.is_valid() &&
tenant_readable_scn >= ls_max_decided_scn) {
// block_tx gc log can replay
} else {
ret = OB_EAGAIN;
if (palf_reach_time_interval(2 * 1000 * 1000, block_log_debug_time_)) {
CLOG_LOG(WARN, "BLOCK_TX log can not replay because tenant_readable_lsn is smaller"
" than ls_max_decided_scn", K(tenant_readable_scn), K(ls_max_decided_scn), K(ls_id));
}
}
}
}
if (OB_SUCC(ret)) {
(void)update_ls_gc_state_after_submit_log_(log_type, scn);
CLOG_LOG(INFO, "replay gc log", K(log_type), K(scn));
}
} }
return ret; return ret;
} }

4
src/logservice/ob_garbage_collector.h
View File

@ -276,7 +276,8 @@ public:
TO_STRING_KV(K(is_inited_), TO_STRING_KV(K(is_inited_),
K(gc_seq_invalid_member_), K(gc_seq_invalid_member_),
K(gc_start_ts_), K(gc_start_ts_),
K(block_tx_ts_)); K(block_tx_ts_),
K(block_log_debug_time_));
private: private:
typedef common::SpinRWLock RWLock; typedef common::SpinRWLock RWLock;
@ -348,6 +349,7 @@ private:
int64_t gc_seq_invalid_member_; //缓存gc检查当前ls不在成员列表时的轮次 int64_t gc_seq_invalid_member_; //缓存gc检查当前ls不在成员列表时的轮次
int64_t gc_start_ts_; int64_t gc_start_ts_;
int64_t block_tx_ts_; int64_t block_tx_ts_;
int64_t block_log_debug_time_;
bool log_sync_stopped_;//used for trans_service to kill trx, True means this replica may not be able to fully synchronize the logs. bool log_sync_stopped_;//used for trans_service to kill trx, True means this replica may not be able to fully synchronize the logs.
}; };