/* * 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 "app.hpp" #include "json_helper.hpp" #include "layers.hpp" #include "layout.hpp" #include "util.hpp" #include "wayland_ivi_wm.hpp" #include #include #include #include #include #include #include #include #include #include #include namespace wm { /* DrawingArea name used by "{layout}.{area}" */ const char kNameLayoutNormal[] = "normal"; const char kNameLayoutSplit[] = "split"; const char kNameAreaFull[] = "full"; const char kNameAreaMain[] = "main"; const char kNameAreaSub[] = "sub"; /* Key for json obejct */ const char kKeyDrawingName[] = "drawing_name"; const char kKeyDrawingArea[] = "drawing_area"; const char kKeyDrawingRect[] = "drawing_rect"; const char kKeyX[] = "x"; const char kKeyY[] = "y"; const char kKeyWidth[] = "width"; const char kKeyHeight[] = "height"; const char kKeyWidthPixel[] = "width_pixel"; const char kKeyHeightPixel[] = "height_pixel"; const char kKeyWidthMm[] = "width_mm"; const char kKeyHeightMm[] = "height_mm"; namespace { using nlohmann::json; result file_to_json(char const *filename) { json j; std::ifstream i(filename); if (i.fail()) { HMI_DEBUG("wm", "Could not open config file, so use default layer information"); j = default_layers_json; } else { i >> j; } return Ok(j); } struct result load_layer_map(char const *filename) { HMI_DEBUG("wm", "loading IDs from %s", filename); auto j = file_to_json(filename); if (j.is_err()) { return Err(j.unwrap_err()); } json jids = j.unwrap(); return to_layer_map(jids); } } // namespace /** * App Impl */ App::App(wl::display *d) : chooks{this}, display{d}, controller{}, outputs(), config(), layers(), id_alloc{}, pending_events(false), policy{} { try { { auto l = load_layer_map( this->config.get_string("layers.json").value().c_str()); if (l.is_ok()) { this->layers = l.unwrap(); } else { HMI_ERROR("wm", "%s", l.err().value()); } } } catch (std::exception &e) { HMI_ERROR("wm", "Loading of configuration failed: %s", e.what()); } // Initialize current car info this->crr_car_info_.parking_brake_stt = true; this->crr_car_info_.accel_pedal_stt = false; this->crr_car_info_.accel_pedal_pos = 0; this->crr_car_info_.car_stt = "stop"; this->crr_car_info_.headlamp_stt = false; } int App::init() { if (!this->display->ok()) { return -1; } if (this->layers.mapping.empty()) { HMI_ERROR("wm", "No surface -> layer mapping loaded"); return -1; } #if 1 // @@@@@ // Load app.db this->loadAppDb(); #endif // Initialize PolicyManager this->pm_.initialize(); // Initialize LayoutManager this->lm_.initialize(); // Make afb event for (int i=Event_Val_Min; i<=Event_Val_Max; i++) { map_afb_event[kListEventName[i]] = afb_daemon_make_event(kListEventName[i]); } this->display->add_global_handler( "wl_output", [this](wl_registry *r, uint32_t name, uint32_t v) { this->outputs.emplace_back(std::make_unique(r, name, v)); }); this->display->add_global_handler( "ivi_wm", [this](wl_registry *r, uint32_t name, uint32_t v) { this->controller = std::make_unique(r, name, v); // Init controller hooks this->controller->chooks = &this->chooks; // This protocol needs the output, so lets just add our mapping here... this->controller->add_proxy_to_id_mapping( this->outputs.back()->proxy.get(), wl_proxy_get_id(reinterpret_cast( this->outputs.back()->proxy.get()))); // Create screen this->controller->create_screen(this->outputs.back()->proxy.get()); // Set display to controller this->controller->display = this->display; }); // First level objects this->display->roundtrip(); // Second level objects this->display->roundtrip(); // Third level objects this->display->roundtrip(); return init_layers(); } int App::dispatch_pending_events() { if (this->pop_pending_events()) { this->display->dispatch_pending(); return 0; } return -1; } bool App::pop_pending_events() { bool x{true}; return this->pending_events.compare_exchange_strong( x, false, std::memory_order_consume); } void App::set_pending_events() { this->pending_events.store(true, std::memory_order_release); } optional App::lookup_id(char const *name) { return this->id_alloc.lookup(std::string(name)); } optional App::lookup_name(int id) { return this->id_alloc.lookup(id); } /** * init_layers() */ int App::init_layers() { if (!this->controller) { HMI_ERROR("wm", "ivi_controller global not available"); return -1; } if (this->outputs.empty()) { HMI_ERROR("wm", "no output was set up!"); return -1; } auto &c = this->controller; auto &o = this->outputs.front(); auto &s = c->screens.begin()->second; auto &layers = c->layers; // Write output dimensions to ivi controller... c->output_size = compositor::size{uint32_t(o->width), uint32_t(o->height)}; c->physical_size = compositor::size{uint32_t(o->physical_width), uint32_t(o->physical_height)}; // Clear scene layers.clear(); // Clear screen s->clear(); // Quick and dirty setup of layers for (auto const &i : this->layers.mapping) { c->layer_create(i.second.layer_id, o->width, o->height); auto &l = layers[i.second.layer_id]; l->set_destination_rectangle(0, 0, o->width, o->height); l->set_visibility(1); HMI_DEBUG("wm", "Setting up layer %s (%d) for surface role match \"%s\"", i.second.name.c_str(), i.second.layer_id, i.second.role.c_str()); } // Add layers to screen s->set_render_order(this->layers.layers); this->layout_commit(); return 0; } void App::layout_commit() { this->controller->commit_changes(); this->display->flush(); } void App::allocateWindowResource(char const *event, char const *drawing_name, char const *drawing_area, char const *role, const reply_func &reply) { const char* new_role = nullptr; const char* new_area = nullptr; if (0 == strcmp("activate", event)) { // TODO: // This process will be removed // because the applications will specify role instead of drawing_name { if ((nullptr == role) || (0 == strcmp("", role))) { HMI_DEBUG("wm", "Role is not specified, so get by using app name"); new_role = this->app2role_[drawing_name].c_str(); } else { new_role = role; } HMI_DEBUG("wm", "drawing_name:%s, new_role: %s", drawing_name, new_role); } // TODO: // This process will be removed // because the area "normal.full" and "normalfull" will be prohibited { if (0 == strcmp("Restriction", drawing_name)) { new_area = drawing_area; } else { if (nullptr == drawing_area) { new_area = "normal"; } else if (0 == strcmp("normal.full", drawing_area)) { new_area = "normal"; } else if (0 == strcmp("restriction.split.sub", drawing_area)) { new_area = "restriction.split.sub"; } else if (0 == strcmp("homescreen", new_role)) { // Now homescreen specifies "normalfull" new_area = "full"; } else { new_area = "normal"; } } HMI_DEBUG("wm", "drawing_area:%s, new_area: %s", drawing_area, new_area); } } else if (0 == strcmp("deactivate", event)) { // TODO: // This process will be removed // because the applications will specify role instead of drawing_name { if ((nullptr == role) || (0 == strcmp("", role))) { HMI_DEBUG("wm", "Role is not specified, so get by using app name"); new_role = this->app2role_[drawing_name].c_str(); } else { new_role = role; } HMI_DEBUG("wm", "drawing_name:%s, new_role: %s", drawing_name, new_role); } new_area = ""; } // TODO: // Check role // TODO: // If event is "activate" and area is not specifid, // get default value by using role // Check Policy json_object* json_in = json_object_new_object(); json_object* json_out = json_object_new_object(); json_object_object_add(json_in, "event", json_object_new_string(event)); if (nullptr != new_role) { json_object_object_add(json_in, "role", json_object_new_string(new_role)); } if (nullptr != new_area) { json_object_object_add(json_in, "area", json_object_new_string(new_area)); } int ret = this->pm_.checkPolicy(json_in, &json_out); if (0 > ret) { reply("Error checkPolicy()"); return; } else { HMI_DEBUG("wm", "result: %s", json_object_get_string(json_out)); } // Release json_object json_object_put(json_in); // Check parking brake state json_object* json_parking_brake; if (!json_object_object_get_ex(json_out, "parking_brake", &json_parking_brake)) { reply("Not found key \"parking_brake\""); return; } json_bool is_changed; is_changed = jh::getBoolFromJson(json_parking_brake, "is_changed"); if (is_changed) { std::string parking_brake_state = jh::getStringFromJson(json_parking_brake, "state"); HMI_DEBUG("wm", "parking_brake_state: %s", parking_brake_state.c_str()); // Update state and emit event if ("parking_brake_off" == parking_brake_state) { this->crr_car_info_.parking_brake_stt = false; #if 0 // FOR ALS: using lightstatus brake, so do not emit parking brake event this->emitParkingBrakeOff(); #endif } else if ("parking_brake_on" == parking_brake_state) { this->crr_car_info_.parking_brake_stt = true; #if 0 // FOR ALS: using lightstatus brake, so do not emit parking brake event this->emitParkingBrakeOn(); #endif } else { reply("Unknown parking brake state"); return; } } // Check accelerator pedal state json_object* json_accel_pedal; if (!json_object_object_get_ex(json_out, "accel_pedal", &json_accel_pedal)) { reply("Not found key \"accel_pedal\""); return; } is_changed = jh::getBoolFromJson(json_accel_pedal, "is_changed"); if (is_changed) { std::string accel_pedal_state = jh::getStringFromJson(json_accel_pedal, "state"); HMI_DEBUG("wm", "accel_pedal_state: %s", accel_pedal_state.c_str()); // Update state if ("accel_pedal_off" == accel_pedal_state) { this->crr_car_info_.accel_pedal_stt = false; } else if ("accel_pedal_on" == accel_pedal_state) { this->crr_car_info_.accel_pedal_stt = true; } else { reply("Unknown accel pedal state"); return; } } // Check lightstatus brake state json_object* json_lightstatus_brake; if (!json_object_object_get_ex(json_out, "lightstatus_brake", &json_lightstatus_brake)) { reply("Not found key \"lightstatus_brake\""); return; } is_changed = jh::getBoolFromJson(json_lightstatus_brake, "is_changed"); if (is_changed) { std::string lightstatus_brake_state = jh::getStringFromJson(json_lightstatus_brake, "state"); HMI_DEBUG("wm", "lightstatus_brake_state: %s", lightstatus_brake_state.c_str()); // Update state and emit event if ("lightstatus_brake_off" == lightstatus_brake_state) { this->crr_car_info_.lightstatus_brake_stt = false; this->emitLightstatusBrakeOff(); } else if ("lightstatus_brake_on" == lightstatus_brake_state) { this->crr_car_info_.lightstatus_brake_stt = true; this->emitLightstatusBrakeOn(); } else { reply("Unknown lightstatus brake state"); return; } } // Check car state json_object* json_car; if (!json_object_object_get_ex(json_out, "car", &json_car)) { reply("Not found key \"car\""); return; } is_changed = jh::getBoolFromJson(json_car, "is_changed"); if (is_changed) { std::string car_state = jh::getStringFromJson(json_car, "state"); HMI_DEBUG("wm", "car_state: %s", car_state.c_str()); // Emit car event if ("car_stop" == car_state) { this->crr_car_info_.car_stt = "stop"; this->emitCarStop(); } else if ("car_run" == car_state) { this->crr_car_info_.car_stt = "run"; this->emitCarRun(); } else { reply("Unknown car state"); return; } } // Check lamp state json_object* json_lamp; if (!json_object_object_get_ex(json_out, "lamp", &json_lamp)) { reply("Not found key \"lamp\""); return; } is_changed = jh::getBoolFromJson(json_lamp, "is_changed"); if (is_changed) { std::string lamp_state = jh::getStringFromJson(json_lamp, "state"); HMI_DEBUG("wm", "lamp_state: %s", lamp_state.c_str()); // Update state and emit event if ("lamp_off" == lamp_state) { this->crr_car_info_.headlamp_stt = false; this->emitHeadlampOff(); } else if ("lamp_on" == lamp_state) { this->crr_car_info_.headlamp_stt = true; this->emitHeadlampOn(); } else { reply("Unknown lamp state"); return; } } // Get category const char* category = nullptr; std::string str_category; if (nullptr != new_role) { str_category = this->pm_.roleToCategory(new_role); category = str_category.c_str(); HMI_DEBUG("wm", "role:%s category:%s", new_role, category); } // Update layout if (this->lm_.updateLayout(json_out, new_role, category)) { HMI_DEBUG("wm", "Layer is changed!!"); // Allocate surface this->allocateSurface(); } else { HMI_DEBUG("wm", "All layer is NOT changed!!"); } // Release json_object json_object_put(json_out); return; } void App::enqueue_flushdraw(int surface_id) { this->check_flushdraw(surface_id); HMI_DEBUG("wm", "Enqueuing EndDraw for surface_id %d", surface_id); this->pending_end_draw.push_back(surface_id); } void App::check_flushdraw(int surface_id) { auto i = std::find(std::begin(this->pending_end_draw), std::end(this->pending_end_draw), surface_id); if (i != std::end(this->pending_end_draw)) { auto n = this->lookup_name(surface_id); HMI_ERROR("wm", "Application %s (%d) has pending EndDraw call(s)!", n ? n->c_str() : "unknown-name", surface_id); std::swap(this->pending_end_draw[std::distance( std::begin(this->pending_end_draw), i)], this->pending_end_draw.back()); this->pending_end_draw.resize(this->pending_end_draw.size() - 1); } } void App::api_enddraw(char const *drawing_name) { for (unsigned i = 0, iend = this->pending_end_draw.size(); i < iend; i++) { auto n = this->lookup_name(this->pending_end_draw[i]); if (n && *n == drawing_name) { std::swap(this->pending_end_draw[i], this->pending_end_draw[iend - 1]); this->pending_end_draw.resize(iend - 1); this->activate(this->pending_end_draw[i]); this->emit_flushdraw(drawing_name); } } } void App::api_ping() { this->dispatch_pending_events(); } void App::send_event(char const *evname){ HMI_DEBUG("wm", "%s: %s", __func__, evname); int ret = afb_event_push(this->map_afb_event[evname], nullptr); if (ret != 0) { HMI_DEBUG("wm", "afb_event_push failed: %m"); } } void App::send_event(char const *evname, char const *label){ HMI_DEBUG("wm", "%s: %s(%s)", __func__, evname, label); json_object *j = json_object_new_object(); json_object_object_add(j, kKeyDrawingName, json_object_new_string(label)); int ret = afb_event_push(this->map_afb_event[evname], j); if (ret != 0) { HMI_DEBUG("wm", "afb_event_push failed: %m"); } } void App::send_event(char const *evname, char const *label, char const *area, int x, int y, int w, int h) { HMI_DEBUG("wm", "%s: %s(%s, %s) x:%d y:%d w:%d h:%d", __func__, evname, label, area, x, y, w, h); json_object *j_rect = json_object_new_object(); json_object_object_add(j_rect, kKeyX, json_object_new_int(x)); json_object_object_add(j_rect, kKeyY, json_object_new_int(y)); json_object_object_add(j_rect, kKeyWidth, json_object_new_int(w)); json_object_object_add(j_rect, kKeyHeight, json_object_new_int(h)); json_object *j = json_object_new_object(); json_object_object_add(j, kKeyDrawingName, json_object_new_string(label)); json_object_object_add(j, kKeyDrawingArea, json_object_new_string(area)); json_object_object_add(j, kKeyDrawingRect, j_rect); int ret = afb_event_push(this->map_afb_event[evname], j); if (ret != 0) { HMI_DEBUG("wm", "afb_event_push failed: %m"); } } /** * proxied events */ void App::surface_created(uint32_t surface_id) { auto layer_id = this->layers.get_layer_id(surface_id); if (!layer_id) { HMI_DEBUG("wm", "Newly created surfce %d is not associated with any layer!", surface_id); return; } HMI_DEBUG("wm", "surface_id is %u, layer_id is %u", surface_id, *layer_id); this->controller->layers[*layer_id]->add_surface(surface_id); this->layout_commit(); // activate the main_surface right away /*if (surface_id == static_cast(this->layers.main_surface)) { HMI_DEBUG("wm", "Activating main_surface (%d)", surface_id); this->api_activate_surface( this->lookup_name(surface_id).value_or("unknown-name").c_str()); }*/ } void App::surface_removed(uint32_t surface_id) { HMI_DEBUG("wm", "surface_id is %u", surface_id); // We cannot normally deactivate the main_surface, so be explicit // about it: if (int(surface_id) == this->layers.main_surface) { this->deactivate_main_surface(); } else { auto drawing_name = this->lookup_name(surface_id); if (drawing_name) { this->allocateWindowResource("deactivate", drawing_name->c_str(), nullptr, nullptr, [](const char*){}); } } this->id_alloc.remove_id(surface_id); this->layers.remove_surface(surface_id); } void App::emit_activated(char const *label) { this->send_event(kListEventName[Event_Active], label); } void App::emit_deactivated(char const *label) { this->send_event(kListEventName[Event_Inactive], label); } void App::emit_syncdraw(char const *label, char const *area, int x, int y, int w, int h) { this->send_event(kListEventName[Event_SyncDraw], label, area, x, y, w, h); } void App::emit_flushdraw(char const *label) { this->send_event(kListEventName[Event_FlushDraw], label); } void App::emit_visible(char const *label, bool is_visible) { this->send_event(is_visible ? kListEventName[Event_Visible] : kListEventName[Event_Invisible], label); } void App::emit_invisible(char const *label) { return emit_visible(label, false); } void App::emit_visible(char const *label) { return emit_visible(label, true); } void App::emitHeadlampOff() { // Send HeadlampOff event for all application this->send_event(kListEventName[Event_HeadlampOff]); } void App::emitHeadlampOn() { // Send HeadlampOn event for all application this->send_event(kListEventName[Event_HeadlampOn]); } void App::emitParkingBrakeOff() { // Send ParkingBrakeOff event for all application this->send_event(kListEventName[Event_ParkingBrakeOff]); } void App::emitParkingBrakeOn() { // Send ParkingBrakeOn event for all application this->send_event(kListEventName[Event_ParkingBrakeOn]); } void App::emitLightstatusBrakeOff() { // Send LightstatusBrakeOff event for all application this->send_event(kListEventName[Event_LightstatusBrakeOff]); } void App::emitLightstatusBrakeOn() { // Send LightstatusBrakeOn event for all application this->send_event(kListEventName[Event_LightstatusBrakeOn]); } void App::emitCarStop() { // Send CarStop event for all application this->send_event(kListEventName[Event_CarStop]); } void App::emitCarRun() { // Send CarRun event for all application this->send_event(kListEventName[Event_CarRun]); } result App::api_request_surface(char const *drawing_name) { auto lid = this->layers.get_layer_id(std::string(drawing_name)); if (!lid) { /** * register drawing_name as fallback and make it displayed. */ lid = this->layers.get_layer_id(std::string("Fallback")); HMI_DEBUG("wm", "%s is not registered in layers.json, then fallback as normal app", drawing_name); if(!lid){ return Err("Drawing name does not match any role, Fallback is disabled"); } } auto rname = this->lookup_id(drawing_name); if (!rname) { // name does not exist yet, allocate surface id... auto id = int(this->id_alloc.generate_id(drawing_name)); this->layers.add_surface(id, *lid); // set the main_surface[_name] here and now if (!this->layers.main_surface_name.empty() && this->layers.main_surface_name == drawing_name) { this->layers.main_surface = id; HMI_DEBUG("wm", "Set main_surface id to %u", id); } #if 0 // @@@@@ // TODO: // This process will be implemented in SystemManager { // Generate app id auto id = int(this->app_id_alloc_.generate_id(drawing_name)); this->appname2appid_[drawing_name] = id; } #endif // Set map of (role, surface_id) std::string role = this->app2role_[std::string(drawing_name)]; this->role2surfaceid_[role] = id; // Set map of (role, app) // If the new app which has the same role which is had by existing app is requested, // the role is given to the new app. this->role2app_[role] = std::string(drawing_name); return Ok(id); } // Check currently registered drawing names if it is already there. return Err("Surface already present"); } char const *App::api_request_surface(char const *drawing_name, char const *ivi_id) { ST(); auto lid = this->layers.get_layer_id(std::string(drawing_name)); unsigned sid = std::stol(ivi_id); if (!lid) { /** * register drawing_name as fallback and make it displayed. */ lid = this->layers.get_layer_id(std::string("Fallback")); HMI_DEBUG("wm", "%s is not registered in layers.json, then fallback as normal app", drawing_name); if(!lid){ return "Drawing name does not match any role, Fallback is disabled"; } } auto rname = this->lookup_id(drawing_name); if (rname) { return "Surface already present"; } // register pair drawing_name and ivi_id this->id_alloc.register_name_id(drawing_name, sid); this->layers.add_surface(sid, *lid); // this surface is already created HMI_DEBUG("wm", "surface_id is %u, layer_id is %u", sid, *lid); this->controller->layers[*lid]->add_surface(sid); this->layout_commit(); return nullptr; } result App::api_get_display_info() { // Check controller if (!this->controller) { return Err("ivi_controller global not available"); } // Set display info compositor::size o_size = this->controller->output_size; compositor::size p_size = this->controller->physical_size; json_object *object = json_object_new_object(); json_object_object_add(object, kKeyWidthPixel, json_object_new_int(o_size.w)); json_object_object_add(object, kKeyHeightPixel, json_object_new_int(o_size.h)); json_object_object_add(object, kKeyWidthMm, json_object_new_int(p_size.w)); json_object_object_add(object, kKeyHeightMm, json_object_new_int(p_size.h)); return Ok(object); } result App::api_get_area_info(char const *drawing_name) { HMI_DEBUG("wm", "called"); // Check drawing name, surface/layer id auto const &surface_id = this->lookup_id(drawing_name); if (!surface_id) { return Err("Surface does not exist"); } if (!this->controller->surface_exists(*surface_id)) { return Err("Surface does not exist in controller!"); } auto layer_id = this->layers.get_layer_id(*surface_id); if (!layer_id) { return Err("Surface is not on any layer!"); } auto o_state = *this->layers.get_layout_state(*surface_id); if (o_state == nullptr) { return Err("Could not find layer for surface"); } // Set area rectangle compositor::rect area_info = this->area_info[*surface_id]; json_object *object = json_object_new_object(); json_object_object_add(object, kKeyX, json_object_new_int(area_info.x)); json_object_object_add(object, kKeyY, json_object_new_int(area_info.y)); json_object_object_add(object, kKeyWidth, json_object_new_int(area_info.w)); json_object_object_add(object, kKeyHeight, json_object_new_int(area_info.h)); return Ok(object); } result App::api_get_car_info(char const *label) { HMI_DEBUG("wm", "called"); json_object *j_in = nullptr; json_object *j_out = nullptr; if (0 == strcmp("parking_brake_status", label)) { // Get parking brake status json_bool val = this->crr_car_info_.parking_brake_stt; j_in = json_object_new_boolean(val); } else if (0 == strcmp("accelerator.pedal.position", label)) { // Get accelerator pedal position double val = this->crr_car_info_.accel_pedal_pos; j_in = json_object_new_double(val); } else if (0 == strcmp("car_state", label)) { // Get car state const char* val = this->crr_car_info_.car_stt; j_in = json_object_new_string(val); } else if (0 == strcmp("lightstatus.brake", label)) { // Get lightstatus brake status json_bool val = this->crr_car_info_.lightstatus_brake_stt; j_in = json_object_new_boolean(val); } else { return Err("Car info does not exist"); } // Create output object j_out = json_object_new_object(); json_object_object_add(j_out, "value", j_in); return Ok(j_out); } void App::activate(int id) { auto ip = this->controller->sprops.find(id); if (ip != this->controller->sprops.end()) { this->controller->surfaces[id]->set_visibility(1); char const *label = this->lookup_name(id).value_or("unknown-name").c_str(); // FOR CES DEMO >>> if ((0 == strcmp(label, "Radio")) || (0 == strcmp(label, "MediaPlayer")) || (0 == strcmp(label, "Music")) || (0 == strcmp(label, "Navigation"))) { for (auto i = surface_bg.begin(); i != surface_bg.end(); ++i) { if (id == *i) { // Remove id this->surface_bg.erase(i); // Remove from BG layer (999) HMI_DEBUG("wm", "Remove %s(%d) from BG layer", label, id); this->controller->layers[999]->remove_surface(id); // Add to FG layer (1001) HMI_DEBUG("wm", "Add %s(%d) to FG layer", label, id); this->controller->layers[1001]->add_surface(id); for (int j : this->surface_bg) { HMI_DEBUG("wm", "Stored id:%d", j); } break; } } } // <<< FOR CES DEMO this->layout_commit(); this->emit_visible(label); this->emit_activated(label); } } void App::deactivate(int id) { auto ip = this->controller->sprops.find(id); if (ip != this->controller->sprops.end()) { char const *label = this->lookup_name(id).value_or("unknown-name").c_str(); // FOR CES DEMO >>> if ((0 == strcmp(label, "Radio")) || (0 == strcmp(label, "MediaPlayer")) || (0 == strcmp(label, "Music")) || (0 == strcmp(label, "Navigation"))) { // Store id this->surface_bg.push_back(id); // Remove from FG layer (1001) HMI_DEBUG("wm", "Remove %s(%d) from FG layer", label, id); this->controller->layers[1001]->remove_surface(id); // Add to BG layer (999) HMI_DEBUG("wm", "Add %s(%d) to BG layer", label, id); this->controller->layers[999]->add_surface(id); for (int j : surface_bg) { HMI_DEBUG("wm", "Stored id:%d", j); } } else { this->controller->surfaces[id]->set_visibility(0); } // <<< FOR CES DEMO this->layout_commit(); this->emit_deactivated(label); this->emit_invisible(label); } } void App::deactivate(std::string role) { std::string app = this->role2app_[role]; auto const &id = this->lookup_id(app.c_str()); if (!id) { HMI_ERROR("wm", "Surface does not exist"); return; } HMI_DEBUG("wm", "Deactivate role:%s (app:%s)", role.c_str(), app.c_str()); this->deactivate(*id); } void App::deactivate_main_surface() { this->layers.main_surface = -1; this->allocateWindowResource("deactivate", this->layers.main_surface_name.c_str(), nullptr, nullptr, [](const char*){}); } /** * controller_hooks */ void controller_hooks::surface_created(uint32_t surface_id) { this->app->surface_created(surface_id); } void controller_hooks::surface_removed(uint32_t surface_id) { this->app->surface_removed(surface_id); } void controller_hooks::surface_visibility(uint32_t /*surface_id*/, uint32_t /*v*/) {} void controller_hooks::surface_destination_rectangle(uint32_t /*surface_id*/, uint32_t /*x*/, uint32_t /*y*/, uint32_t /*w*/, uint32_t /*h*/) {} int App::allocateSurface() { HMI_DEBUG("wm", "Call"); // Get current/previous layers LayoutManager::TypeLayers crr_layers = this->lm_.getCurrentLayers(); LayoutManager::TypeLayers prv_layers = this->lm_.getPreviousLayers(); // Update resource of all layers for (auto itr_layers = crr_layers.begin(); itr_layers != crr_layers.end(); ++itr_layers) { // Get layer std::string layer = itr_layers->first; HMI_DEBUG("wm", "Try to update resource in %s layer", layer.c_str()); // If layout is changed, update resouce if (this->lm_.isLayoutChanged(layer.c_str())) { // Get current/previous layout LayoutManager::TypeLayouts crr_layout = itr_layers->second; LayoutManager::TypeLayouts prv_layout = prv_layers[layer]; // Get current/previous layout name std::string crr_layout_name = crr_layout.begin()->first; std::string prv_layout_name = prv_layout.begin()->first; HMI_DEBUG("wm", "layout name crr:%s prv:%s", crr_layout_name.c_str(), prv_layout_name.c_str()); // Get current/previous ares LayoutManager::TypeAreas crr_areas = crr_layout[crr_layout_name]; LayoutManager::TypeAreas prv_areas = prv_layout[prv_layout_name]; // Create previous displayed role list std::string prv_area_name; std::vector prv_role_list; for (auto itr_areas = prv_areas.begin(); itr_areas != prv_areas.end(); ++itr_areas) { prv_area_name = itr_areas->first; prv_role_list.push_back(prv_areas[prv_area_name]["role"]); HMI_DEBUG("wm", "previous displayed role:%s", prv_areas[prv_area_name]["role"].c_str()); } // Allocate surface for each area std::string crr_area_name; std::string crr_role_name; LayoutManager::TypeRolCtg crr_rol_ctg; for (auto itr_areas = crr_areas.begin(); itr_areas != crr_areas.end(); ++itr_areas) { crr_area_name = itr_areas->first; crr_rol_ctg = itr_areas->second; // Get role of current area if ("category" == crr_rol_ctg.begin()->first) { // If current area have category // Get category name std::string crr_ctg = crr_rol_ctg.begin()->second; // Serch relevant role from previous displayed role list for (auto itr_role = prv_role_list.begin(); itr_role != prv_role_list.end(); ++itr_role) { std::string prv_ctg = this->pm_.roleToCategory((*itr_role).c_str()); if (crr_ctg == prv_ctg) { // First discovered role is set to current role crr_role_name = *itr_role; // Delete used role for other areas // which have same category prv_role_list.erase(itr_role); break; } } } else { crr_role_name = itr_areas->second["role"]; } HMI_DEBUG("wm", "Allocate surface for area:%s role:%s", crr_area_name.c_str(), crr_role_name.c_str()); // Deactivate non-displayed role std::string prv_role_name; if (crr_layout_name == prv_layout_name) { HMI_DEBUG("wm", "Current layout is same with previous"); // Deactivate previous role in same area // if it is different with current prv_role_name = prv_areas[crr_area_name]["role"]; if (crr_role_name != prv_role_name) { this->deactivate(prv_role_name); } } else { HMI_DEBUG("wm", "Current layout is different with previous"); if ("none" != prv_layout_name) { // Deactivate previous role in all area in previous layout // if it is different with current role for(auto itr = prv_areas.begin(); itr != prv_areas.end(); ++itr) { prv_role_name = itr->second["role"].c_str(); if (crr_role_name != prv_role_name) { this->deactivate(prv_role_name); } } } } // Set surface for displayed role if ("none" != crr_layout_name) { // If current layout is not "none", // set surface for current role this->setSurfaceSize(crr_role_name.c_str(), crr_area_name.c_str()); // TODO: // This API is workaround. // Resource manager should manage each resource infomations // according to architecture document. this->lm_.updateArea(layer.c_str(), crr_role_name.c_str(), crr_area_name.c_str()); } } } } return 0; } void App::setSurfaceSize(const char* role, const char* area) { HMI_DEBUG("wm", "role:%s area:%s", role, area); // Get size of current area compositor::rect size = this->lm_.getAreaSize(area); // Set destination to the display rectangle int surface_id = this->role2surfaceid_[role]; if (!this->controller->surface_exists(surface_id)) { // Block until all pending request are processed by wayland display server // because waiting for the surface of new app is created this->display->roundtrip(); } auto &s = this->controller->surfaces[surface_id]; s->set_destination_rectangle(size.x, size.y, size.w, size.h); this->layout_commit(); // Update area information this->area_info[surface_id].x = size.x; this->area_info[surface_id].y = size.y; this->area_info[surface_id].w = size.w; this->area_info[surface_id].h = size.h; HMI_DEBUG("wm", "Surface rect { %d, %d, %d, %d }", size.x, size.y, size.w, size.h); // Emit syncDraw event const char* app = this->role2app_[role].c_str(); this->emit_syncdraw(app, area, size.x, size.y, size.w, size.h); // Enqueue flushDraw event this->enqueue_flushdraw(surface_id); } void App::setAccelPedalPos(double val) { this->crr_car_info_.accel_pedal_pos = val; } extern const char* kDefaultAppDb; int App::loadAppDb() { HMI_DEBUG("wm", "Call"); // Get afm application installed dir char const *afm_app_install_dir = getenv("AFM_APP_INSTALL_DIR"); HMI_DEBUG("wm", "afm_app_install_dir:%s", afm_app_install_dir); std::string file_name; if (!afm_app_install_dir) { HMI_ERROR("wm", "AFM_APP_INSTALL_DIR is not defined"); } else { file_name = std::string(afm_app_install_dir) + std::string("/etc/app.db"); } // Load app.db json_object* json_obj; int ret = jh::inputJsonFilie(file_name.c_str(), &json_obj); if (0 > ret) { HMI_ERROR("wm", "Could not open app.db, so use default role information"); json_obj = json_tokener_parse(kDefaultAppDb); } HMI_DEBUG("wm", "json_obj dump:%s", json_object_get_string(json_obj)); // Perse apps HMI_DEBUG("wm", "Perse apps"); json_object* json_cfg; if (!json_object_object_get_ex(json_obj, "apps", &json_cfg)) { HMI_ERROR("wm", "Parse Error!!"); return -1; } int len = json_object_array_length(json_cfg); HMI_DEBUG("wm", "json_cfg len:%d", len); HMI_DEBUG("wm", "json_cfg dump:%s", json_object_get_string(json_cfg)); for (int i=0; i json_tmp dump:%s", json_object_get_string(json_tmp)); const char* app = jh::getStringFromJson(json_tmp, "name"); if (nullptr == app) { HMI_ERROR("wm", "Parse Error!!"); return -1; } HMI_DEBUG("wm", "> app:%s", app); const char* role = jh::getStringFromJson(json_tmp, "role"); if (nullptr == role) { HMI_ERROR("wm", "Parse Error!!"); return -1; } HMI_DEBUG("wm", "> role:%s", role); this->app2role_[app] = std::string(role); } // Check for(auto itr = this->app2role_.begin(); itr != this->app2role_.end(); ++itr) { HMI_DEBUG("wm", "app:%s role:%s", itr->first.c_str(), itr->second.c_str()); } // Release json_object json_object_put(json_obj); return 0; } const char* kDefaultAppDb = "{ \ \"apps\": [ \ { \ \"name\": \"HomeScreen\", \ \"role\": \"homescreen\" \ }, \ { \ \"name\": \"Music\", \ \"role\": \"music\" \ }, \ { \ \"name\": \"MediaPlayer\", \ \"role\": \"music\" \ }, \ { \ \"name\": \"Video\", \ \"role\": \"video\" \ }, \ { \ \"name\": \"VideoPlayer\", \ \"role\": \"video\" \ }, \ { \ \"name\": \"WebBrowser\", \ \"role\": \"browser\" \ }, \ { \ \"name\": \"Radio\", \ \"role\": \"radio\" \ }, \ { \ \"name\": \"Phone\", \ \"role\": \"phone\" \ }, \ { \ \"name\": \"Navigation\", \ \"role\": \"map\" \ }, \ { \ \"name\": \"HVAC\", \ \"role\": \"hvac\" \ }, \ { \ \"name\": \"Settings\", \ \"role\": \"settings\" \ }, \ { \ \"name\": \"Dashboard\", \ \"role\": \"dashboard\" \ }, \ { \ \"name\": \"POI\", \ \"role\": \"poi\" \ }, \ { \ \"name\": \"Mixer\", \ \"role\": \"mixer\" \ } \ ] \ }"; } // namespace wm