blob: 8632d93b353a00ec72996ea1056b64e608648e31 (
plain)
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
|
#include "MainLoopExecutor.hpp"
#include "../managers/eventLoop/EventLoopManager.hpp"
#include "../macros.hpp"
#include <unistd.h>
static int onDataRead(int fd, uint32_t mask, void* data) {
((CMainLoopExecutor*)data)->onFired();
return 0;
}
CMainLoopExecutor::CMainLoopExecutor(std::function<void()>&& callback) : m_fn(std::move(callback)) {
int fds[2];
pipe(fds);
RASSERT(fds[0] != 0, "CMainLoopExecutor: failed to open a pipe");
RASSERT(fds[1] != 0, "CMainLoopExecutor: failed to open a pipe");
m_event = wl_event_loop_add_fd(g_pEventLoopManager->m_wayland.loop, fds[0], WL_EVENT_READABLE, ::onDataRead, this);
m_readFd = Hyprutils::OS::CFileDescriptor(fds[0]);
m_writeFd = Hyprutils::OS::CFileDescriptor(fds[1]);
}
CMainLoopExecutor::~CMainLoopExecutor() {
if (m_event) // FIXME: potential race in case of a weird destroy on a worker thread
wl_event_source_remove(m_event);
}
void CMainLoopExecutor::signal() {
const char* amogus = "h";
write(m_writeFd.get(), amogus, 1);
}
void CMainLoopExecutor::onFired() {
if (!m_fn)
return;
m_fn();
m_fn = nullptr;
// we need to remove the event here because we're on the main thread
wl_event_source_remove(m_event);
m_event = nullptr;
m_readFd.reset();
m_writeFd.reset();
}
|
