if (!g_conf->bluestore_sync_transaction) {
if (g_conf->bluestore_sync_submit_transaction) {
_txc_update_fm(txc);
- assert(0 == db->submit_transaction(txc->t));
+ int r = db->submit_transaction(txc->t);
+ assert(r == 0);
}
} else {
_txc_update_fm(txc);
- assert(0 == db->submit_transaction_sync(txc->t));
+ int r = db->submit_transaction_sync(txc->t);
+ assert(r == 0);
}
{
std::lock_guard<std::mutex> l(kv_lock);
it != kv_committing.end();
++it) {
_txc_update_fm((*it));
- assert(0 == db->submit_transaction((*it)->t));
+ int r = db->submit_transaction((*it)->t);
+ assert(r == 0);
}
}
get_wal_key(wt.seq, &key);
t->rm_single_key(PREFIX_WAL, key);
}
- assert(0 == db->submit_transaction_sync(t));
+ int r = db->submit_transaction_sync(t);
+ assert(r == 0);
utime_t finish = ceph_clock_now(NULL);
utime_t dur = finish - start;