MCPcopy Create free account
hub / github.com/ceph/ceph / ~NotBeforeTest

Method ~NotBeforeTest

src/test/test_not_before_queue.cc:66–75  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

64 using queue_t = not_before_queue_t<tv_t, test_time_t>;
65
66 ~NotBeforeTest() {
67 // Advance time until all queued items become eligible for processing.
68 // This ensures complete dequeuing during test teardown, preventing memory leaks.
69 // We assume test cutoff timepoints remain within reasonable bounds. If a specified
70 // timepoint precedes current time, the process continues advancing normally.
71 for (unsigned when = 1; queue.eligible_count() < queue.total_count(); when += 1) {
72 queue.advance_time(when);
73 }
74 while (queue.dequeue()) {}
75 }
76 void load_test_data(const std::vector<tv_t> &dt) {
77 for (const auto &d : dt) {
78 queue.enqueue(d);

Callers

nothing calls this directly

Calls 4

eligible_countMethod · 0.80
total_countMethod · 0.80
advance_timeMethod · 0.80
dequeueMethod · 0.45

Tested by

no test coverage detected