ondisk_finisher(g_ceph_context),
collections_lock("KeyValueStore::collections_lock"),
lock("KeyValueStore::lock"),
- default_osr("default"),
throttle_ops(g_ceph_context, "keyvaluestore_ops", g_conf->keyvaluestore_queue_max_ops),
throttle_bytes(g_ceph_context, "keyvaluestore_bytes", g_conf->keyvaluestore_queue_max_bytes),
op_finisher(g_ceph_context),
// set up the sequencer
OpSequencer *osr;
- if (!posr)
- posr = &default_osr;
+ assert(posr);
if (posr->p) {
osr = static_cast<OpSequencer *>(posr->p.get());
dout(5) << "queue_transactions existing " << *osr << "/" << osr->parent
friend ostream& operator<<(ostream& out, const OpSequencer& s);
- Sequencer default_osr;
deque<OpSequencer*> op_queue;
Throttle throttle_ops, throttle_bytes;
Finisher op_finisher;