diff options
author | Giacomo Pozzoni <giacomopoz@gmail.com> | 2021-07-24 14:50:30 +0200 |
---|---|---|
committer | Shauren <shauren.trinity@gmail.com> | 2022-03-11 19:32:22 +0100 |
commit | 51f0294c18a32f5e299b17576e673d6c92bf0201 (patch) | |
tree | 97d892d94f2bb0426fab1ea6e65466bf54219b62 /src/common/Threading/ProducerConsumerQueue.h | |
parent | 21177487ea9476cb4db3f498353c340181d87e14 (diff) |
Core/DBLayer: Add QueueSize() method (#26733)
* Core/DBLayer: Add QueueSize() method
Add QueueSize() method to database objects (Login, Character and World) that returns how many tasks are queued.
Include the queue size of the 3 databases in ".server debug" command
* Make the code less threadsafe
* Send data to InfluxDB
* Update grafana dashboard
(cherry picked from commit 96dc110f4a353871ac74c82ff4b1bcc4c34156f3)
Diffstat (limited to 'src/common/Threading/ProducerConsumerQueue.h')
-rw-r--r-- | src/common/Threading/ProducerConsumerQueue.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/common/Threading/ProducerConsumerQueue.h b/src/common/Threading/ProducerConsumerQueue.h index 1341bd26747..778f434e9de 100644 --- a/src/common/Threading/ProducerConsumerQueue.h +++ b/src/common/Threading/ProducerConsumerQueue.h @@ -52,6 +52,11 @@ public: return _queue.empty(); } + size_t Size() const + { + return _queue.size(); + } + bool Pop(T& value) { std::lock_guard<std::mutex> lock(_queueLock); |