78 lines
1.9 KiB
C++
78 lines
1.9 KiB
C++
|
#pragma once
|
||
|
|
#include <sys/eventfd.h>
|
||
|
|
#include <sys/timerfd.h>
|
||
|
|
|
||
|
|
#include <poll.h>
|
||
|
|
#include <unistd.h>
|
||
|
|
|
||
|
|
#include <iostream>
|
||
|
|
|
||
|
|
namespace libremidi
|
||
|
|
{
|
||
|
|
struct eventfd_notifier
|
||
|
|
{
|
||
|
|
eventfd_notifier(bool semaphore = true)
|
||
|
|
{
|
||
|
|
if (semaphore)
|
||
|
|
this->fd = eventfd(0, EFD_SEMAPHORE | EFD_NONBLOCK);
|
||
|
|
else
|
||
|
|
this->fd = eventfd(0, EFD_NONBLOCK);
|
||
|
|
}
|
||
|
|
~eventfd_notifier() { close(this->fd); }
|
||
|
|
|
||
|
|
eventfd_notifier(const eventfd_notifier&) = delete;
|
||
|
|
eventfd_notifier(eventfd_notifier&&) = delete;
|
||
|
|
eventfd_notifier& operator=(const eventfd_notifier&) = delete;
|
||
|
|
eventfd_notifier& operator=(eventfd_notifier&&) = delete;
|
||
|
|
|
||
|
|
void notify() noexcept { eventfd_write(fd, 1); }
|
||
|
|
static bool ready(pollfd res) noexcept { return res.revents & POLLIN; }
|
||
|
|
eventfd_t consume() noexcept
|
||
|
|
{
|
||
|
|
eventfd_t val;
|
||
|
|
eventfd_read(fd, &val);
|
||
|
|
return val;
|
||
|
|
}
|
||
|
|
|
||
|
|
operator int() const noexcept { return fd; }
|
||
|
|
operator pollfd() const noexcept { return {.fd = fd, .events = POLLIN, .revents = 0}; }
|
||
|
|
int fd{-1};
|
||
|
|
};
|
||
|
|
|
||
|
|
struct timerfd_timer
|
||
|
|
{
|
||
|
|
timerfd_timer() { this->fd = timerfd_create(CLOCK_MONOTONIC, 0); }
|
||
|
|
~timerfd_timer() { close(this->fd); }
|
||
|
|
|
||
|
|
timerfd_timer(const timerfd_timer&) = delete;
|
||
|
|
timerfd_timer(timerfd_timer&&) = delete;
|
||
|
|
timerfd_timer& operator=(const timerfd_timer&) = delete;
|
||
|
|
timerfd_timer& operator=(timerfd_timer&&) = delete;
|
||
|
|
|
||
|
|
void oneshot(int64_t nsec)
|
||
|
|
{
|
||
|
|
itimerspec t{};
|
||
|
|
t.it_value.tv_nsec = nsec;
|
||
|
|
timerfd_settime(this->fd, 0, &t, nullptr);
|
||
|
|
}
|
||
|
|
|
||
|
|
void restart(int64_t nsec)
|
||
|
|
{
|
||
|
|
itimerspec t{};
|
||
|
|
t.it_value.tv_nsec = nsec;
|
||
|
|
t.it_interval.tv_nsec = nsec;
|
||
|
|
timerfd_settime(this->fd, 0, &t, nullptr);
|
||
|
|
}
|
||
|
|
|
||
|
|
void cancel()
|
||
|
|
{
|
||
|
|
itimerspec t{};
|
||
|
|
timerfd_settime(this->fd, 0, &t, nullptr);
|
||
|
|
}
|
||
|
|
|
||
|
|
operator int() const noexcept { return fd; }
|
||
|
|
operator pollfd() const noexcept { return {.fd = fd, .events = POLLIN, .revents = 0}; }
|
||
|
|
int fd{-1};
|
||
|
|
};
|
||
|
|
}
|