]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
key_value_store: Use ceph_assert for asserts.
authorAdam C. Emerson <aemerson@redhat.com>
Thu, 23 Aug 2018 15:24:28 +0000 (11:24 -0400)
committerAdam C. Emerson <aemerson@redhat.com>
Mon, 27 Aug 2018 13:35:43 +0000 (09:35 -0400)
Signed-off-by: Adam C. Emerson <aemerson@redhat.com>
src/key_value_store/kv_flat_btree_async.cc

index 1f3e830e7fddccbeedec2b17b652ebdc14ce66e7..942aa61b5f47ab10cf6f5c0b884e2801087f2dce 100644 (file)
@@ -279,7 +279,7 @@ int KvFlatBtreeAsync::read_index(const string &key, index_data * idata,
     cerr << "\t" << client_name
        << "-read_index: getting keys failed with "
        << err << std::endl;
-    assert(0 == client_name + "-read_index: reading index failed");
+    ceph_assert(0 == client_name + "-read_index: reading index failed");
     return err;
   }
   kvmap.insert(dupmap.begin(), dupmap.end());
@@ -315,7 +315,7 @@ int KvFlatBtreeAsync::read_index(const string &key, index_data * idata,
       << kvmap.size()
       << ", idata is " << idata->str() << std::endl;
 
-  assert(idata->obj != "");
+  ceph_assert(idata->obj != "");
   icache_lock.Lock();
   icache.push(key, *idata);
   icache_lock.Unlock();
@@ -561,7 +561,7 @@ int KvFlatBtreeAsync::rebalance(const index_data &idata1,
     ops.push_back(make_pair(
        pair<int, string>(MAKE_OBJECT, o2w),
        &create[0]));
-    assert((int)write2_map.size() <= 2*k);
+    ceph_assert((int)write2_map.size() <= 2*k);
   } else {
     //rebalance
     if (verbose) cout << "\t\t" << client_name << "-rebalance: rebalancing "
@@ -741,7 +741,7 @@ void KvFlatBtreeAsync::set_up_prefix_index(
        << "-setup_prefix: will assert "
        << this_entry.str() << std::endl;
   }
-  assert(*err == 0);
+  ceph_assert(*err == 0);
   owo->omap_cmp(assertions, err);
   if (to_create.size() <= 2) {
     owo->omap_set(to_insert);
@@ -996,7 +996,7 @@ int KvFlatBtreeAsync::cleanup(const index_data &idata, const int &error) {
       << idata.str()
       << std::endl;
   int err = 0;
-  assert(idata.prefix != "");
+  ceph_assert(idata.prefix != "");
   map<std::string,bufferlist> new_index;
   map<std::string, pair<bufferlist, int> > assertions;
   switch (error) {