/*; * Copyright (c) 2017 TOYOTA MOTOR CORPORATION * * 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 #include #include #include #include #include #include "util.hpp" #include "window_manager.hpp" #include "json_helper.hpp" extern "C" { #include #include } typedef struct WMClientCtxt { std::string name; std::string role; WMClientCtxt(const char *appName, const char* appRole) { name = appName; role = appRole; } } WMClientCtxt; struct afb_instance { wm::WindowManager wmgr; afb_instance() : wmgr() {} ~afb_instance() = default; int init(); bool testFlg; }; struct afb_instance *g_afb_instance; std::mutex binding_m; int afb_instance::init() { return this->wmgr.init(); } int _binding_init() { HMI_NOTICE("WinMan ver. %s", WINMAN_VERSION_STRING); g_afb_instance = new afb_instance; if (g_afb_instance->init() == -1) { HMI_ERROR("Could not connect to compositor"); goto error; } g_afb_instance->testFlg = false; atexit([] { delete g_afb_instance; }); return 0; error: delete g_afb_instance; g_afb_instance = nullptr; return -1; } int binding_init() noexcept { try { return _binding_init(); } catch (std::exception &e) { HMI_ERROR("Uncaught exception in binding_init(): %s", e.what()); } return -1; } static void cbRemoveClientCtxt(void *data) { WMClientCtxt *ctxt = (WMClientCtxt *)data; if (ctxt == nullptr) { return; } HMI_DEBUG("remove app %s", ctxt->name.c_str()); // Policy Manager does not know this app was killed, // so notify it by deactivate request. g_afb_instance->wmgr.api_deactivate_window( ctxt->name.c_str(), ctxt->role.c_str(), [](const char *) {}); g_afb_instance->wmgr.removeClient(ctxt->name); delete ctxt; } static void createSecurityContext(afb_req req, const char* appid, const char* role) { WMClientCtxt *ctxt = (WMClientCtxt *)afb_req_context_get(req); if (!ctxt) { // Create Security Context at first time const char *new_role = g_afb_instance->wmgr.convertRoleOldToNew(role); WMClientCtxt *ctxt = new WMClientCtxt(appid, new_role); HMI_DEBUG("create session for %s", ctxt->name.c_str()); afb_req_session_set_LOA(req, 1); afb_req_context_set(req, ctxt, cbRemoveClientCtxt); } } void windowmanager_requestsurface(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { const char *a_drawing_name = afb_req_value(req, "drawing_name"); if (!a_drawing_name) { afb_req_fail(req, "failed", "Need char const* argument drawing_name"); return; } char *appid = afb_req_get_application_id(req); if(appid) { auto ret = g_afb_instance->wmgr.api_request_surface( appid, a_drawing_name); if (ret.is_err()) { afb_req_fail(req, "failed", ret.unwrap_err()); } else { createSecurityContext(req, appid, a_drawing_name); afb_req_success(req, json_object_new_int(ret.unwrap()), "success"); } free(appid); } else { afb_req_fail(req, "failed", nullptr); } } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling requestsurface: %s", e.what()); return; } } void windowmanager_requestsurfacexdg(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { json_object *jreq = afb_req_json(req); json_object *j_drawing_name = nullptr; if (!json_object_object_get_ex(jreq, "drawing_name", &j_drawing_name)) { afb_req_fail(req, "failed", "Need char const* argument drawing_name"); return; } char const *a_drawing_name = json_object_get_string(j_drawing_name); json_object *j_ivi_id = nullptr; if (!json_object_object_get_ex(jreq, "ivi_id", &j_ivi_id)) { afb_req_fail(req, "failed", "Need char const* argument ivi_id"); return; } char const *a_ivi_id = json_object_get_string(j_ivi_id); char *appid = afb_req_get_application_id(req); if(appid) { auto ret = g_afb_instance->wmgr.api_request_surface( appid, a_drawing_name, a_ivi_id); if (ret != nullptr) { afb_req_fail(req, "failed", ret); } else { createSecurityContext(req, appid, a_drawing_name); afb_req_success(req, NULL, "success"); } free(appid); } } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling requestsurfacexdg: %s", e.what()); return; } } void windowmanager_setrole(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { json_object *jreq = afb_req_json(req); json_object *j_role = nullptr; if (!json_object_object_get_ex(jreq, "role", &j_role)) { afb_req_fail(req, "failed", "Need char const* argument role"); return; } char const *a_role = json_object_get_string(j_role); char *appid = afb_req_get_application_id(req); if(appid) { auto ret = g_afb_instance->wmgr.api_set_role(appid, a_role); if (!ret) { afb_req_fail(req, "failed", "Couldn't register"); } else { createSecurityContext(req, appid, a_role); afb_req_success(req, NULL, "success"); } free(appid); } } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling requestsurfacexdg: %s", e.what()); return; } } void windowmanager_activatewindow(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { const char *a_drawing_name = afb_req_value(req, "drawing_name"); if (!a_drawing_name) { afb_req_fail(req, "failed", "Need char const* argument drawing_name"); return; } const char *a_drawing_area = afb_req_value(req, "drawing_area"); if (!a_drawing_area) { afb_req_fail(req, "failed", "Need char const* argument drawing_area"); return; } char* appid = afb_req_get_application_id(req); if(appid) { auto reply = [&req](const char *errmsg) { if (errmsg != nullptr) { HMI_ERROR(errmsg); afb_req_fail(req, "failed", errmsg); return; } afb_req_success(req, NULL, "success"); }; HMI_DEBUG("activateWindow role:%s area:%s", appid, a_drawing_area); #if 0 std::string appidString = appid; HMI_DEBUG("flg: %d", g_afb_instance->testFlg); if ((appidString == "dashboard" && g_afb_instance->testFlg) || appidString == "hudspeed") { HMI_DEBUG("%s is remote transfer", appid); g_afb_instance->wmgr.api_activate_surface_to_master( appid, a_drawing_name, "hud.upper.left", reply); g_afb_instance->testFlg = false; return; } #endif if (!g_afb_instance->wmgr.wmcon.isRemoteArea(a_drawing_area)) { g_afb_instance->wmgr.api_activate_window( appid, a_drawing_name, a_drawing_area, reply); } else { std::string ecu_name; ecu_name = g_afb_instance->wmgr.wmcon.getAreaToEcuName(a_drawing_area); // TODO: temporarily if (!g_afb_instance->wmgr.wmcon.isConnectionMode()) { HMI_ERROR("WM Standalone Mode"); afb_req_fail(req, "failed", "Standalone Mode"); } else { // If Window Manager is slave and this request is for master, // request activateWindow to master g_afb_instance->wmgr.api_activate_surface_to_master( appid, a_drawing_name, a_drawing_area, reply); } } #if 0 if (appidString == "dashboard") { g_afb_instance->testFlg = true; } #endif free(appid); } } catch (std::exception &e) { HMI_WARNING("failed: Uncaught exception while calling activatesurface: %s", e.what()); g_afb_instance->wmgr.exceptionProcessForTransition(); return; } } void windowmanager_deactivatewindow(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { const char *a_drawing_name = afb_req_value(req, "drawing_name"); if (!a_drawing_name) { afb_req_fail(req, "failed", "Need char const* argument drawing_name"); return; } char* appid = afb_req_get_application_id(req); if(appid) { auto reply = [&req](const char *errmsg) { if (errmsg != nullptr) { HMI_ERROR(errmsg); afb_req_fail(req, "failed", errmsg); return; } afb_req_success(req, NULL, "success"); }; // TODO: Check whether role is tbtnavi to request remote invisible if (g_afb_instance->wmgr.wmcon.getAppIdToEcuName(appid) == "" || ("tbtnavi" != std::string(a_drawing_name))) { g_afb_instance->wmgr.api_deactivate_window( appid, a_drawing_name, reply); } else { // If Window Manager is slave and this request is for master, // request deactivateWindow to master g_afb_instance->wmgr.api_deactivate_surface_to_master( appid, a_drawing_name, reply); } free(appid); } } catch (std::exception &e) { HMI_WARNING("failed: Uncaught exception while calling deactivatesurface: %s", e.what()); g_afb_instance->wmgr.exceptionProcessForTransition(); return; } } void windowmanager_enddraw(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { const char *a_drawing_name = afb_req_value(req, "drawing_name"); if (!a_drawing_name) { afb_req_fail(req, "failed", "Need char const* argument drawing_name"); return; } afb_req_success(req, NULL, "success"); char* appid = afb_req_get_application_id(req); if(appid) { if (!g_afb_instance->wmgr.wmcon.isRemoteEcu(appid) || !g_afb_instance->wmgr.wmcon.isSyncDrawingForRemote(appid)) { g_afb_instance->wmgr.api_enddraw(appid, a_drawing_name); } else { // If Window Manager is slave and requesting app is syncDrawing, // request endDraw to master g_afb_instance->wmgr.api_enddraw_for_remote(appid, a_drawing_name); } free(appid); } } catch (std::exception &e) { HMI_WARNING("failed: Uncaught exception while calling enddraw: %s", e.what()); g_afb_instance->wmgr.exceptionProcessForTransition(); return; } } void windowmanager_getdisplayinfo_thunk(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { auto ret = g_afb_instance->wmgr.api_get_display_info(); if (ret.is_err()) { afb_req_fail(req, "failed", ret.unwrap_err()); return; } afb_req_success(req, ret.unwrap(), "success"); } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling getdisplayinfo: %s", e.what()); return; } } void windowmanager_getareainfo_thunk(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { json_object *jreq = afb_req_json(req); json_object *j_drawing_name = nullptr; if (!json_object_object_get_ex(jreq, "drawing_name", &j_drawing_name)) { afb_req_fail(req, "failed", "Need char const* argument drawing_name"); return; } char const *a_drawing_name = json_object_get_string(j_drawing_name); auto ret = g_afb_instance->wmgr.api_get_area_info(a_drawing_name); if (ret.is_err()) { afb_req_fail(req, "failed", ret.unwrap_err()); return; } afb_req_success(req, ret.unwrap(), "success"); } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling getareainfo: %s", e.what()); return; } } void windowmanager_getcarinfo_thunk(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { json_object *jreq = afb_req_json(req); json_object *j_label = nullptr; if (! json_object_object_get_ex(jreq, "label", &j_label)) { afb_req_fail(req, "failed", "Need char const* argument label"); return; } char const* a_label = json_object_get_string(j_label); auto ret = g_afb_instance->wmgr.api_get_car_info(a_label); if (ret.is_err()) { afb_req_fail(req, "failed", ret.unwrap_err()); return; } afb_req_success(req, ret.unwrap(), "success"); } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling getcarinfo: %s", e.what()); return; } } void windowmanager_set_render_order(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } char* appid = afb_req_get_application_id(req); if(appid) { json_object *jreq = afb_req_json(req); json_object *j_ro; // Do not free this. binder frees jreq, then free j_ro if (json_object_object_get_ex(jreq, "render_order", &j_ro)) { int size = json_object_array_length(j_ro); std::vector ro(size); for(int i = 0; i < size; i++) { ro[i] = json_object_get_string(json_object_array_get_idx(j_ro, i)); } auto ret = g_afb_instance->wmgr.api_client_set_render_order(appid, ro); if (!ret) { afb_req_fail(req, "failed", nullptr); } else { afb_req_success(req, nullptr, nullptr); } } free(appid); } else { afb_req_fail(req, "failed", nullptr); } } void windowmanager_attach_app(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } char* appid = afb_req_get_application_id(req); if(appid) { json_object *jreq = afb_req_json(req); json_object *j_dest, *j_id; // Do not free this. binder frees jreq, then free j_ro if (json_object_object_get_ex(jreq, "destination", &j_dest) && json_object_object_get_ex(jreq, "service_surface", &j_id)) { const char* dest_app = json_object_get_string(j_dest); const char* service = json_object_get_string(j_id); std::string uuid = g_afb_instance->wmgr.api_client_attach_service_surface(appid, dest_app, service); if (uuid.empty()) { afb_req_fail(req, "failed", nullptr); } else { json_object *resp = json_object_new_object(); json_object_object_add(resp, "uuid", json_object_new_string(uuid.c_str())); afb_req_success(req, resp, nullptr); } } free(appid); } else { afb_req_fail(req, "failed", nullptr); } } void windowmanager_get_area_list(afb_req req) noexcept { std::lock_guard guard(binding_m); json_object* ret = g_afb_instance->wmgr.api_get_area_list(); afb_req_success(req, ret, nullptr); } void windowmanager_change_area_size(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } char* appid = afb_req_get_application_id(req); if(appid) { ChangeAreaReq change_req; change_req.appname = appid; change_req.save = false; json_object *jreq = afb_req_json(req); json_object *jsave, *jareas; HMI_INFO("json_check, %s", json_object_get_string(jreq)); if(json_object_object_get_ex(jreq, "save", &jsave)) { change_req.save = json_object_get_boolean(jsave); } if (json_object_object_get_ex(jreq, "areas", &jareas)) { int size = json_object_array_length(jareas); for(int i = 0; i < size; i++) { json_object* elem = json_object_array_get_idx(jareas, i); struct rect rect; std::string name = jh::getStringFromJson(elem, "name"); json_object* jrect; if(json_object_object_get_ex(elem, "rect", &jrect)) { rect.x = jh::getIntFromJson(jrect, "x"); rect.y = jh::getIntFromJson(jrect, "y"); rect.w = jh::getIntFromJson(jrect, "w"); rect.h = jh::getIntFromJson(jrect, "h"); } else { HMI_ERROR("bad request @area name :%s", name.c_str()); afb_req_fail(req, "failed", "bad request"); return; } change_req.area_req[name] = rect; } if(change_req.area_req.size() != 0) { g_afb_instance->wmgr.api_change_area_size(change_req); } afb_req_success(req, nullptr, nullptr); } free(appid); } else { afb_req_fail(req, "failed", nullptr); } } void windowmanager_wm_subscribe(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { json_object *jreq = afb_req_json(req); json_object *j = nullptr; if (!json_object_object_get_ex(jreq, "event", &j)) { afb_req_fail(req, "failed", "Need char const* argument event"); return; } int event_id = json_object_get_int(j); int ret = g_afb_instance->wmgr.api_subscribe(req, event_id); if (ret) { afb_req_fail(req, "failed", "Error: afb_req_subscribe()"); return; } afb_req_success(req, NULL, "success"); if (event_id == 7) { //g_afb_instance->wmgr.api_handshake(); g_afb_instance->wmgr.setSubscribed(true); } } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling wm_subscribe: %s", e.what()); return; } } void windowmanager_connect(afb_req req) noexcept { std::lock_guard guard(binding_m); HMI_DEBUG("WM - HS Connect"); if (g_afb_instance == nullptr) { afb_req_fail(req, "Failed", "Not Start WindowManager"); return; } else { afb_req_success(req, NULL, "success"); } } void windowmanager_ping(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } else { afb_req_success(req, NULL, "success"); } } void windowmanager_debug_terminate(afb_req req) noexcept { std::lock_guard guard(binding_m); if (g_afb_instance == nullptr) { afb_req_fail(req, "failed", "Binding not initialized, did the compositor die?"); return; } try { if (getenv("WINMAN_DEBUG_TERMINATE") != nullptr) { raise(SIGKILL); // afb-daemon kills it's pgroup using TERM, which // doesn't play well with perf } afb_req_success(req, NULL, "success"); } catch (std::exception &e) { afb_req_fail_f(req, "failed", "Uncaught exception while calling debug_terminate: %s", e.what()); return; } } void on_event(const char *event, struct json_object *object) { g_afb_instance->wmgr.analyzeReceivedEvent(event, object); } const struct afb_verb_v2 windowmanager_verbs[] = { {"requestSurface", windowmanager_requestsurface, nullptr, nullptr, AFB_SESSION_NONE}, {"requestSurfaceXdg", windowmanager_requestsurfacexdg, nullptr, nullptr, AFB_SESSION_NONE}, {"setRole", windowmanager_setrole, nullptr, nullptr, AFB_SESSION_NONE}, {"activateWindow", windowmanager_activatewindow, nullptr, nullptr, AFB_SESSION_NONE}, {"deactivateWindow", windowmanager_deactivatewindow, nullptr, nullptr, AFB_SESSION_NONE}, {"endDraw", windowmanager_enddraw, nullptr, nullptr, AFB_SESSION_NONE}, {"getDisplayInfo", windowmanager_getdisplayinfo_thunk, nullptr, nullptr, AFB_SESSION_NONE}, {"getAreaInfo", windowmanager_getareainfo_thunk, nullptr, nullptr, AFB_SESSION_NONE}, {"getCarInfo", windowmanager_getcarinfo_thunk, nullptr, nullptr, AFB_SESSION_NONE }, {"setRenderOrder", windowmanager_set_render_order, nullptr, nullptr, AFB_SESSION_NONE}, {"changeAreaSize", windowmanager_change_area_size, nullptr, nullptr, AFB_SESSION_NONE}, {"getAreaList", windowmanager_get_area_list, nullptr, nullptr, AFB_SESSION_NONE}, {"attachApp", windowmanager_attach_app, nullptr, nullptr, AFB_SESSION_NONE}, {"wm_subscribe", windowmanager_wm_subscribe, nullptr, nullptr, AFB_SESSION_NONE}, {"wm_connect", windowmanager_connect, nullptr, nullptr, AFB_SESSION_NONE}, {"ping", windowmanager_ping, nullptr, nullptr, AFB_SESSION_NONE}, {"debug_terminate", windowmanager_debug_terminate, nullptr, nullptr, AFB_SESSION_NONE}, {}}; extern "C" const struct afb_binding_v2 afbBindingV2 = { "windowmanager", nullptr, nullptr, windowmanager_verbs, nullptr, binding_init, on_event, 0};