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