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

Method dequeue

src/common/QueueRing.h:34–42  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

32 }
33
34 void dequeue(T *entry) {
35 std::unique_lock l(lock);
36 while (entries.empty()) {
37 cond.wait(l);
38 };
39 ceph_assert(!entries.empty());
40 *entry = entries.front();
41 entries.pop_front();
42 };
43 };
44
45 std::vector<QueueBucket> buckets;

Callers

nothing calls this directly

Calls 4

emptyMethod · 0.45
waitMethod · 0.45
frontMethod · 0.45
pop_frontMethod · 0.45

Tested by

no test coverage detected