summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/libwindowmanager.cpp83
1 files changed, 37 insertions, 46 deletions
diff --git a/src/libwindowmanager.cpp b/src/libwindowmanager.cpp
index a306faf..b9a1e12 100644
--- a/src/libwindowmanager.cpp
+++ b/src/libwindowmanager.cpp
@@ -206,7 +206,7 @@ int LibWindowmanager::Impl::init(int port, char const *token) {
}
/* get the default event loop */
- rc = sd_event_default(&this->loop);
+ rc = sd_event_new(&this->loop);
if (rc < 0) {
HMI_ERROR("libwm", "Connection to default event loop failed: %s",
strerror(-rc));
@@ -621,6 +621,41 @@ std::pair<bool, LibWindowmanager::EventType> make_event_type(char const *et) {
}
} // namespace
+#include <condition_variable>
+#include <mutex>
+class callsync {
+private:
+ const std::function<void(bool, json_object *)> &onReply_;
+ std::condition_variable cond_;
+ std::mutex mutex_;
+ bool ok_;
+private:
+ static void on_reply(void *closure, afb_wsj1_msg *msg) {
+ callsync *call = reinterpret_cast<callsync*>(closure);
+ call->onReply_(call->ok_ = afb_wsj1_msg_is_reply_ok(msg), afb_wsj1_msg_object_j(msg));
+ call->cond_.notify_one();
+ afb_wsj1_msg_unref(msg);
+ }
+public:
+ callsync(
+ struct afb_wsj1 *wsj1,
+ const char *api,
+ const char *verb,
+ json_object *args,
+ const std::function<void(bool, json_object *)> &onReply
+ )
+ : onReply_(onReply), cond_(), mutex_(), ok_(false) {
+ std::unique_lock<std::mutex> ulock(mutex_);
+ int rc = afb_wsj1_call_j(wsj1, api, verb, args, on_reply, this);
+ if (rc < 0)
+ onReply(false, nullptr);
+ else
+ cond_.wait(ulock);
+ }
+ operator bool() const { return ok_; }
+ operator int() const { return int(ok_) - 1; }
+};
+
/// object will be json_object_put
int LibWindowmanager::Impl::api_call(
const char *verb, json_object *object,
@@ -631,51 +666,7 @@ int LibWindowmanager::Impl::api_call(
if ((0 == strcmp("RequestSurface", verb)) ||
(0 == strcmp("GetDisplayInfo", verb)) ||
(0 == strcmp("GetAreaInfo", verb))) {
- // We need to wrap the actual onReply call once in order to
- // *look* like a normal functions pointer (std::functions<>
- // with captures cannot convert to function pointers).
- // Alternatively we could setup a local struct and use it as
- // closure, but I think it is cleaner this way.
- int call_rc = 0;
- std::atomic<bool> returned{};
- returned.store(false, std::memory_order_relaxed);
- std::function<void(bool, json_object *)> wrappedOnReply =
- [&returned, &call_rc, &onReply](bool ok, json_object *j) {
- TRACEN(wrappedOnReply);
- call_rc = ok ? 0 : -EINVAL;
- // We know it failed, but there may be an explanation in the
- // json object.
- {
- TRACEN(onReply);
- onReply(ok, j);
- }
- returned.store(true, std::memory_order_release);
- };
-
- // make the actual call, use wrappedOnReply as closure
- rc = afb_wsj1_call_j(
- this->wsj1, wmAPI, verb, object,
- [](void *closure, afb_wsj1_msg *msg) {
- TRACEN(callClosure);
- auto *onReply =
- reinterpret_cast<std::function<void(bool, json_object *)> *>(
- closure);
- (*onReply)(!(afb_wsj1_msg_is_reply_ok(msg) == 0),
- afb_wsj1_msg_object_j(msg));
- },
- &wrappedOnReply);
-
- if (0 == rc) {
- // We need to wait until "returned" got set, this is necessary
- // if events get triggered by the call (and would be dispatched before
- // the actual call-reply).
- while (!returned.load(std::memory_order_consume)) {
- sd_event_run(loop, 16);
- }
-
- // return the actual API call result
- rc = call_rc;
- }
+ rc = callsync(this->wsj1, wmAPI, verb, object, onReply);
}
else {
rc = afb_wsj1_call_j(this->wsj1, wmAPI, verb, object, _on_reply_static, this);