From cf97c1f60b4697eebbeb19a1fb21f8b32c4ad4ec Mon Sep 17 00:00:00 2001 From: WarmUpTill Date: Wed, 21 Feb 2024 20:54:48 +0100 Subject: [PATCH] Add Clear() to MessageBuffer --- lib/utils/message-buffer.hpp | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/lib/utils/message-buffer.hpp b/lib/utils/message-buffer.hpp index 8d751bff..a876ff68 100644 --- a/lib/utils/message-buffer.hpp +++ b/lib/utils/message-buffer.hpp @@ -8,6 +8,7 @@ namespace advss { template class MessageBuffer { public: bool Empty(); + void Clear(); void AppendMessage(const T &); std::optional ConsumeMessage(); @@ -22,6 +23,12 @@ template inline bool MessageBuffer::Empty() return _buffer.empty(); } +template inline void MessageBuffer::Clear() +{ + std::lock_guard lock(_mutex); + _buffer.clear(); +} + template inline void MessageBuffer::AppendMessage(const T &message) { std::lock_guard lock(_mutex);