auto &&trigger) {
return shard_services.get_or_create_pg(
std::move(trigger),
- opref.get_pgid(), opref.get_epoch(),
+ opref.get_pgid(),
std::move(opref.get_create_info())
);
}).safe_then([&logger, &shard_services, &opref](Ref<PG> pgref) {
ShardServices::get_or_create_pg(
PGMap::PGCreationBlockingEvent::TriggerI&& trigger,
spg_t pgid,
- epoch_t epoch,
std::unique_ptr<PGCreateInfo> info)
{
if (info) {
get_or_create_pg_ret get_or_create_pg(
PGMap::PGCreationBlockingEvent::TriggerI&&,
spg_t pgid,
- epoch_t epoch,
std::unique_ptr<PGCreateInfo> info);
using wait_for_pg_ertr = PGMap::wait_for_pg_ertr;