X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain.cpp;h=03aa2029994e8f7cbcf45818a52e2b07d98f2953;hb=dc747bcc7b70476ac14cde38e5e90a60bc057546;hp=e78b42f497d4e29f1806da34fa1535344704e214;hpb=77fcaa36178e739044b8ce4e68388440c4379a74;p=staging%2Fwindowmanager.git diff --git a/src/main.cpp b/src/main.cpp index e78b42f..03aa202 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -13,24 +13,53 @@ extern "C" { #include -using json = nlohmann::json; - namespace { struct wayland { std::unique_ptr display; std::unique_ptr controller; std::vector> outputs; - sd_event_source *event_source; - wayland() - : display(new wl::display), - controller(nullptr), - outputs(), - event_source{} {} + wayland() : display(new wl::display), controller(nullptr), outputs() {} + + int init(); }; struct wayland *g_wayland; +int wayland::init() { + if (!this->display->ok()) { + return -1; + } + + this->display->r.add_global_handler("wl_output", [](wl_registry *r, + uint32_t name, + uint32_t v) { + g_wayland->outputs.emplace_back(std::make_unique(r, name, v)); + }); + + this->display->r.add_global_handler( + "ivi_controller", [](wl_registry *r, uint32_t name, uint32_t v) { + g_wayland->controller = + std::make_unique(r, name, v); + + // XXX: This protocol needs the output, so lets just add our mapping + // here... + g_wayland->controller->add_proxy_to_id_mapping( + g_wayland->outputs.back()->proxy.get(), + wl_proxy_get_id(reinterpret_cast( + g_wayland->outputs.back()->proxy.get()))); + }); + + // First level objects + this->display->roundtrip(); + // Second level objects + this->display->roundtrip(); + // Third level objects + this->display->roundtrip(); + + return 0; +} + // _ _ _ _ _ ____ // (_)_ __ (_) |_ | | __ _ _ _ ___ _ _| |_ / /\ \ // | | '_ \| | __| | |/ _` | | | |/ _ \| | | | __| | | | @@ -84,6 +113,36 @@ char const *init_layout() { return nullptr; } +int display_event_callback(sd_event_source *evs, int fd, uint32_t events, + void *data) { + if ((events & EPOLLHUP) != 0) { + AFB_ERROR("The compositor hung up, dying now."); + delete g_wayland; + g_wayland = nullptr; + goto error; + } + + if (events & EPOLLIN) { + int ret = g_wayland->display->dispatch(); + if (ret == -1) { + AFB_ERROR("wl_display_dipatch() returned error %d", + g_wayland->display->get_error()); + goto error; + } + g_wayland->display->flush(); + + // execute pending tasks, that is layout changes etc. + g_wayland->controller->execute_pending(); + g_wayland->display->roundtrip(); + } + + return 0; + +error: + sd_event_source_unref(evs); + return -1; +} + // _ _ _ _ _ _ _ ____ // | |__ (_)_ __ __| (_)_ __ __ _ (_)_ __ (_) |_ / /\ \ // | '_ \| | '_ \ / _` | | '_ \ / _` | | | '_ \| | __| | | | @@ -104,66 +163,20 @@ int binding_init_() { } g_wayland = new wayland; - if (!g_wayland->display->ok()) { + if (g_wayland->init() == -1) { AFB_ERROR("Could not connect to compositor"); + delete g_wayland; return -1; } - auto &d = g_wayland->display; - d->r.add_global_handler("wl_output", [](wl_registry *r, uint32_t name, - uint32_t v) { - g_wayland->outputs.emplace_back(std::make_unique(r, name, v)); - }); - - d->r.add_global_handler("ivi_controller", [](wl_registry *r, uint32_t name, - uint32_t v) { - g_wayland->controller = std::make_unique(r, name, v); - - // XXX: This protocol needs the output, so lets just add our mapping - // here... - g_wayland->controller->add_proxy_to_id_mapping( - g_wayland->outputs.back()->proxy.get(), - wl_proxy_get_id(reinterpret_cast( - g_wayland->outputs.back()->proxy.get()))); - }); - - // First level objects - d->roundtrip(); - // Second level objects - d->roundtrip(); - // Third level objects - d->roundtrip(); - if (char const *e = init_layout()) { AFB_ERROR("Could not init layout: %s", e); return -1; } - sd_event *ev = afb_daemon_get_event_loop(); - sd_event_add_io( - ev, &g_wayland->event_source, g_wayland->display->get_fd(), - EPOLLIN | EPOLLHUP, - [](sd_event_source *evs, int fd, uint32_t events, void *data) { - if ((events & EPOLLHUP) != 0) { - sd_event_source_unref(evs); - delete g_wayland; - g_wayland = nullptr; - return 1; - } - - if (events & EPOLLIN) { - int ret = g_wayland->display->dispatch(); - g_wayland->display->flush(); - - // execute pending tasks, that is layout changes etc. - g_wayland->controller->execute_pending(); - g_wayland->display->roundtrip(); - return ret == -1 ? -1 : 0; - } - - return 0; - }, - g_wayland); + sd_event_add_io(afb_daemon_get_event_loop(), nullptr, + g_wayland->display->get_fd(), EPOLLIN, + display_event_callback, g_wayland); atexit([] { delete g_wayland; }); @@ -179,6 +192,15 @@ int binding_init() noexcept { return -1; } +#define CHECK_WAYLAND() \ + do { \ + if (g_wayland == nullptr) { \ + afb_req_fail(req, "failed", \ + "Binding not initialized, did the compositor die?"); \ + return; \ + } \ + } while (0) + // _ _ _ _ ____ // __| | ___| |__ _ _ __ _ ___| |_ __ _| |_ _ _ ___ / /\ \ // / _` |/ _ \ '_ \| | | |/ _` | / __| __/ _` | __| | | / __| | | | @@ -189,37 +211,35 @@ void debug_status(struct afb_req req) noexcept { // Quick and dirty, dump current surfaces and layers AFB_REQ_DEBUG(req, "status"); - if (g_wayland == nullptr) { - afb_req_fail(req, "failed", - "Binding not initialized, did the compositor die?"); - return; - } + CHECK_WAYLAND(); try { + using json = nlohmann::json; + json j; if (!g_wayland->controller->surfaces.empty()) { - auto js = json::array(); + auto a = json::array(); for (auto const &i : g_wayland->controller->surfaces) { auto const &r = i.second->dst_rect; auto const &s = i.second->size; - js.push_back({{"id", i.first}, - {"size", {s.w, s.h}}, - {"dst_rect", {r.w, r.h, r.x, r.y}}}); + a.push_back({{"id", i.first}, + {"size", {s.w, s.h}}, + {"dst_rect", {r.w, r.h, r.x, r.y}}}); } - j["surfaces"] = js; + j["surfaces"] = a; } if (!g_wayland->controller->layers.empty()) { - auto js = json::array(); + auto a = json::array(); for (auto const &i : g_wayland->controller->layers) { auto const &r = i.second->dst_rect; auto const &s = i.second->size; - js.push_back({{"id", i.first}, + a.push_back({{"id", i.first}, {"size", {s.w, s.h}}, {"dst_rect", {r.w, r.h, r.x, r.y}}}); } - j["layers"] = js; + j["layers"] = a; } afb_req_success(req, json_tokener_parse(j.dump().c_str()), "status"); @@ -228,8 +248,39 @@ void debug_status(struct afb_req req) noexcept { } } +void debug_surfaces(afb_req req) { + CHECK_WAYLAND(); + + auto a = json_object_new_array(); + + if (!g_wayland->controller->surfaces.empty()) { + for (auto const &i : g_wayland->controller->surfaces) { + json_object_array_add(a, json_object_new_int(i.first)); + } + } + + afb_req_success(req, a, "surfaces"); +} + +void debug_layers(afb_req req) { + CHECK_WAYLAND(); + + auto a = json_object_new_array(); + + if (!g_wayland->controller->layers.empty()) { + for (auto const &i : g_wayland->controller->layers) { + json_object_array_add(a, json_object_new_int(i.first)); + } + } + + afb_req_success(req, a, "surfaces"); +} + const struct afb_verb_v2 verbs[] = { - {"status", debug_status, NULL, NULL, AFB_SESSION_NONE_V2}, {}, + {"status", debug_status, NULL, NULL, AFB_SESSION_NONE_V2}, + {"layers", debug_layers, NULL, NULL, AFB_SESSION_NONE_V2}, + {"surfaces", debug_surfaces, NULL, NULL, AFB_SESSION_NONE_V2}, + {}, }; } // namespace