From ad148587dcf5244c2d2011dba339786c765c54c4 Mon Sep 17 00:00:00 2001 From: Elias Fleckenstein Date: Wed, 4 Nov 2020 16:19:54 +0100 Subject: Make Lint Happy --- src/util/thread.h | 75 ++++++++++++++++++++++++++----------------------------- 1 file changed, 36 insertions(+), 39 deletions(-) (limited to 'src/util/thread.h') diff --git a/src/util/thread.h b/src/util/thread.h index 73e9beb80..4633de310 100644 --- a/src/util/thread.h +++ b/src/util/thread.h @@ -26,13 +26,10 @@ with this program; if not, write to the Free Software Foundation, Inc., #include "log.h" #include "container.h" -template -class MutexedVariable +template class MutexedVariable { public: - MutexedVariable(const T &value): - m_value(value) - {} + MutexedVariable(const T &value) : m_value(value) {} T get() { @@ -48,6 +45,7 @@ public: // You pretty surely want to grab the lock when accessing this T m_value; + private: std::mutex m_mutex; }; @@ -55,38 +53,37 @@ private: /* A single worker thread - multiple client threads queue framework. */ -template -class GetResult { +template class GetResult +{ public: Key key; T item; std::pair caller; }; -template -class ResultQueue : public MutexedQueue > { +template +class ResultQueue : public MutexedQueue> +{ }; -template -class CallerInfo { +template class CallerInfo +{ public: Caller caller; Data data; ResultQueue *dest; }; -template -class GetRequest { +template class GetRequest +{ public: GetRequest() = default; ~GetRequest() = default; - GetRequest(const Key &a_key): key(a_key) - { - } + GetRequest(const Key &a_key) : key(a_key) {} Key key; - std::list > callers; + std::list> callers; }; /** @@ -96,32 +93,33 @@ public: * @param Caller unique id of calling thread * @param CallerData data passed back to caller */ -template -class RequestQueue { +template +class RequestQueue +{ public: - bool empty() - { - return m_queue.empty(); - } + bool empty() { return m_queue.empty(); } void add(const Key &key, Caller caller, CallerData callerdata, - ResultQueue *dest) + ResultQueue *dest) { - typename std::deque >::iterator i; - typename std::list >::iterator j; + typename std::deque>::iterator i; + typename std::list>::iterator j; { MutexAutoLock lock(m_queue.getMutex()); /* - If the caller is already on the list, only update CallerData + If the caller is already on the list, only update + CallerData */ - for (i = m_queue.getQueue().begin(); i != m_queue.getQueue().end(); ++i) { + for (i = m_queue.getQueue().begin(); + i != m_queue.getQueue().end(); ++i) { GetRequest &request = *i; if (request.key != key) continue; - for (j = request.callers.begin(); j != request.callers.end(); ++j) { + for (j = request.callers.begin(); + j != request.callers.end(); ++j) { CallerInfo &ca = *j; if (ca.caller == caller) { ca.data = callerdata; @@ -158,19 +156,16 @@ public: return m_queue.pop_front(timeout_ms); } - GetRequest pop() - { - return m_queue.pop_frontNoEx(); - } + GetRequest pop() { return m_queue.pop_frontNoEx(); } void pushResult(GetRequest req, T res) { - for (typename std::list >::iterator - i = req.callers.begin(); + for (typename std::list>::iterator + i = req.callers.begin(); i != req.callers.end(); ++i) { CallerInfo &ca = *i; - GetResult result; + GetResult result; result.key = req.key; result.item = res; @@ -182,7 +177,7 @@ public: } private: - MutexedQueue > m_queue; + MutexedQueue> m_queue; }; class UpdateThread : public Thread @@ -208,9 +203,11 @@ public: while (!stopRequested()) { m_update_sem.wait(); // Set semaphore to 0 - while (m_update_sem.wait(0)); + while (m_update_sem.wait(0)) + ; - if (stopRequested()) break; + if (stopRequested()) + break; doUpdate(); } -- cgit v1.2.3