paxos_service[PAXOS_HEALTH].reset(new HealthMonitor(*this, *paxos, "health"));
paxos_service[PAXOS_CONFIG].reset(new ConfigMonitor(*this, *paxos, "config"));
paxos_service[PAXOS_KV].reset(new KVMonitor(*this, *paxos, "kv"));
-#ifdef WITH_NVMEOF_GATEWAY_MONITOR
paxos_service[PAXOS_NVMEGW].reset(new NVMeofGwMon(*this, *paxos, "nvmeofgw"));
-#endif
bool r = mon_caps.parse("allow *", NULL);
ceph_assert(r);
mgrmon()->dispatch(op);
return;
}
-#ifdef WITH_NVMEOF_GATEWAY_MONITOR
if (module == "nvme-gw"){
nvmegwmon()->dispatch(op);
return;
}
-#endif
if (prefix == "fsid") {
if (f) {
f->open_object_section("fsid");
paxos_service[PAXOS_MGR]->dispatch(op);
return;
-#ifdef WITH_NVMEOF_GATEWAY_MONITOR
case MSG_MNVMEOF_GW_BEACON:
paxos_service[PAXOS_NVMEGW]->dispatch(op);
return;
-#endif
// MgrStat
} else if (p->first.find("kv:") == 0) {
kvmon()->check_sub(s->sub_map[p->first]);
}
-#ifdef WITH_NVMEOF_GATEWAY_MONITOR
else if (p->first == "NVMeofGw") {
nvmegwmon()->check_sub(s->sub_map[p->first]);
}
-#endif
}
if (reply) {
#define CEPH_MON_PROTOCOL 13 /* cluster internal */
-// NVMe-oF gateway monitor and HA is disabled by default upstream for now.
-// see doc/nvmeof/ha.md for more details
-//#define WITH_NVMEOF_GATEWAY_MONITOR
enum {
l_cluster_first = 555000,
}
class NVMeofGwMon *nvmegwmon() {
-#ifdef WITH_NVMEOF_GATEWAY_MONITOR
return (class NVMeofGwMon*) paxos_service[PAXOS_NVMEGW].get();
-#else
- return nullptr;
-#endif
}