dout(20) << " removing " << *p << " object " << *q << dendl;
t.remove(*p, *q);
}
- store->apply_transaction(t);
+ store->apply_transaction(service.meta_osr.get(), t);
}
}
}
// superblock and commit
write_superblock(t);
store->queue_transaction(
- 0,
+ service.meta_osr.get(),
_t,
new C_OnMapApply(&service, _t, pinned_maps, osdmap->get_epoch()),
0, 0);
superblock.compat_features.incompat.insert(CEPH_OSD_FEATURE_INCOMPAT_SHARDS);
ObjectStore::Transaction *t = new ObjectStore::Transaction;
write_superblock(*t);
- int err = store->queue_transaction_and_cleanup(NULL, t);
+ int err = store->queue_transaction_and_cleanup(service.meta_osr.get(), t);
assert(err == 0);
fs->set_allow_sharded_objects();
}