*/
PG *OSD::get_or_create_pg(
const pg_info_t& info, pg_interval_map_t& pi,
- epoch_t epoch, int from, int& created, bool primary,
- OpRequestRef op)
+ epoch_t epoch, int from, int& created, bool primary)
{
PG *pg;
}
pg = get_or_create_pg(it->first.info, it->second,
- it->first.query_epoch, from, created, true, op);
+ it->first.query_epoch, from, created, true);
if (!pg)
continue;
pg->queue_notify(it->first.epoch_sent, it->first.query_epoch, from, it->first);
int created = 0;
PG *pg = get_or_create_pg(m->info, m->past_intervals, m->get_epoch(),
- from, created, false, op);
+ from, created, false);
if (!pg)
return;
op->mark_started();
continue;
}
PG *pg = get_or_create_pg(p->first.info, p->second, p->first.epoch_sent,
- from, created, false, op);
+ from, created, false);
if (!pg)
continue;
pg->queue_info(p->first.epoch_sent, p->first.query_epoch, from,
PG *get_or_create_pg(const pg_info_t& info,
pg_interval_map_t& pi,
epoch_t epoch, int from, int& pcreated,
- bool primary,
- OpRequestRef op);
+ bool primary);
void load_pgs();
void build_past_intervals_parallel();