42 lines
897 B
C++
42 lines
897 B
C++
#include <lorie-compositor.hpp>
|
|
#include <unistd.h>
|
|
#include <fcntl.h>
|
|
#include <string.h>
|
|
#include <errno.h>
|
|
#include <sys/eventfd.h>
|
|
|
|
LorieMessageQueue::LorieMessageQueue() {
|
|
pthread_mutex_init(&write_mutex, nullptr);
|
|
pthread_mutex_init(&read_mutex, nullptr);
|
|
|
|
fd = eventfd(0, EFD_CLOEXEC);
|
|
if (fd == -1) {
|
|
LOGE("Failed to create socketpair for message queue: %s", strerror(errno));
|
|
return;
|
|
}
|
|
}
|
|
|
|
void LorieMessageQueue::write(std::function<void()> func) {
|
|
static uint64_t i = 1;
|
|
pthread_mutex_lock(&write_mutex);
|
|
queue.push(func);
|
|
pthread_mutex_unlock(&write_mutex);
|
|
::write(fd, &i, sizeof(uint64_t));
|
|
}
|
|
|
|
void LorieMessageQueue::run() {
|
|
static uint64_t i = 0;
|
|
::read(fd, &i, sizeof(uint64_t));
|
|
while(!queue.empty()){
|
|
queue.front()();
|
|
|
|
pthread_mutex_lock(&read_mutex);
|
|
queue.pop();
|
|
pthread_mutex_unlock(&read_mutex);
|
|
}
|
|
}
|
|
|
|
int LorieMessageQueue::get_fd() {
|
|
return fd;
|
|
}
|