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());
<< 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();
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 "
<< "-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);
<< 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) {