]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
bluestore: change the return type of _txc_finalize to void
authorDongsheng Yang <dongsheng.yang@easystack.cn>
Thu, 14 Apr 2016 10:37:48 +0000 (18:37 +0800)
committerDongsheng Yang <dongsheng.yang@easystack.cn>
Mon, 25 Apr 2016 04:57:53 +0000 (00:57 -0400)
Signed-off-by: Dongsheng Yang <dongsheng.yang@easystack.cn>
src/os/bluestore/BlueStore.cc
src/os/bluestore/BlueStore.h

index ccf5ad91d925d90a8b48fc77d5f207235ec71015..08641316c6f659a4f55103887317ada8ee034201 100644 (file)
@@ -3720,7 +3720,7 @@ void BlueStore::_txc_finish_io(TransContext *txc)
           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;
@@ -3764,8 +3764,6 @@ int BlueStore::_txc_finalize(OpSequencer *osr, TransContext *txc)
     get_wal_key(txc->wal_txn->seq, &key);
     txc->t->set(PREFIX_WAL, key, bl);
   }
-
-  return 0;
 }
 
 void BlueStore::_txc_finish_kv(TransContext *txc)
@@ -4262,7 +4260,6 @@ int BlueStore::queue_transactions(
   Context *onreadable_sync;
   ObjectStore::Transaction::collect_contexts(
     tls, &onreadable, &ondisk, &onreadable_sync);
-  int r;
 
   // set up the sequencer
   OpSequencer *osr;
@@ -4290,8 +4287,7 @@ int BlueStore::queue_transactions(
     _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);
index 91aec621603bc71d6e2e71dd8a008e5d07aecd23..ba0fa06a4f7fa7e02df65d2ee9d19a72f211083b 100644 (file)
@@ -609,7 +609,7 @@ private:
                    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);