diff options
| -rw-r--r-- | src/cam/event_loop.cpp | 24 | ||||
| -rw-r--r-- | src/cam/event_loop.h | 7 |
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); |