Switch the queue of the log backend to use a circular buffer.

lib/include/srsran/common/srsran_assert.h

@@ -27,9 +27,6 @@
 #define srsran_assert(condition, fmt, ...)                                                                             \
   do {                                                                                                                 \
     if (srsran_unlikely(not(condition))) {                                                                             \
-      srslog::fetch_basic_logger("ALL").error("%s:%d: " fmt, __FILE__, __LINE__, ##__VA_ARGS__);                       \
-      srslog::flush();                                                                                                 \
-      srsran::console_stderr("%s:%d: " fmt "\n", __FILE__, __LINE__, ##__VA_ARGS__);                                   \
       std::abort();                                                                                                    \
     }                                                                                                                  \
   } while (0)

lib/include/srsran/srslog/detail/support/work_queue.h

@@ -13,9 +13,9 @@
 #ifndef SRSLOG_DETAIL_SUPPORT_WORK_QUEUE_H
 #define SRSLOG_DETAIL_SUPPORT_WORK_QUEUE_H
 
+#include "srsran/adt/circular_buffer.h"
 #include "srsran/srslog/detail/support/backend_capacity.h"
 #include "srsran/srslog/detail/support/thread_utils.h"
-#include <queue>
 
 namespace srslog {
 
@@ -27,7 +27,7 @@ namespace detail {
 template <typename T, size_t capacity = SRSLOG_QUEUE_CAPACITY>
 class work_queue
 {
-  std::queue<T>              queue;
+  srsran::static_circular_buffer<T, capacity> queue;
   mutable condition_variable                  cond_var;
   static constexpr size_t                     threshold = capacity * 0.98;
 
@@ -43,7 +43,7 @@ public:
   {
     cond_var.lock();
     // Discard the new element if we reach the maximum capacity.
-    if (queue.size() > capacity) {
+    if (queue.full()) {
       cond_var.unlock();
       return false;
     }
@@ -60,7 +60,7 @@ public:
   {
     cond_var.lock();
     // Discard the new element if we reach the maximum capacity.
-    if (queue.size() > capacity) {
+    if (queue.full()) {
       cond_var.unlock();
       return false;
     }
@@ -81,7 +81,7 @@ public:
       cond_var.wait();
     }
 
-    T elem = std::move(queue.front());
+    T elem = std::move(queue.top());
     queue.pop();
 
     cond_var.unlock();
@@ -112,7 +112,7 @@ public:
     }
 
     // Here we have been woken up normally.
-    T Item = std::move(queue.front());
+    T Item = std::move(queue.top());
     queue.pop();
 
     cond_var.unlock();