X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;ds=inline;f=src%2Fmain.cpp;h=bf78b52dfd31f3479e2dbfead32c8ad29c68469e;hb=5ba849b33c433730c586da57cfe7851e0c2a9b91;hp=0c010ea465991217ab21e1df8701058f5a86cbfc;hpb=db95653246560c24ad3c8cb224b3d9321b50af0a;p=staging%2Fwindowmanager.git diff --git a/src/main.cpp b/src/main.cpp index 0c010ea..bf78b52 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -1,55 +1,259 @@ -#include "util.h" +#include "json_helper.hpp" +#include "util.hpp" #include "wayland.hpp" -#include -#include +#include +#include -#include -#include -#include -#include +extern "C" { +#define AFB_BINDING_VERSION 2 +#include +#include +} -struct conn { +namespace { +struct wayland { + std::unique_ptr display; + std::unique_ptr controller; std::vector> outputs; - std::unique_ptr c; - - ~conn(); -}; - -conn::~conn() { - this->outputs.clear(); -} -int main(int argc, char **argv) { - lognotice("WinMan ver. %s", WINMAN_VERSION_STRING); + wayland() : display(new wl::display), controller(nullptr), outputs() {} - if (!getenv("XDG_RUNTIME_DIR")) - fatal("Environment variable XDG_RUNTIME_DIR not set"); + int init(); +}; - auto d = std::make_unique(); - if (!d->d) - fatal("Could not connect to compositor"); +struct wayland *g_wayland; - struct conn c = {}; +int wayland::init() { + if (!this->display->ok()) { + return -1; + } - d->r->add_global_handler("ivi_controller", [&](wl_registry *r, uint32_t name, uint32_t v) { - c.c = std::make_unique(r, name, v); + 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)); }); - d->r->add_global_handler("wl_output", [&](wl_registry *r, uint32_t name, uint32_t v) { - c.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 - d->roundtrip(); + this->display->roundtrip(); // Second level objects - d->roundtrip(); + this->display->roundtrip(); // Third level objects - /* wl_display_roundtrip(c.d); */ + this->display->roundtrip(); + + return 0; +} + +// _ _ _ _ _ ____ +// (_)_ __ (_) |_ | | __ _ _ _ ___ _ _| |_ / /\ \ +// | | '_ \| | __| | |/ _` | | | |/ _ \| | | | __| | | | +// | | | | | | |_ | | (_| | |_| | (_) | |_| | |_| | | | +// |_|_| |_|_|\__|___|_|\__,_|\__, |\___/ \__,_|\__| | | | +// |_____| |___/ \_\/_/ +char const *init_layout() { + if (!g_wayland->controller) { + return "ivi_controller global not available"; + } + + if (g_wayland->outputs.empty()) { + return "no output was set up!"; + } + + auto &c = g_wayland->controller; + + auto &o = g_wayland->outputs.front(); + auto &s = c->screens.begin()->second; + auto &layers = c->layers; + + // XXX: Write output dimensions to ivi controller... + c->output_size = genivi::size{uint32_t(o->width), uint32_t(o->height)}; + + // Clear scene + layers.clear(); + + // Clear screen + s->clear(); + + // Setup our dummy scene... + c->layer_create(100, 0, 0); // bottom layer, anything else + c->layer_create(1000, 0, 0); // top layer, mandelbrot + + auto &l100 = c->layers[100]; + auto &l1k = c->layers[1000]; + + // Set layers fullscreen + l100->set_destination_rectangle(0, 0, o->width, o->height); + l1k->set_destination_rectangle(0, 0, o->width, o->height); + l100->set_visibility(1); + l1k->set_visibility(1); + + // Add layers to screen + s->set_render_order({100, 1000}); + + c->commit_changes(); + + g_wayland->display->flush(); + + 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(); - if (!c.c) - fatal("ivi_controller global not available"); - // main loop + // 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; +} + +// _ _ _ _ _ _ _ ____ +// | |__ (_)_ __ __| (_)_ __ __ _ (_)_ __ (_) |_ / /\ \ +// | '_ \| | '_ \ / _` | | '_ \ / _` | | | '_ \| | __| | | | +// | |_) | | | | | (_| | | | | | (_| | | | | | | | |_| | | | +// |_.__/|_|_| |_|\__,_|_|_| |_|\__, |___|_|_| |_|_|\__| | | | +// |___/_____| \_\/_/ +int binding_init_() { + lognotice("WinMan ver. %s", WINMAN_VERSION_STRING); + + if (g_wayland != nullptr) { + AFB_ERROR("Wayland context already initialized?"); + return 0; + } + + if (getenv("XDG_RUNTIME_DIR") == nullptr) { + AFB_ERROR("Environment variable XDG_RUNTIME_DIR not set"); + goto error; + } + + g_wayland = new wayland; + if (g_wayland->init() == -1) { + AFB_ERROR("Could not connect to compositor"); + goto error; + } + + if (char const *e = init_layout()) { + AFB_ERROR("Could not init layout: %s", e); + goto error; + } + + { + int ret = sd_event_add_io(afb_daemon_get_event_loop(), nullptr, + g_wayland->display->get_fd(), EPOLLIN, + display_event_callback, g_wayland); + if (ret < 0) { + AFB_ERROR("Could not initialize wayland event handler: %d", -ret); + goto error; + } + } + + atexit([] { delete g_wayland; }); + + return 0; + +error: + delete g_wayland; + g_wayland = nullptr; + return -1; +} + +int binding_init() noexcept { + try { + return binding_init_(); + } catch (std::exception &e) { + AFB_ERROR("Uncaught exception in binding_init(): %s", e.what()); + } + 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) + +// _ _ _ _ ____ +// __| | ___| |__ _ _ __ _ ___| |_ __ _| |_ _ _ ___ / /\ \ +// / _` |/ _ \ '_ \| | | |/ _` | / __| __/ _` | __| | | / __| | | | +// | (_| | __/ |_) | |_| | (_| | \__ \ || (_| | |_| |_| \__ \ | | | +// \__,_|\___|_.__/ \__,_|\__, |___|___/\__\__,_|\__|\__,_|___/ | | | +// |___/_____| \_\/_/ +void debug_status(struct afb_req req) { + // Quick and dirty, dump current surfaces and layers + AFB_REQ_DEBUG(req, "status"); + + auto o = json_object_new_object(); + json_object_object_add(o, "surfaces", + to_json(g_wayland->controller->surfaces)); + json_object_object_add(o, "layers", to_json(g_wayland->controller->layers)); + json_object_object_add(o, "screens", + to_json(g_wayland->controller->screens)); + + afb_req_success(req, o, "status"); +} + +void debug_surfaces(afb_req req) { + afb_req_success(req, to_json(g_wayland->controller->surfaces), "surfaces"); +} + +void debug_layers(afb_req req) { + afb_req_success(req, to_json(g_wayland->controller->layers), "layers"); } + +#define WRAP(F) \ + [](afb_req req) noexcept { \ + CHECK_WAYLAND(); \ + try { \ + F(req); \ + } catch (std::exception & e) { \ + afb_req_fail_f(req, "failed", "Uncaught exception: %s", e.what()); \ + } \ + } + +const struct afb_verb_v2 verbs[] = { + {"debug::status", WRAP(debug_status), NULL, NULL, AFB_SESSION_NONE_V2}, + {"debug::layers", WRAP(debug_layers), NULL, NULL, AFB_SESSION_NONE_V2}, + {"debug::surfaces", WRAP(debug_surfaces), NULL, NULL, AFB_SESSION_NONE_V2}, + {}, +}; +} // namespace + +extern "C" const struct afb_binding_v2 afbBindingV2 = { + "winman", NULL, NULL, verbs, NULL, binding_init, NULL, 1};