src/shm_queue.h
@@ -76,7 +76,7 @@ private: Circular<D> queue_; bhome_shm::Mutex mutex_; // bhome_shm::Mutex mutex_; }; template <int Power = 4> @@ -92,11 +92,12 @@ using namespace std::chrono; auto end_time = steady_clock::now() + milliseconds(timeout_ms); do { if (TryRead(d)) { return true; } else { robust::QuickSleep(); for (int i = 0; i < 100; ++i) { if (TryRead(d)) { return true; } } robust::QuickSleep(); } while (steady_clock::now() < end_time); return false; }