return seastar::now();
}
}).then([this] {
- return heartbeat->start(public_msgr.get_myaddrs(),
- cluster_msgr.get_myaddrs());
+ return heartbeat->start(public_msgr->get_myaddrs(),
+ cluster_msgr->get_myaddrs());
+ }).then([this] {
+ // create the admin-socket server, and the objects that register
+ // to handle incoming commands
+ return start_asok_admin();
}).then([this] {
return start_boot();
});
std::unique_ptr<Heartbeat> heartbeat;
seastar::timer<seastar::lowres_clock> heartbeat_timer;
+ // admin-socket
+ seastar::lw_shared_ptr<crimson::admin::AdminSocket> asok;
+
public:
OSD(int id, uint32_t nonce,
- crimson::net::Messenger& cluster_msgr,
- crimson::net::Messenger& client_msgr,
- crimson::net::Messenger& hb_front_msgr,
- crimson::net::Messenger& hb_back_msgr);
+ crimson::net::MessengerRef cluster_msgr,
+ crimson::net::MessengerRef client_msgr,
+ crimson::net::MessengerRef hb_front_msgr,
+ crimson::net::MessengerRef hb_back_msgr);
~OSD() final;
seastar::future<> mkfs(uuid_d osd_uuid, uuid_d cluster_fsid);