| 367 | } |
| 368 | |
| 369 | T *front() { |
| 370 | ceph_assert(ceph_mutex_is_locked(m_pool->_lock)); |
| 371 | if (m_items.empty()) { |
| 372 | return NULL; |
| 373 | } |
| 374 | return m_items.front(); |
| 375 | } |
| 376 | void requeue_front(T *item) { |
| 377 | std::lock_guard pool_locker(m_pool->_lock); |
| 378 | _void_process_finish(nullptr); |
no test coverage detected