diff --git a/include/spdlog/details/circular_q.h b/include/spdlog/details/circular_q.h index b78af247..b01325bb 100644 --- a/include/spdlog/details/circular_q.h +++ b/include/spdlog/details/circular_q.h @@ -56,7 +56,7 @@ public: size_t overrun_counter() const { - return overrun_counter_; + return overrun_counter_; } private: diff --git a/include/spdlog/details/mpmc_blocking_q.h b/include/spdlog/details/mpmc_blocking_q.h index cf34d225..ca789fc6 100644 --- a/include/spdlog/details/mpmc_blocking_q.h +++ b/include/spdlog/details/mpmc_blocking_q.h @@ -30,12 +30,6 @@ public: { } - size_t overrun_counter() const - { - std::unique_lock lock(queue_mutex_); - return q_.overrun_counter(); - } - #ifndef __MINGW32__ // try to enqueue and block if no room left void enqueue(T &&item) @@ -111,6 +105,12 @@ public: #endif + size_t overrun_counter() + { + std::unique_lock lock(queue_mutex_); + return q_.overrun_counter(); + } + private: std::mutex queue_mutex_; std::condition_variable push_cv_; diff --git a/include/spdlog/details/thread_pool.h b/include/spdlog/details/thread_pool.h index aab089f4..282d67e8 100644 --- a/include/spdlog/details/thread_pool.h +++ b/include/spdlog/details/thread_pool.h @@ -157,9 +157,9 @@ public: post_async_msg_(async_msg(std::move(worker_ptr), async_msg_type::flush), overflow_policy); } - size_t overrun_counter() const + size_t overrun_counter() { - return q_.overrun_counter(); + return q_.overrun_counter(); } private: