}
}
-Heartbeat::Heartbeat(int whoami,
- uint32_t nonce,
- const OSDMapService& service,
+Heartbeat::Heartbeat(const OSDMapService& service,
ceph::mon::Client& monc,
ceph::net::Messenger& front_msgr,
ceph::net::Messenger& back_msgr)
- : whoami{whoami},
- nonce{nonce},
- service{service},
+ : service{service},
monc{monc},
front_msgr{front_msgr},
back_msgr{back_msgr},
public:
using osd_id_t = int;
- Heartbeat(int whoami,
- uint32_t nonce,
- const OSDMapService& service,
+ Heartbeat(const OSDMapService& service,
ceph::mon::Client& monc,
ceph::net::Messenger& front_msgr,
ceph::net::Messenger& back_msgr);
seastar::future<> start_messenger(ceph::net::Messenger& msgr,
const entity_addrvec_t& addrs);
private:
- const int whoami;
- const uint32_t nonce;
const OSDMapService& service;
ceph::mon::Client& monc;
ceph::net::Messenger& front_msgr;
public_msgr{public_msgr},
monc{new ceph::mon::Client{public_msgr}},
mgrc{new ceph::mgr::Client{public_msgr, *this}},
- heartbeat{new Heartbeat{whoami, nonce, *this, *monc,
- hb_front_msgr, hb_back_msgr}},
+ heartbeat{new Heartbeat{*this, *monc, hb_front_msgr, hb_back_msgr}},
heartbeat_timer{[this] { update_heartbeat_peers(); }},
store{std::make_unique<ceph::os::CyanStore>(
local_conf().get_val<std::string>("osd_data"))}