2204b7cf06
We can have SelectionList in flights on the buffer, so mark it for deletion by moving it in a buffer trash, and effectively delete it later, at a point where there should not be any further access to it.
92 lines
2.0 KiB
C++
92 lines
2.0 KiB
C++
#include "event_manager.hh"
|
|
|
|
#include <poll.h>
|
|
|
|
namespace Kakoune
|
|
{
|
|
|
|
FDWatcher::FDWatcher(int fd, Callback callback)
|
|
: m_fd{fd}, m_callback{std::move(callback)}
|
|
{
|
|
EventManager::instance().m_fd_watchers.insert(this);
|
|
}
|
|
|
|
FDWatcher::~FDWatcher()
|
|
{
|
|
EventManager::instance().m_fd_watchers.erase(this);
|
|
}
|
|
|
|
Timer::Timer(TimePoint date, Callback callback)
|
|
: m_date{date}, m_callback{std::move(callback)}
|
|
{
|
|
EventManager::instance().m_timers.insert(this);
|
|
}
|
|
|
|
Timer::~Timer()
|
|
{
|
|
EventManager::instance().m_timers.erase(this);
|
|
}
|
|
|
|
void Timer::run()
|
|
{
|
|
m_date = TimePoint::max();
|
|
m_callback(*this);
|
|
}
|
|
|
|
EventManager::EventManager()
|
|
{
|
|
m_forced_fd.reserve(4);
|
|
}
|
|
|
|
EventManager::~EventManager()
|
|
{
|
|
kak_assert(m_fd_watchers.empty());
|
|
kak_assert(m_timers.empty());
|
|
}
|
|
|
|
void EventManager::handle_next_events()
|
|
{
|
|
std::vector<pollfd> events;
|
|
events.reserve(m_fd_watchers.size());
|
|
for (auto& watcher : m_fd_watchers)
|
|
events.emplace_back(pollfd{ watcher->fd(), POLLIN | POLLPRI, 0 });
|
|
std::vector<int> forced;
|
|
std::swap(forced, m_forced_fd);
|
|
|
|
TimePoint next_timer = TimePoint::max();
|
|
for (auto& timer : m_timers)
|
|
{
|
|
if (timer->next_date() <= next_timer)
|
|
next_timer = timer->next_date();
|
|
}
|
|
using namespace std::chrono;
|
|
auto timeout = duration_cast<milliseconds>(next_timer - Clock::now()).count();
|
|
poll(events.data(), events.size(), timeout < INT_MAX ? (int)timeout : INT_MAX);
|
|
for (size_t i = 0; i < events.size(); ++i)
|
|
{
|
|
auto& event = events[i];
|
|
const int fd = event.fd;
|
|
if (event.revents or contains(forced, fd))
|
|
{
|
|
auto it = find_if(m_fd_watchers,
|
|
[fd](FDWatcher* w) { return w->fd() == fd; });
|
|
if (it != m_fd_watchers.end())
|
|
(*it)->run();
|
|
}
|
|
}
|
|
|
|
TimePoint now = Clock::now();
|
|
for (auto& timer : m_timers)
|
|
{
|
|
if (timer->next_date() <= now)
|
|
timer->run();
|
|
}
|
|
}
|
|
|
|
void EventManager::force_signal(int fd)
|
|
{
|
|
m_forced_fd.push_back(fd);
|
|
}
|
|
|
|
}
|