src/shm_queue.h
@@ -74,8 +74,8 @@ } while (steady_clock::now() < end_time); return false; } bool TryRead(Data &d, const bool try_more = true) { return queue_.pop_front(d, try_more); } bool TryWrite(const Data d, const bool try_more = true) { return queue_.push_back(d, try_more); } bool TryRead(Data &d, const bool try_more = true) { return queue_.pop(d, try_more); } bool TryWrite(const Data d, const bool try_more = true) { return queue_.push(d, try_more); } private: robust::AtomicQueue<Power, Data> queue_;