From f49e93338b6309a66b558dea40d114925f01e993 Mon Sep 17 00:00:00 2001
From: Laurent Pinchart <laurent.pinchart@ideasonboard.com>
Date: Sun, 8 Nov 2020 01:26:33 +0200
Subject: cam: event_loop: Add deferred calls support
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Add a deferred cals queue to the EventLoop class to support queuing
calls from a different thread and processing them in the event loop's
thread.

Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com>
Reviewed-by: Kieran Bingham <kieran.bingham@ideasonboard.com>
Reviewed-by: Niklas Söderlund <niklas.soderlund@ragnatech.se>
---
 src/cam/event_loop.cpp | 29 ++++++++++++++++++++++++++++-
 1 file changed, 28 insertions(+), 1 deletion(-)

(limited to 'src/cam/event_loop.cpp')

diff --git a/src/cam/event_loop.cpp b/src/cam/event_loop.cpp
index 13f2583d..94c5d1d3 100644
--- a/src/cam/event_loop.cpp
+++ b/src/cam/event_loop.cpp
@@ -40,8 +40,10 @@ int EventLoop::exec()
 	exitCode_ = -1;
 	exit_.store(false, std::memory_order_release);
 
-	while (!exit_.load(std::memory_order_acquire))
+	while (!exit_.load(std::memory_order_acquire)) {
+		dispatchCalls();
 		event_base_loop(event_, EVLOOP_NO_EXIT_ON_EMPTY);
+	}
 
 	return exitCode_;
 }
@@ -57,3 +59,28 @@ void EventLoop::interrupt()
 {
 	event_base_loopbreak(event_);
 }
+
+void EventLoop::callLater(const std::function<void()> &func)
+{
+	{
+		std::unique_lock<std::mutex> locker(lock_);
+		calls_.push_back(func);
+	}
+
+	interrupt();
+}
+
+void EventLoop::dispatchCalls()
+{
+	std::unique_lock<std::mutex> locker(lock_);
+
+	for (auto iter = calls_.begin(); iter != calls_.end(); ) {
+		std::function<void()> call = std::move(*iter);
+
+		iter = calls_.erase(iter);
+
+		locker.unlock();
+		call();
+		locker.lock();
+	}
+}
-- 
cgit v1.2.1