iioutil/commandqueue: Made the enqueue thread-safe.

Signed-off-by: andrei.danila <[email protected]>
analogdevicesinc · Apr 29, 2024 · cdbc0d3 · cdbc0d3
1 parent 90e8e61
commit cdbc0d3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/iioutil/include/iioutil/commandqueue.h b/iioutil/include/iioutil/commandqueue.h
@@ -31,6 +31,7 @@ private Q_SLOTS:
 private:
 	std::deque<Command *> m_commandQueue;
 	std::mutex m_commandMutex;
+	std::mutex m_enqueueMutex;
 	std::atomic<bool> m_running;
 	QThreadPool m_commandExecThreadPool;
 };

diff --git a/iioutil/src/commandqueue.cpp b/iioutil/src/commandqueue.cpp
@@ -26,8 +26,10 @@ CommandQueue::~CommandQueue()
 
 void CommandQueue::enqueue(Command *command)
 {
+	m_enqueueMutex.lock();
 	m_commandQueue.push_back(command);
 	qDebug(CAT_COMMANDQUEUE) << "enqueued " << command << " " << m_commandQueue.size();
+	m_enqueueMutex.unlock();
 
 	if(!m_running) {
 		start();