else if (r > 0)
rval += r;
}
- assert(pending_complete);
+ ceph_assert(pending_complete);
int count = --pending_complete;
if (!count && !building) {
complete();
if (r < 0 && r != -EEXIST)
rval = r;
}
- assert(pending_safe);
+ ceph_assert(pending_safe);
int count = --pending_safe;
if (!count && !building) {
safe();
void libradosstriper::MultiAioCompletionImpl::finish_adding_requests()
{
lock.Lock();
- assert(building);
+ ceph_assert(building);
building = false;
if (!pending_complete)
complete();
lock.Unlock();
}
void _get() {
- assert(lock.is_locked());
- assert(ref > 0);
+ ceph_assert(lock.is_locked());
+ ceph_assert(ref > 0);
++ref;
}
void put() {
put_unlock();
}
void put_unlock() {
- assert(ref > 0);
+ ceph_assert(ref > 0);
int n = --ref;
lock.Unlock();
if (!n)
lock.Unlock();
}
void complete() {
- assert(lock.is_locked());
+ ceph_assert(lock.is_locked());
if (callback_complete) {
callback_complete(this, callback_complete_arg);
callback_complete = 0;
cond.Signal();
}
void safe() {
- assert(lock.is_locked());
+ ceph_assert(lock.is_locked());
if (callback_safe) {
callback_safe(this, callback_safe_arg);
callback_safe = 0;
libradosstriper::MultiAioCompletion::~MultiAioCompletion()
{
- assert(pc->ref == 1);
+ ceph_assert(pc->ref == 1);
pc->put();
}
{
MultiAioCompletionImpl *c;
int r = rados_striper_multi_aio_create_completion(cb_arg, cb_complete, cb_safe, (void**)&c);
- assert(r == 0);
+ ceph_assert(r == 0);
return new MultiAioCompletion(c);
}