OPTION(bluestore_debug_randomize_serial_transaction, OPT_INT, 0)
OPTION(bluestore_debug_omit_block_device_write, OPT_BOOL, false)
OPTION(bluestore_debug_fsck_abort, OPT_BOOL, false)
+OPTION(bluestore_debug_omit_kv_commit, OPT_BOOL, false)
OPTION(bluestore_debug_permit_any_bdev_label, OPT_BOOL, false)
OPTION(bluestore_shard_finishers, OPT_BOOL, false)
<< dendl;
} else {
txc->state = TransContext::STATE_KV_SUBMITTED;
- int r = db->submit_transaction(txc->t);
+ int r = cct->_conf->bluestore_debug_omit_kv_commit ? 0 : db->submit_transaction(txc->t);
assert(r == 0);
_txc_applied_kv(txc);
}
for (auto txc : kv_submitting) {
assert(txc->state == TransContext::STATE_KV_QUEUED);
txc->log_state_latency(logger, l_bluestore_state_kv_queued_lat);
- int r = db->submit_transaction(txc->t);
+ int r = cct->_conf->bluestore_debug_omit_kv_commit ? 0 : db->submit_transaction(txc->t);
assert(r == 0);
_txc_applied_kv(txc);
--txc->osr->kv_committing_serially;
}
// submit synct synchronously (block and wait for it to commit)
- int r = db->submit_transaction_sync(synct);
+ int r = cct->_conf->bluestore_debug_omit_kv_commit ? 0 : db->submit_transaction_sync(synct);
assert(r == 0);
if (new_nid_max) {