using ceph::mono_clock;
using ceph::mono_time;
+static const auto& APP_NAME_CEPHFS = pg_pool_t::APPLICATION_NAME_CEPHFS;
+
class FlagSetHandler : public FileSystemCommandHandler
{
public:
mon->osdmon()->wait_for_writeable(op, new PaxosService::C_RetryMessage(mon->mdsmon(), op));
return -EAGAIN;
}
- mon->osdmon()->do_application_enable(data,
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "data", fs_name, true);
- mon->osdmon()->do_application_enable(metadata,
- pg_pool_t::APPLICATION_NAME_CEPHFS,
+ mon->osdmon()->do_application_enable(data, APP_NAME_CEPHFS, "data",
+ fs_name, true);
+ mon->osdmon()->do_application_enable(metadata, APP_NAME_CEPHFS,
"metadata", fs_name, true);
mon->osdmon()->do_set_pool_opt(metadata,
pool_opts_t::RECOVERY_PRIORITY,
mon->osdmon()->wait_for_writeable(op, new PaxosService::C_RetryMessage(mon->mdsmon(), op));
return -EAGAIN;
}
- mon->osdmon()->do_application_enable(poolid,
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "data", fs_name, true);
+ mon->osdmon()->do_application_enable(poolid, APP_NAME_CEPHFS, "data",
+ fs_name, true);
mon->osdmon()->propose_pending();
fsmap.modify_filesystem(
return -EAGAIN;
}
for (const auto p : fs->mds_map.get_data_pools()) {
- mon->osdmon()->do_application_enable(p,
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "data", new_fs_name, true);
+ mon->osdmon()->do_application_enable(p, APP_NAME_CEPHFS, "data",
+ new_fs_name, true);
}
- mon->osdmon()->do_application_enable(fs->mds_map.get_metadata_pool(),
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "metadata", new_fs_name, true);
+ mon->osdmon()->do_application_enable(
+ fs->mds_map.get_metadata_pool(), APP_NAME_CEPHFS, "metadata",
+ new_fs_name, true);
mon->osdmon()->propose_pending();
auto f = [new_fs_name](auto fs) {
// Finally, the swap begins.
// Swap CephFS names on OSD pool application tag
for (const auto p : fs1p->get_mds_map().get_data_pools()) {
- mon->osdmon()->do_application_enable(p,
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "data", fs2_name, true);
+ mon->osdmon()->do_application_enable(p, APP_NAME_CEPHFS, "data",
+ fs2_name, true);
}
- mon->osdmon()->do_application_enable(fs1p->get_mds_map().get_metadata_pool(),
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "metadata", fs2_name, true);
+ mon->osdmon()->do_application_enable(
+ fs1p->get_mds_map().get_metadata_pool(), APP_NAME_CEPHFS, "metadata",
+ fs2_name, true);
for (const auto p : fs2p->get_mds_map().get_data_pools()) {
- mon->osdmon()->do_application_enable(p,
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "data", fs1_name, true);
+ mon->osdmon()->do_application_enable(p, APP_NAME_CEPHFS, "data",
+ fs1_name, true);
}
- mon->osdmon()->do_application_enable(fs2p->get_mds_map().get_metadata_pool(),
- pg_pool_t::APPLICATION_NAME_CEPHFS,
- "metadata", fs1_name, true);
+ mon->osdmon()->do_application_enable(
+ fs2p->get_mds_map().get_metadata_pool(), APP_NAME_CEPHFS, "metadata",
+ fs1_name, true);
mon->osdmon()->propose_pending();
// Now swap CephFS names and, optionally, FSCIDs.
auto app_map = pool->application_metadata;
if (!allow_overlay && !force && !app_map.empty()) {
- auto app = app_map.find(pg_pool_t::APPLICATION_NAME_CEPHFS);
+ auto app = app_map.find(APP_NAME_CEPHFS);
if (app != app_map.end()) {
auto& [app_name, app_metadata] = *app;
auto itr = app_metadata.find("data");
}
if (!force && !pool->application_metadata.empty() &&
- pool->application_metadata.count(
- pg_pool_t::APPLICATION_NAME_CEPHFS) == 0) {
+ pool->application_metadata.count(APP_NAME_CEPHFS) == 0) {
*ss << " pool '" << pool_name << "' (id '" << pool_id
<< "') has a non-CephFS application enabled.";
return -EINVAL;