template <typename I>
void PoolReplayer<I>::shut_down() {
+ dout(20) << dendl;
{
std::lock_guard l{m_lock};
m_stopping = true;
const std::string &description,
RadosRef *rados_ref,
bool strip_cluster_overrides) {
+ dout(10) << "cluster_name=" << cluster_name << ", client_name=" << client_name
+ << ", mon_host=" << mon_host << ", strip_cluster_overrides="
+ << strip_cluster_overrides << dendl;
+
// NOTE: manually bootstrap a CephContext here instead of via
// the librados API to avoid mixing global singletons between
// the librados shared library and the daemon
template <typename I>
int PoolReplayer<I>::list_mirroring_namespaces(
std::set<std::string> *namespaces) {
+ dout(20) << dendl;
ceph_assert(ceph_mutex_is_locked(m_lock));
std::vector<std::string> names;
template <typename I>
void PoolReplayer<I>::reopen_logs()
{
+ dout(20) << dendl;
std::lock_guard locker{m_lock};
if (m_local_rados) {
template <typename I>
void PoolReplayer<I>::namespace_replayer_acquire_leader(const std::string &name,
Context *on_finish) {
+ dout(20) << dendl;
ceph_assert(ceph_mutex_is_locked(m_lock));
auto it = m_namespace_replayers.find(name);