in src/outmdsd/ConcurrentQueue.h [68:76]
void push(T && new_value)
{
std::lock_guard<std::mutex> lk(mut);
if (is_full()) {
data_queue.pop();
}
data_queue.emplace(std::move(new_value));
data_cond.notify_one();
}