X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fmain.cpp;h=5b140f2ac190db0c9be86620ace768acbe89bee4;hb=6fdda786876d9640a6a26f05ef2c5aa7e2175421;hp=52d6b3207317bb28cd31be152d7dd796ce6ecc7d;hpb=1c2a6b6e01836423ca4168cc3f067a113efe654b;p=staging%2Fwindowmanager.git diff --git a/src/main.cpp b/src/main.cpp index 52d6b32..5b140f2 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -1,171 +1,162 @@ -#include "util.h" +/* + * Copyright (C) 2017 Mentor Graphics Development (Deutschland) GmbH + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "app.hpp" +#include "json_helper.hpp" +#include "util.hpp" #include "wayland.hpp" -#include +#include +#include -#include +#include -struct connection { - std::vector> outputs; - std::unique_ptr c; -}; +extern "C" { +#include +#include +} namespace { -// _ _ _ ____ -// ___| |__ ___ ___| | __ _____ _____ _ __ | |_ ___ / /\ \ -// / __| '_ \ / _ \/ __| |/ / / _ \ \ / / _ \ '_ \| __/ __| | | | -// | (__| | | | __/ (__| < | __/\ V / __/ | | | |_\__ \ | | | -// \___|_| |_|\___|\___|_|\_\___\___| \_/ \___|_| |_|\__|___/ | | | -// |_____| \_\/_/ -int check_events(struct wl::display &d, struct connection &c, int fd) { - struct pollfd pfd[2] = {{.fd = d.get_fd(), .events = POLLIN, .revents = 0}, - {.fd = fd, .events = POLLIN, .revents = 0}}; - - d.flush(); - - if (poll(pfd, fd != -1 ? 2 : 1, -1) != -1 && errno != EINTR) { - int ret = 0; - - if ((pfd[0].revents & POLLIN) != 0) { - ret = d.dispatch(); - } - if (ret == -1) { - return ret; - } +struct afb_instance { + std::unique_ptr display; + wm::App app; - if (fd != -1 && ((pfd[1].revents & POLLIN) != 0)) { - char buf[256]; - - // read all there is ... - while (read(pfd[1].fd, buf, sizeof(buf)) == sizeof(buf)) { - ; - } - - // Display current status - if (!c.c->surfaces.empty()) { - puts("Surfaces:"); - for (auto const &i : c.c->surfaces) { - auto const &r = i.second->dst_rect; - auto const &s = i.second->size; - printf("%d [%ux%u] (%ux%u@%dx%d), ", i.first, s.w, s.h, r.w, r.h, - r.x, r.y); - } - puts("\b\b "); - } - - if (!c.c->layers.empty()) { - puts("Layers:"); - for (auto const &i : c.c->layers) { - auto const &r = i.second->dst_rect; - auto const &s = i.second->size; - printf("%d [%ux%u] (%ux%u@%dx%d), ", i.first, s.w, s.h, r.w, r.h, - r.x, r.y); - } - puts("\b\b "); - } - } - } + afb_instance() : display{new wl::display}, app{this->display.get()} {} - return 0; -} + int init(); +}; -// _ _ _ _ _ ____ -// (_)_ __ (_) |_ | | __ _ _ _ ___ _ _| |_ / /\ \ -// | | '_ \| | __| | |/ _` | | | |/ _ \| | | | __| | | | -// | | | | | | |_ | | (_| | |_| | (_) | |_| | |_| | | | -// |_|_| |_|_|\__|___|_|\__,_|\__, |\___/ \__,_|\__| | | | -// |_____| |___/ \_\/_/ -char const *init_layout(struct connection &c) { - if (!c.c) { - return "ivi_controller global not available"; - } +struct afb_instance *g_afb_instance; - if (c.outputs.empty()) { - return "no output was set up!"; +int afb_instance::init() { + if (!this->display->ok()) { + return -1; } - auto &o = c.outputs.front(); - auto &s = c.c->screens.begin()->second; - auto &layers = c.c->layers; - - // XXX: Write output dimensions to ivi controller... - c.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.c->layer_create(100, 0, 0); // bottom layer, anything else - c.c->layer_create(1000, 0, 0); // top layer, mandelbrot + return this->app.init(); +} - auto &l100 = c.c->layers[100]; - auto &l1k = c.c->layers[1000]; +int display_event_callback(sd_event_source *evs, int /*fd*/, uint32_t events, + void * /*data*/) { + ST(); - // 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); + if ((events & EPOLLHUP) != 0) { + logerror("The compositor hung up, dying now."); + delete g_afb_instance; + g_afb_instance = nullptr; + goto error; + } - // Add layers to screen - s->set_render_order({100, 1000}); + if ((events & EPOLLIN) != 0u) { + { + STN(display_read_events); + g_afb_instance->app.display->read_events(); + g_afb_instance->app.set_pending_events(); + } + { + // We want do dispatch pending wayland events from within + // the API context + STN(winman_ping_api_call); + afb_service_call("winman", "ping", json_object_new_object(), + [](void *c, int st, json_object *j) { + STN(winman_ping_api_call_return); + }, + nullptr); + } + } - c.c->commit_changes(); - // Note: this does not flush the display! + return 0; - return nullptr; +error: + sd_event_source_unref(evs); + if (getenv("WINMAN_EXIT_ON_HANGUP") != nullptr) { + exit(1); +} + return -1; } -} // namespace -// _ ____ -// _ __ ___ __ _(_)_ __ / /\ \ -// | '_ ` _ \ / _` | | '_ \| | | | -// | | | | | | (_| | | | | | | | | -// |_| |_| |_|\__,_|_|_| |_| | | | -// \_\/_/ -int main(int /*argc*/, char ** /*argv*/) { +// _ _ _ _ _ _ _ ____ +// | |__ (_)_ __ __| (_)_ __ __ _ (_)_ __ (_) |_ / /\ \ +// | '_ \| | '_ \ / _` | | '_ \ / _` | | | '_ \| | __| | | | +// | |_) | | | | | (_| | | | | | (_| | | | | | | | |_| | | | +// |_.__/|_|_| |_|\__,_|_|_| |_|\__, |___|_|_| |_|_|\__| | | | +// |___/_____| \_\/_/ +int binding_init_() { lognotice("WinMan ver. %s", WINMAN_VERSION_STRING); + if (g_afb_instance != nullptr) { + logerror("Wayland context already initialized?"); + return 0; + } + if (getenv("XDG_RUNTIME_DIR") == nullptr) { - fatal("Environment variable XDG_RUNTIME_DIR not set"); + logerror("Environment variable XDG_RUNTIME_DIR not set"); + goto error; } - struct wl::display d {}; - if (!d.ok()) { - fatal("Could not connect to compositor"); + g_afb_instance = new afb_instance; + if (g_afb_instance->init() == -1) { + logerror("Could not connect to compositor"); + goto error; } - struct connection c {}; + { + int ret = sd_event_add_io(afb_daemon_get_event_loop(), nullptr, + g_afb_instance->display->get_fd(), EPOLLIN, + display_event_callback, g_afb_instance); + if (ret < 0) { + logerror("Could not initialize afb_instance event handler: %d", -ret); + goto error; + } + } - d.r.add_global_handler( - "ivi_controller", [&c](wl_registry *r, uint32_t name, uint32_t v) { - c.c = std::make_unique(r, name, v); - }); + atexit([] { delete g_afb_instance; }); - d.r.add_global_handler( - "wl_output", [&c](wl_registry *r, uint32_t name, uint32_t v) { - c.outputs.emplace_back(std::make_unique(r, name, v)); - }); + return 0; - // First level objects - d.roundtrip(); - // Second level objects - d.roundtrip(); - // Third level objects - d.roundtrip(); +error: + delete g_afb_instance; + g_afb_instance = nullptr; + return -1; +} - if (char const *e = init_layout(c)) { - fatal("Could not init layout: %s", e); +int binding_init() noexcept { + try { + return binding_init_(); + } catch (std::exception &e) { + logerror("Uncaught exception in binding_init(): %s", e.what()); } + return -1; +} - while (check_events(d, c, STDIN_FILENO) != -1) { - c.c->execute_pending(); - d.flush(); - } +} // namespace - return 0; +#include "afb_binding_glue.inl" + +// XXX implement send_event right here... +namespace wm { +void binding_api::send_event(char const *evname, char const *label) { + logdebug("%s: %s(%s)", __func__, evname, label); + int ret = afb_daemon_broadcast_event(evname, json_object_new_string(label)); + if (ret != 0) { + logdebug("afb_event_broadcast failed: %m"); + } } +} // namespace wm + +extern "C" const struct afb_binding_v2 afbBindingV2 = { + "winman", nullptr, nullptr, winman_verbs, nullptr, binding_init, nullptr, 0};