ceph::net::Messenger& hb_back_msgr)
: whoami{id},
nonce{nonce},
- beacon_timer{[this] { send_beacon(); }},
+ // do this in background
+ beacon_timer{[this] { (void)send_beacon(); }},
cluster_msgr{cluster_msgr},
public_msgr{public_msgr},
monc{new ceph::mon::Client{public_msgr, *this}},
local_conf().get_val<std::string>("osd_data"))},
shard_services{*this, cluster_msgr, public_msgr, *monc, *mgrc, *store},
heartbeat{new Heartbeat{shard_services, *monc, hb_front_msgr, hb_back_msgr}},
- heartbeat_timer{[this] { update_heartbeat_peers(); }},
+ // do this in background
+ heartbeat_timer{[this] { (void)update_heartbeat_peers(); }},
osdmap_gate("OSD::osdmap_gate", std::make_optional(std::ref(shard_services)))
{
osdmaps[0] = boost::make_local_shared<OSDMap>();
auto [fut, creating] = pg_map.get_pg(pgid, bool(info));
if (!creating && info) {
pg_map.set_creating(pgid);
- handle_pg_create_info(std::move(info));
+ (void)handle_pg_create_info(std::move(info));
}
return std::move(fut);
}
PG::~PG() {}
bool PG::try_flush_or_schedule_async() {
- shard_services.get_store().do_transaction(
+ (void)shard_services.get_store().do_transaction(
coll_ref,
ObjectStore::Transaction()).then(
[this, epoch=get_osdmap_epoch()]() {
void send_cluster_message(
int osd, Message *m,
epoch_t epoch, bool share_map_update=false) final {
- shard_services.send_to_osd(osd, m, epoch);
+ (void)shard_services.send_to_osd(osd, m, epoch);
}
void send_pg_created(pg_t pgid) final {
- shard_services.send_pg_created(pgid);
+ (void)shard_services.send_pg_created(pgid);
}
bool try_flush_or_schedule_async() final;