pair<RecoveryMessages *, read_result_t &> arg(
m, resiter->second);
reqiter->second.cb->complete(arg);
- reqiter->second.cb = NULL;
+ reqiter->second.cb = nullptr;
}
}
tid_to_read_map.erase(rop.tid);
<< " for obj " << *i << dendl;
assert(req.cb);
delete req.cb;
- req.cb = NULL;
+ req.cb = nullptr;
op.to_read.erase(*i);
op.complete.erase(*i);
j != i->second.to_read.end();
++j) {
delete j->second.cb;
- j->second.cb = 0;
+ j->second.cb = nullptr;
}
}
tid_to_read_map.clear();
bool async_read_started = false;
object_copy_data_t _reply_obj;
- C_CopyFrom_AsyncReadCb *cb = NULL;
+ C_CopyFrom_AsyncReadCb *cb = nullptr;
if (pool.info.require_rollback()) {
cb = new C_CopyFrom_AsyncReadCb(&osd_op, features);
}
{
assert(lock.is_locked_by_me());
dout(10) << "timeout" << dendl;
- cb = NULL;
+ cb = nullptr;
if (is_discarded()) {
lock.Unlock();
return;
{
osd->watch_lock.Lock();
osd->watch_timer.cancel_event(cb);
- cb = NULL;
+ cb = nullptr;
osd->watch_lock.Unlock();
}
}
boost::intrusive_ptr<PrimaryLogPG> pg(watch->pg);
osd->watch_lock.Unlock();
pg->lock();
- watch->cb = NULL;
+ watch->cb = nullptr;
if (!watch->is_discarded() && !canceled)
watch->pg->handle_watch_timeout(watch);
delete this; // ~Watch requires pg lock!
OSDService *osd(watch->osd);
dout(10) << "HandleWatchTimeoutDelayed" << dendl;
assert(watch->pg->is_locked());
- watch->cb = NULL;
+ watch->cb = nullptr;
if (!watch->is_discarded() && !canceled)
watch->pg->handle_watch_timeout(watch);
}
Mutex::Locker l(osd->watch_lock);
osd->watch_timer.cancel_event(cb); // harmless if not registered with timer
}
- cb = NULL;
+ cb = nullptr;
}
void Watch::got_ping(utime_t t)