diff --git a/lib/include/srsran/common/block_queue.h b/lib/include/srsran/common/block_queue.h index 7982d191c..479f474d2 100644 --- a/lib/include/srsran/common/block_queue.h +++ b/lib/include/srsran/common/block_queue.h @@ -121,7 +121,14 @@ public: const myobj& front() const { return q.front(); } - size_t size() { return q.size(); } + size_t size() + { + size_t len = 0; + pthread_mutex_lock(&mutex); + len = q.size(); + pthread_mutex_unlock(&mutex); + return len; + } private: bool pop_(myobj* value, bool block)