pg->handle_initialize(&rctx);
pg->handle_activate_map(&rctx);
- rctx.created_pgs.insert(pg);
dispatch_context(rctx, pg.get(), osdmap, nullptr);
child->lock(true);
out_pgs->insert(child);
child->ch = store->create_new_collection(child->coll);
- rctx->created_pgs.insert(child);
unsigned split_bits = i->get_split_bits(pg_num);
dout(10) << " pg_num is " << pg_num
std::move(*ctx.transaction), TrackedOpRef(), handle);
assert(tr == 0);
delete (ctx.transaction);
- ctx.created_pgs.clear();
ctx.transaction = new ObjectStore::Transaction;
ctx.on_applied = new C_Contexts(cct);
ctx.on_safe = new C_Contexts(cct);
- ctx.created_pgs.clear();
}
}
delete ctx.info_map;
if ((ctx.on_applied->empty() &&
ctx.on_safe->empty() &&
- ctx.transaction->empty() &&
- ctx.created_pgs.empty()) || !pg) {
+ ctx.transaction->empty()) || !pg) {
delete ctx.transaction;
delete ctx.on_applied;
delete ctx.on_safe;
- assert(ctx.created_pgs.empty());
} else {
if (ctx.on_applied)
ctx.transaction->register_on_applied(ctx.on_applied);
pg->ch,
std::move(*ctx.transaction), TrackedOpRef(),
handle);
- ctx.created_pgs.clear();
delete (ctx.transaction);
assert(tr == 0);
- ctx.created_pgs.clear();
}
}
map<int, map<spg_t, pg_query_t> > *query_map;
map<int, vector<pair<pg_notify_t, PastIntervals> > > *info_map;
map<int, vector<pair<pg_notify_t, PastIntervals> > > *notify_list;
- set<PGRef> created_pgs;
C_Contexts *on_applied;
C_Contexts *on_safe;
ObjectStore::Transaction *transaction;