MCPcopy Create free account
hub / github.com/ceph/ceph / _void_dequeue

Method _void_dequeue

src/common/WorkQueue.h:343–353  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

341 return m_items.empty();
342 }
343 void *_void_dequeue() override {
344 ceph_assert(ceph_mutex_is_locked(m_pool->_lock));
345 if (m_items.empty()) {
346 return NULL;
347 }
348
349 ++m_processing;
350 T *item = m_items.front();
351 m_items.pop_front();
352 return item;
353 }
354 void _void_process(void *item, ThreadPool::TPHandle &handle) override {
355 process(reinterpret_cast<T *>(item));
356 }

Callers

nothing calls this directly

Calls 3

emptyMethod · 0.45
frontMethod · 0.45
pop_frontMethod · 0.45

Tested by

no test coverage detected