utime_t now = g_clock.now();
p.pop_running(running, now);
- if (running.empty()) {
+ if (running.empty())
continue;
- }
- dout(DBL) << "pt2" << dendl;
p.lock.Unlock();
if (p.event_lock)
p.event_lock->Lock();
dout(DBL) << "start callback " << *cit << dendl;
(*cit)->finish(0);
if (p.event_lock) {
- dout(DBL) << "pt3" << dendl;
p.event_lock->Unlock();
}
dout(DBL) << "finish callback " << *cit << dendl;
if (p.event_lock)
p.event_lock->Lock();
}
- if (p.event_lock) {
- dout(DBL) << "pt4" << dendl;
+ if (p.event_lock)
p.event_lock->Unlock();
- }
p.lock.Lock();
}
}
bool Timer::cancel_event(Context *callback)
{
- dout(DBL) << __func__ << ": " << callback << dendl;
+ dout(DBL) << __PRETTY_FUNCTION__ << ": " << callback << dendl;
lock.Lock();
bool ret = cancel_event_impl(callback, false);
void Timer::cancel_all_events(void)
{
- dout(DBL) << __func__ << dendl;
+ dout(DBL) << __PRETTY_FUNCTION__ << dendl;
lock.Lock();
cancel_all_events_impl(false);
SafeTimer::~SafeTimer()
{
- dout(DBL) << __func__ << dendl;
+ dout(DBL) << __PRETTY_FUNCTION__ << dendl;
t.shutdown();
}
bool SafeTimer::cancel_event(Context *callback)
{
- dout(DBL) << __func__ << ": " << callback << dendl;
+ dout(DBL) << __PRETTY_FUNCTION__ << ": " << callback << dendl;
assert(t.event_lock->is_locked());
void SafeTimer::cancel_all_events()
{
- dout(DBL) << __func__ << dendl;
+ dout(DBL) << __PRETTY_FUNCTION__ << dendl;
assert(t.event_lock->is_locked());