--(o->lru_refcnt);
/* assertions that o state has not changed across
* relock */
- assert(o->lru_refcnt == SENTINEL_REFCNT);
- assert(o->lru_flags & FLAG_INLRU);
+ ceph_assert(o->lru_refcnt == SENTINEL_REFCNT);
+ ceph_assert(o->lru_flags & FLAG_INLRU);
Object::Queue::iterator it =
Object::Queue::s_iterator_to(*o);
lane.q.erase(it);
LRU(int lanes, uint32_t _hiwat)
: n_lanes(lanes), evict_lane(0), lane_hiwat(_hiwat)
{
- assert(n_lanes > 0);
+ ceph_assert(n_lanes > 0);
qlane = new Lane[n_lanes];
}
lane.q.push_back(*o);
break;
default:
- abort();
+ ceph_abort();
break;
}
if (flags & FLAG_INITIAL)
struct Latch {
Partition* p;
LK* lock;
- insert_commit_data commit_data;
+ insert_commit_data commit_data{};
Latch() : p(nullptr), lock(nullptr) {}
};
}
TreeX(int n_part=1, int csz=127) : n_part(n_part), csz(csz) {
- assert(n_part > 0);
+ ceph_assert(n_part > 0);
part = new Partition[n_part];
for (int ix = 0; ix < n_part; ++ix) {
Partition& p = part[ix];
void drain(std::function<void(T*)> uref,
uint32_t flags = FLAG_NONE) {
/* clear a table, call supplied function on
- * each element found (e.g., retuns sentinel
+ * each element found (e.g., returns sentinel
* references) */
Object::Queue2 drain_q;
for (int t_ix = 0; t_ix < n_part; ++t_ix) {