p->state == TransContext::STATE_IO_DONE);
}
-int BlueStore::_txc_finalize(OpSequencer *osr, TransContext *txc)
+void BlueStore::_txc_finalize(OpSequencer *osr, TransContext *txc)
{
dout(20) << __func__ << " osr " << osr << " txc " << txc
<< " onodes " << txc->onodes << dendl;
get_wal_key(txc->wal_txn->seq, &key);
txc->t->set(PREFIX_WAL, key, bl);
}
-
- return 0;
}
void BlueStore::_txc_finish_kv(TransContext *txc)
Context *onreadable_sync;
ObjectStore::Transaction::collect_contexts(
tls, &onreadable, &ondisk, &onreadable_sync);
- int r;
// set up the sequencer
OpSequencer *osr;
_txc_add_transaction(txc, &(*p));
}
- r = _txc_finalize(osr, txc);
- assert(r == 0);
+ _txc_finalize(osr, txc);
throttle_ops.get(txc->ops);
throttle_bytes.get(txc->bytes);
uint64_t offset, uint64_t length,
bool shared);
void _txc_add_transaction(TransContext *txc, Transaction *t);
- int _txc_finalize(OpSequencer *osr, TransContext *txc);
+ void _txc_finalize(OpSequencer *osr, TransContext *txc);
void _txc_state_proc(TransContext *txc);
void _txc_aio_submit(TransContext *txc);
void _txc_update_fm(TransContext *txc);