in src/outmdsd/ConcurrentQueue.h [142:147]
void stop_once_empty() { std::lock_guard<std::mutex> lk(mut); stopOnceEmpty = true; data_cond.notify_all(); }