bluestore: check return value of db->submit_transaction() by assert(0 == r)

Signed-off-by: Dongsheng Yang <dongsheng.yang@easystack.cn>

diff --git a/src/os/bluestore/BlueStore.cc b/src/os/bluestore/BlueStore.cc
index 33750ed055a24922a537eeed3466a1eb6a1c8e43..ccf5ad91d925d90a8b48fc77d5f207235ec71015 100644 (file)
--- a/src/os/bluestore/BlueStore.cc
+++ b/src/os/bluestore/BlueStore.cc
@@ -1785,7 +1785,7 @@ int BlueStore::mkfs()
     } else {
       fm->release(reserved, end, t);
     }
-    db->submit_transaction_sync(t);
+    assert(0 == db->submit_transaction_sync(t));
   }
 
   r = write_meta("kv_backend", g_conf->bluestore_kvbackend);
@@ -3623,11 +3623,11 @@ void BlueStore::_txc_state_proc(TransContext *txc)
       if (!g_conf->bluestore_sync_transaction) {
        if (g_conf->bluestore_sync_submit_transaction) {
          _txc_update_fm(txc);
-         db->submit_transaction(txc->t);
+         assert(0 == db->submit_transaction(txc->t));
        }
       } else {
        _txc_update_fm(txc);
-       db->submit_transaction_sync(txc->t);
+       assert(0 == db->submit_transaction_sync(txc->t));
       }
       {
        std::lock_guard<std::mutex> l(kv_lock);
@@ -3929,7 +3929,7 @@ void BlueStore::_kv_sync_thread()
             it != kv_committing.end();
             ++it) {
          _txc_update_fm((*it));
-         db->submit_transaction((*it)->t);
+         assert(0 == db->submit_transaction((*it)->t));
        }
       }
 
@@ -3995,7 +3995,7 @@ void BlueStore::_kv_sync_thread()
        get_wal_key(wt.seq, &key);
        t->rmkey(PREFIX_WAL, key);
       }
-      db->submit_transaction_sync(t);
+      assert(0 == db->submit_transaction_sync(t));
 
       utime_t finish = ceph_clock_now(NULL);
       utime_t dur = finish - start;