peering_wq.drain();
dout(0) << "done with init, starting boot process" << dendl;
+
+ // subscribe to any pg creations
+ monc->sub_want("osd_pg_creates", last_pg_create_epoch, 0);
+
+ // we don't need to ask for an osdmap here; objecter will
+ //monc->sub_want("osdmap", osdmap->get_epoch(), CEPH_SUBSCRIBE_ONETIME);
+
+ monc->renew_subs();
+
start_boot();
return 0;
send_pg_stats(now);
map_lock.put_read();
-
- monc->sub_want("osd_pg_creates", last_pg_create_epoch, 0);
- monc->sub_want("osdmap", osdmap->get_epoch(), CEPH_SUBSCRIBE_ONETIME);
- monc->renew_subs();
}
// full map requests may happen while active or pre-boot