summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/cam/event_loop.cpp24
-rw-r--r--src/cam/event_loop.h7
2 files changed, 30 insertions, 1 deletions
diff --git a/src/cam/event_loop.cpp b/src/cam/event_loop.cpp
index 2e3ce995..cb83845c 100644
--- a/src/cam/event_loop.cpp
+++ b/src/cam/event_loop.cpp
@@ -84,6 +84,30 @@ void EventLoop::addFdEvent(int fd, EventType type,
events_.push_back(std::move(event));
}
+void EventLoop::addTimerEvent(const std::chrono::microseconds period,
+ const std::function<void()> &callback)
+{
+ std::unique_ptr<Event> event = std::make_unique<Event>(callback);
+ event->event_ = event_new(base_, -1, EV_PERSIST, &EventLoop::Event::dispatch,
+ event.get());
+ if (!event->event_) {
+ std::cerr << "Failed to create timer event" << std::endl;
+ return;
+ }
+
+ struct timeval tv;
+ tv.tv_sec = period.count() / 1000000ULL;
+ tv.tv_usec = period.count() % 1000000ULL;
+
+ int ret = event_add(event->event_, &tv);
+ if (ret < 0) {
+ std::cerr << "Failed to add timer event" << std::endl;
+ return;
+ }
+
+ events_.push_back(std::move(event));
+}
+
void EventLoop::dispatchCallback([[maybe_unused]] evutil_socket_t fd,
[[maybe_unused]] short flags, void *param)
{
diff --git a/src/cam/event_loop.h b/src/cam/event_loop.h
index 79902d87..ef79e8e5 100644
--- a/src/cam/event_loop.h
+++ b/src/cam/event_loop.h
@@ -7,9 +7,10 @@
#pragma once
+#include <chrono>
#include <functional>
-#include <memory>
#include <list>
+#include <memory>
#include <mutex>
#include <event2/util.h>
@@ -37,6 +38,10 @@ public:
void addFdEvent(int fd, EventType type,
const std::function<void()> &handler);
+ using duration = std::chrono::steady_clock::duration;
+ void addTimerEvent(const std::chrono::microseconds period,
+ const std::function<void()> &handler);
+
private:
struct Event {
Event(const std::function<void()> &callback);