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

enable replay clog before ObServerCheckpointSlogHandler started

Browse Source
This commit is contained in:
windye 2023-08-25 02:40:29 +00:00 committed by ob-robot
parent 44e77d6cf7
commit 285799da2f
3 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/observer/ob_server.cpp
View File

@ -874,12 +874,6 @@ int ObServer::start()
FLOG_INFO("success to start server checkpoint slog handler");
}
if (FAILEDx(ObServerCheckpointSlogHandler::enable_replay_clog())) {
LOG_ERROR("fail to enable replay clog", KR(ret));
} else {
FLOG_INFO("success to enable replay clog");
}
if (FAILEDx(log_block_mgr_.start(storage_env_.log_disk_size_))) {
LOG_ERROR("fail to start log pool", KR(ret));
} else {

4
src/storage/slog_ckpt/ob_server_checkpoint_slog_handler.cpp
View File

@ -113,6 +113,8 @@ int ObServerCheckpointSlogHandler::start()
LOG_WARN("fail to try write checkpoint for compat", K(ret));
} else if (OB_FAIL(finish_slog_replay())) {
LOG_ERROR("fail to finish slog replay", KR(ret));
} else if (OB_FAIL(enable_replay_clog())) {
LOG_ERROR("fail to enable replay clog", KR(ret));
} else if (OB_FAIL(task_timer_.start())) { // start checkpoint task after finsh replay slog
LOG_WARN("fail to start task timer", K(ret));
} else {
@ -242,6 +244,7 @@ int ObServerCheckpointSlogHandler::finish_slog_replay()
}
}
}
FLOG_INFO("finish slog replay", K(ret));
return ret;
}
@ -251,6 +254,7 @@ int ObServerCheckpointSlogHandler::enable_replay_clog()
common::ObArray<uint64_t> tenant_ids;
omt::ObMultiTenant *omt = GCTX.omt_;
ObTransferService *transfer_service = nullptr;
if (OB_ISNULL(omt)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected error, omt is nullptr", K(ret));

2
src/storage/slog_ckpt/ob_server_checkpoint_slog_handler.h
View File

@ -74,7 +74,6 @@ public:
int load_all_tenant_metas(); // for obadmin
int write_tenant_super_block_slog(const ObTenantSuperBlock &super_block);
const TENANT_META_MAP &get_tenant_meta_map() const { return tenant_meta_map_for_replay_; } // for obadmin
static int enable_replay_clog();
private:
@ -102,6 +101,7 @@ private:
int handle_tenant_deleting(const uint64_t tenant_id);
int finish_slog_replay();
static int enable_replay_clog();
int mock_start(); // for test;
private: