Martin Michelsen
44 lines
1.2 KiB
C++
44 lines
1.2 KiB
C++
#include "EventUtils.hh"
|
|
|
|
#include <event2/event.h>
|
|
|
|
#include <deque>
|
|
#include <functional>
|
|
#include <memory>
|
|
#include <stdexcept>
|
|
|
|
static void dispatch_forward_to_event_thread(evutil_socket_t, short, void* ctx) {
|
|
auto* fn = reinterpret_cast<std::function<void()>*>(ctx);
|
|
(*fn)();
|
|
delete fn;
|
|
}
|
|
|
|
void forward_to_event_thread(std::shared_ptr<struct event_base> base, std::function<void()>&& fn) {
|
|
struct timeval tv = {0, 0};
|
|
std::function<void()>* new_fn = new std::function<void()>(std::move(fn));
|
|
event_base_once(base.get(), -1, EV_TIMEOUT, dispatch_forward_to_event_thread, new_fn, &tv);
|
|
}
|
|
|
|
template <>
|
|
void call_on_event_thread<void>(std::shared_ptr<struct event_base> base, std::function<void()>&& compute) {
|
|
bool succeeded = false;
|
|
std::string exc_what;
|
|
std::mutex ret_lock;
|
|
std::condition_variable ret_cv;
|
|
std::unique_lock<std::mutex> g(ret_lock);
|
|
forward_to_event_thread(base, [&]() -> void {
|
|
std::lock_guard<std::mutex> g(ret_lock);
|
|
try {
|
|
compute();
|
|
succeeded = true;
|
|
} catch (const std::exception& e) {
|
|
exc_what = e.what();
|
|
}
|
|
ret_cv.notify_one();
|
|
});
|
|
ret_cv.wait(g);
|
|
if (!succeeded) {
|
|
throw std::runtime_error(exc_what);
|
|
}
|
|
}
|