txc->state = TransContext::STATE_KV_QUEUED;
if (!g_conf->kstore_sync_transaction) {
std::lock_guard<std::mutex> l(kv_lock);
- if (g_conf->kstore_sync_submit_transaction)
- assert(0 == db->submit_transaction(txc->t));
+ if (g_conf->kstore_sync_submit_transaction) {
+ int r = db->submit_transaction(txc->t);
+ assert(r == 0);
+ }
kv_queue.push_back(txc);
kv_cond.notify_one();
return;
}
- assert(0 == db->submit_transaction_sync(txc->t));
+ {
+ int r = db->submit_transaction_sync(txc->t);
+ assert(r == 0);
+ }
break;
case TransContext::STATE_KV_QUEUED:
for (std::deque<TransContext *>::iterator it = kv_committing.begin();
it != kv_committing.end();
++it) {
- assert(0 == db->submit_transaction((*it)->t));
+ int r = db->submit_transaction((*it)->t);
+ assert(r == 0);
}
}
- 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;
dout(20) << __func__ << " committed " << kv_committing.size()