diff --git a/src/common/WorkQueue.cc b/src/common/WorkQueue.cc index e419e84e33a..6fd9044483e 100644 --- a/src/common/WorkQueue.cc +++ b/src/common/WorkQueue.cc @@ -107,8 +107,8 @@ void ThreadPool::worker(WorkThread *wt) if (item) { processing++; ldout(cct,12) << "worker wq " << wq->name << " start processing " << item << dendl; - _lock.Unlock(); cct->get_heartbeat_map()->reset_timeout(hb, wq->timeout_interval, wq->suicide_interval); + _lock.Unlock(); wq->_void_process(item); _lock.Lock(); wq->_void_process_finish(item);