lichao
2021-05-13 db322f33ba13592f2492317e3f1a070454c97059
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;
   }