#define DEPRECATED_CEPH_FEATURE_INDEP_PG_MAP (1ULL<<17) // DEPRECATED: JEWEL
#define CEPH_FEATURE_CRUSH_TUNABLES (1ULL<<18)
#define DEPRECATED_CEPH_FEATURE_CHUNKY_SCRUB (1ULL<<19) // DEPRECATED: JEWEL
-#define CEPH_FEATURE_MON_NULLROUTE (1ULL<<20)
+#define DEPRECATED_CEPH_FEATURE_MON_NULLROUTE (1ULL<<20) // DEPRECATED: JEWEL
#define CEPH_FEATURE_MON_GV (1ULL<<21)
#define CEPH_FEATURE_BACKFILL_RESERVATION (1ULL<<22)
#define CEPH_FEATURE_MSG_AUTH (1ULL<<23)
DEPRECATED_CEPH_FEATURE_INDEP_PG_MAP | \
CEPH_FEATURE_CRUSH_TUNABLES | \
DEPRECATED_CEPH_FEATURE_CHUNKY_SCRUB | \
- CEPH_FEATURE_MON_NULLROUTE | \
+ DEPRECATED_CEPH_FEATURE_MON_NULLROUTE | \
CEPH_FEATURE_MON_GV | \
CEPH_FEATURE_BACKFILL_RESERVATION | \
CEPH_FEATURE_MSG_AUTH | \
void encode_payload(uint64_t features) {
::encode(session_mon_tid, payload);
::encode(dest, payload);
- if ((features & CEPH_FEATURE_MON_NULLROUTE) == 0) {
- header.version = 1;
- header.compat_version = 1;
- assert(msg);
- encode_message(msg, features, payload);
- return;
- }
bool m = msg ? true : false;
::encode(m, payload);
if (msg)
Message *req = op->get_req();
if (session->proxy_con) {
- if (get_quorum_features() & CEPH_FEATURE_MON_NULLROUTE) {
- dout(10) << "no_reply to " << req->get_source_inst()
- << " via " << session->proxy_con->get_peer_addr()
- << " for request " << *req << dendl;
- session->proxy_con->send_message(new MRoute(session->proxy_tid, NULL));
- op->mark_event("no_reply: send routed request");
- } else {
- dout(10) << "no_reply no quorum nullroute feature for "
- << req->get_source_inst()
- << " via " << session->proxy_con->get_peer_addr()
- << " for request " << *req << dendl;
- op->mark_event("no_reply: no quorum support");
- }
+ dout(10) << "no_reply to " << req->get_source_inst()
+ << " via " << session->proxy_con->get_peer_addr()
+ << " for request " << *req << dendl;
+ session->proxy_con->send_message(new MRoute(session->proxy_tid, NULL));
+ op->mark_event("no_reply: send routed request");
} else {
dout(10) << "no_reply to " << req->get_source_inst()
<< " " << *req << dendl;