implement delete_shared_tablet_dir for obAdmin
This commit is contained in:
@ -32,6 +32,7 @@ namespace storage
|
|||||||
|
|
||||||
ObTenantStorageMetaService::ObTenantStorageMetaService()
|
ObTenantStorageMetaService::ObTenantStorageMetaService()
|
||||||
: is_inited_(false),
|
: is_inited_(false),
|
||||||
|
is_started_(false),
|
||||||
is_shared_storage_(false),
|
is_shared_storage_(false),
|
||||||
ckpt_slog_handler_(),
|
ckpt_slog_handler_(),
|
||||||
slogger_(),
|
slogger_(),
|
||||||
@ -106,6 +107,9 @@ int ObTenantStorageMetaService::start()
|
|||||||
MTL(checkpoint::ObTabletGCService*)->set_mtl_start_max_block_id(macro_block_id);
|
MTL(checkpoint::ObTabletGCService*)->set_mtl_start_max_block_id(macro_block_id);
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
is_started_ = true;
|
||||||
|
}
|
||||||
FLOG_INFO("finish start ObTenantStorageMetaService", K(ret));
|
FLOG_INFO("finish start ObTenantStorageMetaService", K(ret));
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
@ -142,6 +146,7 @@ void ObTenantStorageMetaService::destroy()
|
|||||||
shared_object_rwriter_.reset();
|
shared_object_rwriter_.reset();
|
||||||
shared_object_raw_rwriter_.reset();
|
shared_object_raw_rwriter_.reset();
|
||||||
is_shared_storage_ = false;
|
is_shared_storage_ = false;
|
||||||
|
is_started_ = false;
|
||||||
is_inited_ = false;
|
is_inited_ = false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -39,6 +39,7 @@ public:
|
|||||||
void stop();
|
void stop();
|
||||||
void wait();
|
void wait();
|
||||||
void destroy();
|
void destroy();
|
||||||
|
bool is_started() { return is_started_; }
|
||||||
ObTenantStorageMetaPersister &get_persister() { return persister_; }
|
ObTenantStorageMetaPersister &get_persister() { return persister_; }
|
||||||
ObTenantStorageMetaReplayer &get_replayer() { return replayer_; }
|
ObTenantStorageMetaReplayer &get_replayer() { return replayer_; }
|
||||||
ObTenantSeqGenerator &get_seq_generator() { return seq_generator_; }
|
ObTenantSeqGenerator &get_seq_generator() { return seq_generator_; }
|
||||||
@ -138,6 +139,7 @@ private:
|
|||||||
#endif
|
#endif
|
||||||
private:
|
private:
|
||||||
bool is_inited_;
|
bool is_inited_;
|
||||||
|
bool is_started_;
|
||||||
bool is_shared_storage_;
|
bool is_shared_storage_;
|
||||||
ObTenantCheckpointSlogHandler ckpt_slog_handler_;
|
ObTenantCheckpointSlogHandler ckpt_slog_handler_;
|
||||||
storage::ObStorageLogger slogger_;
|
storage::ObStorageLogger slogger_;
|
||||||
|
Reference in New Issue
Block a user