service.cancel_pending_splits_for_parent(pg->info.pgid);
+ store->queue_transaction(
+ pg->osr.get(), rmt,
+ new ObjectStore::C_DeleteTransactionHolder<
+ SequencerRef>(rmt, pg->osr),
+ new ContainerContext<
+ SequencerRef>(pg->osr));
+
DeletingStateRef deleting = service.deleting_pgs.lookup_or_create(
pg->info.pgid,
make_pair(
);
remove_wq.queue(make_pair(PGRef(pg), deleting));
- store->queue_transaction(
- pg->osr.get(), rmt,
- new ObjectStore::C_DeleteTransactionHolder<
- SequencerRef>(rmt, pg->osr),
- new ContainerContext<
- SequencerRef>(pg->osr));
-
// remove from map
pg_map.erase(pg->info.pgid);
pg->put("PGMap"); // since we've taken it out of map