Signed-off-by: David Zafman <dzafman@redhat.com>
scrub_finalize_wq(cct->_conf->osd_scrub_finalize_thread_timeout, &osd_tp),
rep_scrub_wq(this, cct->_conf->osd_scrub_thread_timeout, &disk_tp),
remove_wq(store, cct->_conf->osd_remove_thread_timeout, &disk_tp),
- next_removal_seq(0),
service(this)
{
monc->set_messenger(client_messenger);
remove_queue.clear();
}
} remove_wq;
- uint64_t next_removal_seq;
- coll_t get_next_removal_coll(spg_t pgid) {
- return coll_t::make_removal_coll(next_removal_seq++, pgid);
- }
private:
bool ms_can_fast_dispatch_any() const { return true; }
return coll_t(pg_to_tmp_str(pgid));
}
- static coll_t make_removal_coll(uint64_t seq, spg_t pgid) {
- return coll_t(seq_to_removal_str(seq, pgid));
- }
-
const std::string& to_str() const {
return str;
}
oss << p << "_TEMP";
return oss.str();
}
- static std::string seq_to_removal_str(uint64_t seq, spg_t pgid) {
- std::ostringstream oss;
- oss << "FORREMOVAL_" << seq << "_" << pgid;
- return oss.str();
- }
std::string str;
};