{
pg->lock();
dout(10) << *pg << " generate_backlog" << dendl;
-
+ assert(!pg->is_active());
+
map<eversion_t,PG::Log::Entry> omap;
if (!pg->build_backlog_map(omap))
goto out;
dout(10) << *pg << " generate_backlog aborting" << dendl;
goto out2;
}
+ assert(!pg->is_active());
if (!pg->is_primary()) {
dout(10) << *pg << " sending info+missing+backlog to primary" << dendl;
messenger->send_message(m, osdmap->get_inst(pg->get_primary()));
} else {
dout(10) << *pg << " generated backlog, peering" << dendl;
- assert(!pg->is_active());
map< int, map<pg_t,PG::Query> > query_map; // peer -> PG -> get_summary_since
ObjectStore::Transaction t;