Method _linger_commit

src/osdc/Objecter.cc:646–677

}

void Objecter::_linger_commit(LingerOp *info, bs::error_code ec,
			      cb::list& outbl)
{
  std::unique_lock wl(info->watch_lock);
  ldout(cct, 10) << "_linger_commit " << info->linger_id << dendl;
  if (info->on_reg_commit) {
    asio::defer(service.get_executor(),
		asio::append(std::move(info->on_reg_commit),
			     ec, cb::list{}));
  }
  if (ec && info->on_notify_finish) {
    asio::defer(service.get_executor(),
		asio::append(std::move(info->on_notify_finish),
			     ec, cb::list{}));
  }

  // only tell the user the first time we do this
  info->registered = true;
  info->pobjver = NULL;

  if (!info->is_watch) {
    // make note of the notify_id
    auto p = outbl.cbegin();
    try {
      decode(info->notify_id, p);
      ldout(cct, 10) << "_linger_commit  notify_id=" << info->notify_id
		     << dendl;
    }
    catch (cb::error& e) {
    }
  }
}

class CB_DoWatchError {
  Objecter *objecter;