1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
#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)}
{
if (EventManager::has_instance())
EventManager::instance().m_timers.insert(this);
}
Timer::~Timer()
{
if (EventManager::has_instance())
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 });
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);
// gather forced fds *after* poll, so that signal handlers can write to
// m_forced_fd, interupt poll, and directly be serviced.
std::vector<int> forced;
std::swap(forced, m_forced_fd);
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);
}
}
|
