+ logger().debug("{}: pg present", *this);
+ return this->template enter_stage<interruptor>(client_pp(*pg).await_map
+ ).then_interruptible([this, pg] {
+ return this->template with_blocking_event<
+ PG_OSDMapGate::OSDMapBlocker::BlockingEvent
+ >([this, pg](auto &&trigger) {
+ return pg->osdmap_gate.wait_for_map(
+ std::move(trigger), req->min_epoch);
+ });
+ }).then_interruptible([this, pg](auto) {
+ return pg->do_update_log_missing(req, conn);
+ });