src/app.cpp

   1 /*
   2  * Copyright (c) 2017 TOYOTA MOTOR CORPORATION
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 #include "app.hpp"
  18 #include "json_helper.hpp"
  19 #include "layers.hpp"
  20 #include "layout.hpp"
  21 #include "util.hpp"
  22 #include "wayland_ivi_wm.hpp"
  23
  24 #include <cstdio>
  25 #include <memory>
  26
  27 #include <cassert>
  28
  29 #include <json-c/json.h>
  30
  31 #include <algorithm>
  32 #include <csignal>
  33 #include <fstream>
  34 #include <json.hpp>
  35 #include <regex>
  36 #include <thread>
  37
  38 #include "wm-client.hpp"
  39 #include "applist.hpp"
  40
  41 extern "C"
  42 {
  43 #include <systemd/sd-event.h>
  44 }
  45
  46 namespace wm
  47 {
  48
  49 const unsigned TIME_OUT = 10000000UL; /* 10s */
  50
  51 /* DrawingArea name used by "{layout}.{area}" */
  52 const char kNameLayoutNormal[] = "normal";
  53 const char kNameLayoutSplit[] = "split";
  54 const char kNameAreaFull[] = "full";
  55 const char kNameAreaMain[] = "main";
  56 const char kNameAreaSub[] = "sub";
  57
  58 /* Key for json obejct */
  59 const char kKeyDrawingName[] = "drawing_name";
  60 const char kKeyDrawingArea[] = "drawing_area";
  61 const char kKeyDrawingRect[] = "drawing_rect";
  62 const char kKeyX[] = "x";
  63 const char kKeyY[] = "y";
  64 const char kKeyWidth[] = "width";
  65 const char kKeyHeight[] = "height";
  66 const char kKeyWidthPixel[] = "width_pixel";
  67 const char kKeyHeightPixel[] = "height_pixel";
  68 const char kKeyWidthMm[] = "width_mm";
  69 const char kKeyHeightMm[] = "height_mm";
  70
  71 static const std::string task_allocate = "allocate";
  72 static const std::string task_release = "release";
  73 static sd_event_source *timer_ev_src = nullptr;
  74
  75 static AppList app_list;
  76
  77 namespace
  78 {
  79
  80 using nlohmann::json;
  81
  82 result<json> file_to_json(char const *filename)
  83 {
  84     json j;
  85     std::ifstream i(filename);
  86     if (i.fail())
  87     {
  88         HMI_DEBUG("wm", "Could not open config file, so use default layer information");
  89         j = default_layers_json;
  90     }
  91     else
  92     {
  93         i >> j;
  94     }
  95
  96     return Ok(j);
  97 }
  98
  99 struct result<layer_map> load_layer_map(char const *filename)
 100 {
 101     HMI_DEBUG("wm", "loading IDs from %s", filename);
 102
 103     auto j = file_to_json(filename);
 104     if (j.is_err())
 105     {
 106         return Err<layer_map>(j.unwrap_err());
 107     }
 108     json jids = j.unwrap();
 109
 110     return to_layer_map(jids);
 111 }
 112
 113 static int
 114 processTimerHandler(sd_event_source *s, uint64_t usec, void *userdata)
 115 {
 116     HMI_NOTICE("wm", "Time out occurs because the client replys endDraw slow, so revert the request");
 117     reinterpret_cast<wm::App *>(userdata)->timerHandler();
 118     return 0;
 119 }
 120
 121 } // namespace
 122
 123 void App::timerHandler()
 124 {
 125     unsigned seq = app_list.currentSequenceNumber();
 126     HMI_SEQ_DEBUG(seq, "Timer expired remove Request");
 127     app_list.req_dump();
 128     app_list.removeRequest(seq);
 129     app_list.next();
 130     app_list.req_dump();
 131     if (app_list.haveRequest())
 132     {
 133         this->process_request();
 134     }
 135 }
 136
 137 void App::removeClient(const std::string &appid)
 138 {
 139     HMI_DEBUG("wm", "Remove clinet %s from list", appid.c_str());
 140     app_list.removeClient(appid);
 141 }
 142
 143 bool App::subscribeEventForApp(const std::string &appid, afb_req req, const std::string &evname)
 144 {
 145     if(!app_list.contains(appid)){
 146         HMI_DEBUG("wm", "Client %s is not registered", appid.c_str());
 147         return false;
 148     }
 149     auto client = app_list.lookUpClient(appid);
 150     return client->subscribe(req, evname);
 151 }
 152
 153 /**
 154  * App Impl
 155  */
 156 App::App(wl::display *d)
 157     : chooks{this},
 158       display{d},
 159       controller{},
 160       outputs(),
 161       config(),
 162       layers(),
 163       id_alloc{},
 164       pending_events(false),
 165       policy{}
 166 {
 167     try
 168     {
 169         {
 170             auto l = load_layer_map(
 171                 this->config.get_string("layers.json").value().c_str());
 172             if (l.is_ok())
 173             {
 174                 this->layers = l.unwrap();
 175             }
 176             else
 177             {
 178                 HMI_ERROR("wm", "%s", l.err().value());
 179             }
 180         }
 181     }
 182     catch (std::exception &e)
 183     {
 184         HMI_ERROR("wm", "Loading of configuration failed: %s", e.what());
 185     }
 186 }
 187
 188 int App::init()
 189 {
 190     if (!this->display->ok())
 191     {
 192         return -1;
 193     }
 194
 195     if (this->layers.mapping.empty())
 196     {
 197         HMI_ERROR("wm", "No surface -> layer mapping loaded");
 198         return -1;
 199     }
 200
 201     // Make afb event
 202     for (int i = Event_Val_Min; i <= Event_Val_Max; i++)
 203     {
 204         map_afb_event[kListEventName[i]] = afb_daemon_make_event(kListEventName[i]);
 205     }
 206
 207     this->display->add_global_handler(
 208         "wl_output", [this](wl_registry *r, uint32_t name, uint32_t v) {
 209             this->outputs.emplace_back(std::make_unique<wl::output>(r, name, v));
 210         });
 211
 212     this->display->add_global_handler(
 213         "ivi_wm", [this](wl_registry *r, uint32_t name, uint32_t v) {
 214             this->controller =
 215                 std::make_unique<struct compositor::controller>(r, name, v);
 216
 217             // Init controller hooks
 218             this->controller->chooks = &this->chooks;
 219
 220             // This protocol needs the output, so lets just add our mapping here...
 221             this->controller->add_proxy_to_id_mapping(
 222                 this->outputs.back()->proxy.get(),
 223                 wl_proxy_get_id(reinterpret_cast<struct wl_proxy *>(
 224                     this->outputs.back()->proxy.get())));
 225
 226             // Create screen
 227             this->controller->create_screen(this->outputs.back()->proxy.get());
 228
 229             // Set display to controller
 230             this->controller->display = this->display;
 231         });
 232
 233     // First level objects
 234     this->display->roundtrip();
 235     // Second level objects
 236     this->display->roundtrip();
 237     // Third level objects
 238     this->display->roundtrip();
 239
 240     return init_layers();
 241 }
 242
 243 int App::dispatch_pending_events()
 244 {
 245     if (this->pop_pending_events())
 246     {
 247         this->display->dispatch_pending();
 248         return 0;
 249     }
 250     return -1;
 251 }
 252
 253 bool App::pop_pending_events()
 254 {
 255     bool x{true};
 256     return this->pending_events.compare_exchange_strong(
 257         x, false, std::memory_order_consume);
 258 }
 259
 260 void App::set_pending_events()
 261 {
 262     this->pending_events.store(true, std::memory_order_release);
 263 }
 264
 265 optional<int> App::lookup_id(char const *name)
 266 {
 267     return this->id_alloc.lookup(std::string(name));
 268 }
 269 optional<std::string> App::lookup_name(int id)
 270 {
 271     return this->id_alloc.lookup(id);
 272 }
 273
 274 /**
 275  * init_layers()
 276  */
 277 int App::init_layers()
 278 {
 279     if (!this->controller)
 280     {
 281         HMI_ERROR("wm", "ivi_controller global not available");
 282         return -1;
 283     }
 284
 285     if (this->outputs.empty())
 286     {
 287         HMI_ERROR("wm", "no output was set up!");
 288         return -1;
 289     }
 290
 291     auto &c = this->controller;
 292
 293     auto &o = this->outputs.front();
 294     auto &s = c->screens.begin()->second;
 295     auto &layers = c->layers;
 296
 297     // Write output dimensions to ivi controller...
 298     c->output_size = compositor::size{uint32_t(o->width), uint32_t(o->height)};
 299     c->physical_size = compositor::size{uint32_t(o->physical_width),
 300                                         uint32_t(o->physical_height)};
 301
 302     // Clear scene
 303     layers.clear();
 304
 305     // Clear screen
 306     s->clear();
 307
 308     // Quick and dirty setup of layers
 309     for (auto const &i : this->layers.mapping)
 310     {
 311         c->layer_create(i.second.layer_id, o->width, o->height);
 312         auto &l = layers[i.second.layer_id];
 313         l->set_destination_rectangle(0, 0, o->width, o->height);
 314         l->set_visibility(1);
 315         HMI_DEBUG("wm", "Setting up layer %s (%d) for surface role match \"%s\"",
 316                   i.second.name.c_str(), i.second.layer_id, i.second.role.c_str());
 317     }
 318
 319     // Add layers to screen
 320     s->set_render_order(this->layers.layers);
 321
 322     this->layout_commit();
 323
 324     return 0;
 325 }
 326
 327 void App::surface_set_layout(int surface_id, optional<int> sub_surface_id)
 328 {
 329     if (!this->controller->surface_exists(surface_id))
 330     {
 331         HMI_ERROR("wm", "Surface %d does not exist", surface_id);
 332         return;
 333     }
 334
 335     auto o_layer_id = this->layers.get_layer_id(surface_id);
 336
 337     if (!o_layer_id)
 338     {
 339         HMI_ERROR("wm", "Surface %d is not associated with any layer!", surface_id);
 340         return;
 341     }
 342
 343     uint32_t layer_id = *o_layer_id;
 344
 345     auto const &layer = this->layers.get_layer(layer_id);
 346     auto rect = layer.value().rect;
 347     auto &s = this->controller->surfaces[surface_id];
 348
 349     int x = rect.x;
 350     int y = rect.y;
 351     int w = rect.w;
 352     int h = rect.h;
 353
 354     // less-than-0 values refer to MAX + 1 - $VALUE
 355     // e.g. MAX is either screen width or height
 356     if (w < 0)
 357     {
 358         w = this->controller->output_size.w + 1 + w;
 359     }
 360     if (h < 0)
 361     {
 362         h = this->controller->output_size.h + 1 + h;
 363     }
 364
 365     if (sub_surface_id)
 366     {
 367         if (o_layer_id != this->layers.get_layer_id(*sub_surface_id))
 368         {
 369             HMI_ERROR("wm",
 370                       "surface_set_layout: layers of surfaces (%d and %d) don't match!",
 371                       surface_id, *sub_surface_id);
 372             return;
 373         }
 374
 375         int x_off = 0;
 376         int y_off = 0;
 377
 378         // split along major axis
 379         if (w > h)
 380         {
 381             w /= 2;
 382             x_off = w;
 383         }
 384         else
 385         {
 386             h /= 2;
 387             y_off = h;
 388         }
 389
 390         auto &ss = this->controller->surfaces[*sub_surface_id];
 391
 392         HMI_DEBUG("wm", "surface_set_layout for sub surface %u on layer %u",
 393                   *sub_surface_id, layer_id);
 394
 395         // set destination to the display rectangle
 396         ss->set_destination_rectangle(x + x_off, y + y_off, w, h);
 397
 398         this->area_info[*sub_surface_id].x = x;
 399         this->area_info[*sub_surface_id].y = y;
 400         this->area_info[*sub_surface_id].w = w;
 401         this->area_info[*sub_surface_id].h = h;
 402     }
 403
 404     HMI_DEBUG("wm", "surface_set_layout for surface %u on layer %u", surface_id,
 405               layer_id);
 406
 407     // set destination to the display rectangle
 408     s->set_destination_rectangle(x, y, w, h);
 409
 410     // update area information
 411     this->area_info[surface_id].x = x;
 412     this->area_info[surface_id].y = y;
 413     this->area_info[surface_id].w = w;
 414     this->area_info[surface_id].h = h;
 415
 416     HMI_DEBUG("wm", "Surface %u now on layer %u with rect { %d, %d, %d, %d }",
 417               surface_id, layer_id, x, y, w, h);
 418 }
 419
 420 void App::layout_commit()
 421 {
 422     this->controller->commit_changes();
 423     this->display->flush();
 424 }
 425
 426 void App::set_timer()
 427 {
 428     HMI_SEQ_DEBUG(app_list.currentSequenceNumber(), "Timer set activate");
 429     if (timer_ev_src == nullptr)
 430     {
 431         // firsttime set into sd_event
 432         int ret = sd_event_add_time(afb_daemon_get_event_loop(), &timer_ev_src,
 433                                     CLOCK_REALTIME, time(NULL) * (1000000UL) + TIME_OUT, 1, processTimerHandler, this);
 434         if (ret < 0)
 435         {
 436             HMI_ERROR("wm", "Could't set timer");
 437         }
 438     }
 439     else
 440     {
 441         // update timer limitation after second time
 442         sd_event_source_set_time(timer_ev_src, time(NULL) * (1000000UL) + TIME_OUT);
 443         sd_event_source_set_enabled(timer_ev_src, SD_EVENT_ONESHOT);
 444     }
 445 }
 446
 447 void App::stop_timer()
 448 {
 449     unsigned seq = app_list.currentSequenceNumber();
 450     HMI_SEQ_DEBUG(seq, "Timer stop");
 451     int rc = sd_event_source_set_enabled(timer_ev_src, SD_EVENT_OFF);
 452     if (rc < 0)
 453     {
 454         HMI_SEQ_ERROR(seq, "Timer stop failed");
 455     }
 456 }
 457
 458 bool App::lm_release(const struct WMAction &action)
 459 {
 460     //auto const &surface_id = this->lookup_id(drawing_name);
 461     unsigned req_num = app_list.currentSequenceNumber();
 462     auto const &surface_id = this->lookup_id(action.role.c_str());
 463     if (!surface_id)
 464     {
 465         HMI_SEQ_ERROR(req_num, "Surface does not exist");
 466         return false;
 467     }
 468
 469     if (*surface_id == this->layers.main_surface)
 470     {
 471         HMI_SEQ_ERROR(req_num, "Cannot deactivate main_surface");
 472         return false;
 473     }
 474
 475     auto o_state = *this->layers.get_layout_state(*surface_id);
 476
 477     if (o_state == nullptr)
 478     {
 479         HMI_SEQ_ERROR(req_num, "Could not find layer for surface");
 480         return false;
 481     }
 482
 483     struct LayoutState &state = *o_state;
 484
 485     if (state.main == -1)
 486     {
 487         HMI_SEQ_ERROR(req_num, "No surface active");
 488         return false;
 489     }
 490
 491     // Check against main_surface, main_surface_name is the configuration item.
 492     if (*surface_id == this->layers.main_surface)
 493     {
 494         HMI_SEQ_DEBUG(req_num, "Refusing to deactivate main_surface %d", *surface_id);
 495         //reply(nullptr);
 496         return true;
 497     }
 498     if ((state.main == *surface_id) && (state.sub == *surface_id))
 499     {
 500         HMI_SEQ_ERROR(req_num, "Surface is not active");
 501         return false;
 502     }
 503
 504     if (state.main == *surface_id)
 505     {
 506         if (state.sub != -1)
 507         {
 508             this->try_layout(
 509                 state, LayoutState{state.sub, -1}, [&](LayoutState const &nl) {
 510                     std::string sub = std::move(*this->lookup_name(state.sub));
 511
 512                     this->deactivate(*surface_id);
 513                     this->surface_set_layout(state.sub);
 514                     state = nl;
 515
 516                     this->layout_commit();
 517                     std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
 518                     compositor::rect area_rect = this->area_info[state.sub];
 519                     this->emit_syncdraw(sub.c_str(), str_area.c_str(),
 520                                         area_rect.x, area_rect.y, area_rect.w, area_rect.h);
 521                     this->enqueue_flushdraw(state.sub);
 522                 });
 523         }
 524         else
 525         {
 526             this->try_layout(state, LayoutState{-1, -1}, [&](LayoutState const &nl) {
 527                 this->deactivate(*surface_id);
 528                 state = nl;
 529                 this->layout_commit();
 530             });
 531         }
 532     }
 533     else if (state.sub == *surface_id)
 534     {
 535         this->try_layout(
 536             state, LayoutState{state.main, -1}, [&](LayoutState const &nl) {
 537                 std::string main = std::move(*this->lookup_name(state.main));
 538
 539                 this->deactivate(*surface_id);
 540                 this->surface_set_layout(state.main);
 541                 state = nl;
 542
 543                 this->layout_commit();
 544                 std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
 545                 compositor::rect area_rect = this->area_info[state.main];
 546                 this->emit_syncdraw(main.c_str(), str_area.c_str(),
 547                                     area_rect.x, area_rect.y, area_rect.w, area_rect.h);
 548                 this->enqueue_flushdraw(state.main);
 549             });
 550     }
 551     return true;
 552 }
 553
 554 bool App::lm_layout_change(const struct WMAction &action)
 555 {
 556     const char *msg = this->check_surface_exist(action.role.c_str());
 557
 558     /*
 559     lm_.updateLayout(action);
 560     TODO: emit syncDraw with application*/
 561     if (msg)
 562     {
 563         HMI_SEQ_DEBUG(app_list.currentSequenceNumber(), msg);
 564         //app_list.removeRequest(req_num);
 565         return false;
 566     }
 567     this->lm_layout_change(action.role.c_str());
 568     return true;
 569 }
 570
 571 bool App::do_transition(unsigned req_num)
 572 {
 573     /*
 574     * Check Policy
 575     */
 576     // get current trigger
 577     auto trigger = app_list.getRequest(req_num);
 578     bool is_activate = true;
 579
 580     /*  get new status from Policy Manager
 581
 582     (json_object*?) newLayout = checkPolicy(trigger);
 583     (vector<struct WMAction>&) auto actions = translator.inputActionFromLayout(newLayout, currentLayout)
 584     for(const auto& x : actions){
 585         app_list.setAciton(req_num, x)
 586     }
 587
 588     or
 589
 590     translator.inputActionFromLayout(newLayout, currentLayout, &app_list, req_num);
 591
 592     /* The following error check is not necessary because main.cpp will reject the message form not registered object
 593    } */
 594     HMI_SEQ_NOTICE(req_num, "ATM, Policy manager does't exist, then set WMAction as is");
 595
 596     if (TASK_RELEASE == trigger.task)
 597     {
 598         is_activate = false;
 599     }
 600     bool ret = app_list.setAction(req_num, trigger.appid, trigger.role, trigger.area, is_activate);
 601     app_list.req_dump();
 602
 603     if (!ret)
 604     {
 605         HMI_SEQ_ERROR(req_num, "Failed to set action");
 606         return ret;
 607     }
 608
 609     // layer manager task
 610     bool sync_draw_happen = false;
 611     for (const auto &y : app_list.getActions(req_num))
 612     {
 613         /*
 614         do_task(y);
 615         */
 616         /*  TODO
 617            but current we can't do do_task,
 618            so divide the processing into lm_layout_change and lm_release
 619         */
 620         if (y.visible)
 621         {
 622             sync_draw_happen = true;
 623             ret = lm_layout_change(y);
 624             if (!ret)
 625             {
 626                 HMI_SEQ_ERROR(req_num, "Failed layout change: %s", y.appid.c_str());
 627                 app_list.removeRequest(req_num);
 628                 break;
 629                 // TODO: if transition fails, what should we do?
 630             }
 631             /* app_list.lookUpClient(y.appid)->emit_syncdraw(y.role, y.area); */
 632         }
 633         else
 634         {
 635             ret = lm_release(y);
 636             if (!ret)
 637             {
 638                 HMI_SEQ_ERROR(req_num, "Failed release resource: %s", y.appid.c_str());
 639                 app_list.removeRequest(req_num);
 640                 break;
 641                 // TODO: if transition fails, what should we do?
 642             }
 643             /* app_list.lookUpClient(y.appid)->emit_invisible(y.role, y.area); */
 644         }
 645     }
 646
 647     if (!ret)
 648     {
 649         //this->emit_error(request_seq, 0 /*error_num*/, "error happens"); // test
 650     }
 651     else if (ret && sync_draw_happen)
 652     {
 653         this->set_timer();
 654     }
 655     else
 656     {
 657         app_list.removeRequest(req_num); // HACK!!!
 658     }
 659     return ret;
 660 }
 661
 662 void App::lm_layout_change(const char *drawing_name)
 663 {
 664     auto const &surface_id = this->lookup_id(drawing_name);
 665     auto layer_id = this->layers.get_layer_id(*surface_id);
 666     auto o_state = *this->layers.get_layout_state(*surface_id);
 667     struct LayoutState &state = *o_state;
 668
 669     // disable layers that are above our current layer
 670     for (auto const &l : this->layers.mapping)
 671     {
 672         if (l.second.layer_id <= *layer_id)
 673         {
 674             continue;
 675         }
 676
 677         bool flush = false;
 678         if (l.second.state.main != -1)
 679         {
 680             this->deactivate(l.second.state.main);
 681             l.second.state.main = -1;
 682             flush = true;
 683         }
 684
 685         if (l.second.state.sub != -1)
 686         {
 687             this->deactivate(l.second.state.sub);
 688             l.second.state.sub = -1;
 689             flush = true;
 690         }
 691
 692         if (flush)
 693         {
 694             this->layout_commit();
 695         }
 696     }
 697
 698     auto layer = this->layers.get_layer(*layer_id);
 699
 700     if (state.main == -1)
 701     {
 702         this->try_layout(
 703             state, LayoutState{*surface_id}, [&](LayoutState const &nl) {
 704                 HMI_DEBUG("wm", "Layout: %s", kNameLayoutNormal);
 705                 this->surface_set_layout(*surface_id);
 706                 state = nl;
 707
 708                 // Commit for configuraton
 709                 this->layout_commit();
 710
 711                 std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
 712                 compositor::rect area_rect = this->area_info[*surface_id];
 713                 this->emit_syncdraw(drawing_name, str_area.c_str(),
 714                                     area_rect.x, area_rect.y, area_rect.w, area_rect.h);
 715                 this->enqueue_flushdraw(state.main);
 716             });
 717     }
 718     else
 719     {
 720         if (0 == strcmp(drawing_name, "HomeScreen"))
 721         {
 722             this->try_layout(
 723                 state, LayoutState{*surface_id}, [&](LayoutState const &nl) {
 724                     HMI_DEBUG("wm", "Layout: %s", kNameLayoutNormal);
 725                     std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
 726                     compositor::rect area_rect = this->area_info[*surface_id];
 727                     this->emit_syncdraw(drawing_name, str_area.c_str(),
 728                                         area_rect.x, area_rect.y, area_rect.w, area_rect.h);
 729                     this->enqueue_flushdraw(state.main);
 730                 });
 731         }
 732         else
 733         {
 734             bool can_split = this->can_split(state, *surface_id);
 735
 736             if (can_split)
 737             {
 738                 this->try_layout(
 739                     state,
 740                     LayoutState{state.main, *surface_id},
 741                     [&](LayoutState const &nl) {
 742                         HMI_DEBUG("wm", "Layout: %s", kNameLayoutSplit);
 743                         std::string main =
 744                             std::move(*this->lookup_name(state.main));
 745
 746                         this->surface_set_layout(state.main, surface_id);
 747                         if (state.sub != *surface_id)
 748                         {
 749                             if (state.sub != -1)
 750                             {
 751                                 this->deactivate(state.sub);
 752                             }
 753                         }
 754                         state = nl;
 755
 756                         // Commit for configuration and visibility(0)
 757                         this->layout_commit();
 758
 759                         std::string str_area_main = std::string(kNameLayoutSplit) + "." + std::string(kNameAreaMain);
 760                         std::string str_area_sub = std::string(kNameLayoutSplit) + "." + std::string(kNameAreaSub);
 761                         compositor::rect area_rect_main = this->area_info[state.main];
 762                         compositor::rect area_rect_sub = this->area_info[*surface_id];
 763                         this->emit_syncdraw(main.c_str(), str_area_main.c_str(),
 764                                             area_rect_main.x, area_rect_main.y,
 765                                             area_rect_main.w, area_rect_main.h);
 766                         this->emit_syncdraw(drawing_name, str_area_sub.c_str(),
 767                                             area_rect_sub.x, area_rect_sub.y,
 768                                             area_rect_sub.w, area_rect_sub.h);
 769                         this->enqueue_flushdraw(state.main);
 770                         this->enqueue_flushdraw(state.sub);
 771                     });
 772             }
 773             else
 774             {
 775                 this->try_layout(
 776                     state, LayoutState{*surface_id}, [&](LayoutState const &nl) {
 777                         HMI_DEBUG("wm", "Layout: %s", kNameLayoutNormal);
 778
 779                         this->surface_set_layout(*surface_id);
 780                         if (state.main != *surface_id)
 781                         {
 782                             this->deactivate(state.main);
 783                         }
 784                         if (state.sub != -1)
 785                         {
 786                             if (state.sub != *surface_id)
 787                             {
 788                                 this->deactivate(state.sub);
 789                             }
 790                         }
 791                         state = nl;
 792
 793                         // Commit for configuraton and visibility(0)
 794                         this->layout_commit();
 795
 796                         std::string str_area = std::string(kNameLayoutNormal) + "." + std::string(kNameAreaFull);
 797                         compositor::rect area_rect = this->area_info[*surface_id];
 798                         this->emit_syncdraw(drawing_name, str_area.c_str(),
 799                                             area_rect.x, area_rect.y, area_rect.w, area_rect.h);
 800                         this->enqueue_flushdraw(state.main);
 801                     });
 802             }
 803         }
 804     }
 805 }
 806
 807 const char *App::check_surface_exist(const char *drawing_name)
 808 {
 809     auto const &surface_id = this->lookup_id(drawing_name);
 810     if (!surface_id)
 811     {
 812         //reply("Surface does not exist");
 813         return "Surface does not exist";
 814     }
 815
 816     if (!this->controller->surface_exists(*surface_id))
 817     {
 818         //reply("Surface does not exist in controller!");
 819         return "Surface does not exist in controller!";
 820     }
 821
 822     auto layer_id = this->layers.get_layer_id(*surface_id);
 823
 824     if (!layer_id)
 825     {
 826         //reply("Surface is not on any layer!");
 827         return "Surface is not on any layer!";
 828     }
 829
 830     auto o_state = *this->layers.get_layout_state(*surface_id);
 831
 832     if (o_state == nullptr)
 833     {
 834         //reply("Could not find layer for surface");
 835         return "Could not find layer for surface";
 836     }
 837
 838     HMI_DEBUG("wm", "surface %d is detected", *surface_id);
 839     return nullptr;
 840     //reply(nullptr);
 841 }
 842
 843 void App::api_activate_surface(char const *appid, char const *drawing_name, char const *drawing_area, const reply_func &reply)
 844 {
 845     ST();
 846
 847     /*
 848    * Check Phase
 849    */
 850
 851     std::string id = appid;
 852     std::string role = drawing_name;
 853     std::string area = drawing_area;
 854
 855     if (!app_list.contains(id))
 856     {
 857         reply("app doesn't request 'requestSurface' yet");
 858         return;
 859     }
 860
 861     auto client = app_list.lookUpClient(id);
 862
 863     // test
 864     HMI_DEBUG("wm", "test");
 865     client->emitError(WM_CLIENT_ERROR_EVENT::UNKNOWN_ERROR);
 866
 867     /*
 868    * Queueing Phase
 869    */
 870     unsigned current = app_list.currentSequenceNumber();
 871     unsigned requested_num = app_list.getSequenceNumber(id);
 872     if (requested_num != 0)
 873     {
 874         HMI_SEQ_INFO(requested_num, "%s %s %s request is already queued", id.c_str(), role.c_str(), area.c_str());
 875         reply("already requested");
 876         return;
 877     }
 878
 879     WMRequest req = WMRequest(id, role, area, Task::TASK_ALLOCATE);
 880     unsigned new_req = app_list.addAllocateRequest(req);
 881     app_list.req_dump();
 882
 883     HMI_SEQ_DEBUG(current, "%s start sequence with %s, %s", id.c_str(), role.c_str(), area.c_str());
 884
 885     reply(nullptr);
 886     if (new_req != current)
 887     {
 888         // Add request, then invoked after the previous task is finished
 889         HMI_SEQ_DEBUG(new_req, "request is accepted");
 890         return;
 891     }
 892
 893     /*
 894     * Do allocate tasks
 895     */
 896     bool ret = this->do_transition(new_req);
 897
 898     if (!ret)
 899     {
 900         HMI_SEQ_ERROR(new_req, "failed to do_transition");
 901         //this->emit_error()
 902     }
 903 }
 904
 905 void App::api_deactivate_surface(char const *appid, char const *drawing_name, const reply_func &reply)
 906 {
 907     ST();
 908
 909     /*
 910    * Check Phase
 911    */
 912     std::string id = appid;
 913     std::string role = drawing_name;
 914     std::string area = ""; //drawing_area;
 915
 916     if (!app_list.contains(id))
 917     {
 918         reply("app doesn't request 'requestSurface' yet");
 919         return;
 920     }
 921     auto client = app_list.lookUpClient(id);
 922
 923     /*
 924    * Queueing Phase
 925    */
 926     unsigned current = app_list.currentSequenceNumber();
 927     unsigned requested_num = app_list.getSequenceNumber(id);
 928     if (requested_num != 0)
 929     {
 930         HMI_SEQ_INFO(requested_num, "%s %s %s request is already queued", id.c_str(), role.c_str(), area.c_str());
 931         reply("already requested");
 932         return;
 933     }
 934
 935     WMRequest req = WMRequest(id, role, area, Task::TASK_RELEASE);
 936     unsigned new_req = app_list.addAllocateRequest(req);
 937     app_list.req_dump();
 938
 939     HMI_SEQ_DEBUG(current, "%s start sequence with %s, %s", id.c_str(), role.c_str(), area.c_str());
 940
 941     reply(nullptr);
 942     if (new_req != current)
 943     {
 944         // Add request, then invoked after the previous task is finished
 945         HMI_SEQ_DEBUG(new_req, "request is accepted");
 946         return;
 947     }
 948
 949     /*
 950     * Do allocate tasks
 951     */
 952     bool ret = this->do_transition(new_req);
 953
 954     if (!ret)
 955     {
 956         HMI_SEQ_ERROR(new_req, "failed to do_transition");
 957         //this->emit_error()
 958     }
 959 }
 960
 961 void App::enqueue_flushdraw(int surface_id)
 962 {
 963     this->check_flushdraw(surface_id);
 964     HMI_DEBUG("wm", "Enqueuing EndDraw for surface_id %d", surface_id);
 965     this->pending_end_draw.push_back(surface_id);
 966 }
 967
 968 void App::check_flushdraw(int surface_id)
 969 {
 970     auto i = std::find(std::begin(this->pending_end_draw),
 971                        std::end(this->pending_end_draw), surface_id);
 972     if (i != std::end(this->pending_end_draw))
 973     {
 974         auto n = this->lookup_name(surface_id);
 975         HMI_ERROR("wm", "Application %s (%d) has pending EndDraw call(s)!",
 976                   n ? n->c_str() : "unknown-name", surface_id);
 977         std::swap(this->pending_end_draw[std::distance(
 978                       std::begin(this->pending_end_draw), i)],
 979                   this->pending_end_draw.back());
 980         this->pending_end_draw.resize(this->pending_end_draw.size() - 1);
 981     }
 982 }
 983
 984 void App::lm_enddraw(const char *drawing_name)
 985 {
 986     HMI_DEBUG("wm", "end draw %s", drawing_name);
 987     for (unsigned i = 0, iend = this->pending_end_draw.size(); i < iend; i++)
 988     {
 989         auto n = this->lookup_name(this->pending_end_draw[i]);
 990         if (n && *n == drawing_name)
 991         {
 992             std::swap(this->pending_end_draw[i], this->pending_end_draw[iend - 1]);
 993             this->pending_end_draw.resize(iend - 1);
 994             this->activate(this->pending_end_draw[i]);
 995             this->emit_flushdraw(drawing_name);
 996         }
 997     }
 998 }
 999
1000 void App::do_enddraw(unsigned request_seq)
1001 {
1002     // get actions
1003     auto actions = app_list.getActions(request_seq);
1004     HMI_SEQ_INFO(request_seq, "do endDraw");
1005
1006     for (const auto &act : actions)
1007     {
1008         HMI_SEQ_DEBUG(request_seq, "visible %s", act.role.c_str());
1009         this->lm_enddraw(act.role.c_str());
1010     }
1011
1012     HMI_SEQ_INFO(request_seq, "emit flushDraw");
1013     /*     do
1014     {
1015         // emit flush Draw
1016         //emitFlushDrawToAll(&app_list, request_seq);
1017         // emit status change event
1018     } while (!app_list.requestFinished());*/
1019 }
1020
1021 void App::process_request()
1022 {
1023     unsigned req = app_list.currentSequenceNumber();
1024     HMI_SEQ_DEBUG(req, "Do next request");
1025     do_transition(req);
1026 }
1027
1028 void App::api_enddraw(char const *appid, char const *drawing_name)
1029 {
1030     std::string id(appid);
1031     std::string role(drawing_name);
1032     unsigned current_seq = app_list.currentSequenceNumber();
1033     bool result = app_list.setEndDrawFinished(current_seq, id, role);
1034
1035     if (!result)
1036     {
1037         HMI_ERROR("wm", "%s doesn't have Window Resource", id.c_str());
1038         return;
1039     }
1040
1041     if (app_list.endDrawFullfilled(current_seq))
1042     {
1043         // do task for endDraw
1044         //this->stop_timer();
1045         this->do_enddraw(current_seq);
1046
1047         this->stop_timer();
1048
1049         app_list.removeRequest(current_seq);
1050         HMI_SEQ_INFO(current_seq, "Finish request");
1051         app_list.next();
1052         if (app_list.haveRequest())
1053         {
1054             this->process_request();
1055         }
1056     }
1057     else
1058     {
1059         HMI_SEQ_INFO(current_seq, "Wait other App call endDraw");
1060         return;
1061     }
1062 }
1063
1064 void App::api_ping() { this->dispatch_pending_events(); }
1065
1066 void App::send_event(char const *evname, char const *label)
1067 {
1068     HMI_DEBUG("wm", "%s: %s(%s)", __func__, evname, label);
1069
1070     json_object *j = json_object_new_object();
1071     json_object_object_add(j, kKeyDrawingName, json_object_new_string(label));
1072
1073     int ret = afb_event_push(this->map_afb_event[evname], j);
1074     if (ret != 0)
1075     {
1076         HMI_DEBUG("wm", "afb_event_push failed: %m");
1077     }
1078 }
1079
1080 void App::send_event(char const *evname, char const *label, char const *area,
1081                      int x, int y, int w, int h)
1082 {
1083     HMI_DEBUG("wm", "%s: %s(%s, %s) x:%d y:%d w:%d h:%d",
1084               __func__, evname, label, area, x, y, w, h);
1085
1086     json_object *j_rect = json_object_new_object();
1087     json_object_object_add(j_rect, kKeyX, json_object_new_int(x));
1088     json_object_object_add(j_rect, kKeyY, json_object_new_int(y));
1089     json_object_object_add(j_rect, kKeyWidth, json_object_new_int(w));
1090     json_object_object_add(j_rect, kKeyHeight, json_object_new_int(h));
1091
1092     json_object *j = json_object_new_object();
1093     json_object_object_add(j, kKeyDrawingName, json_object_new_string(label));
1094     json_object_object_add(j, kKeyDrawingArea, json_object_new_string(area));
1095     json_object_object_add(j, kKeyDrawingRect, j_rect);
1096
1097     int ret = afb_event_push(this->map_afb_event[evname], j);
1098     if (ret != 0)
1099     {
1100         HMI_DEBUG("wm", "afb_event_push failed: %m");
1101     }
1102 }
1103
1104 /**
1105  * proxied events
1106  */
1107 void App::surface_created(uint32_t surface_id)
1108 {
1109     auto layer_id = this->layers.get_layer_id(surface_id);
1110     if (!layer_id)
1111     {
1112         HMI_DEBUG("wm", "Newly created surfce %d is not associated with any layer!",
1113                   surface_id);
1114         return;
1115     }
1116
1117     HMI_DEBUG("wm", "surface_id is %u, layer_id is %u", surface_id, *layer_id);
1118
1119     this->controller->layers[*layer_id]->add_surface(surface_id);
1120     this->layout_commit();
1121     // activate the main_surface right away
1122     /*if (surface_id == static_cast<unsigned>(this->layers.main_surface)) {
1123       HMI_DEBUG("wm", "Activating main_surface (%d)", surface_id);
1124
1125       this->api_activate_surface(
1126          this->lookup_name(surface_id).value_or("unknown-name").c_str());
1127    }*/
1128
1129     // search pid from surfaceID
1130
1131     // pick up appid from pid from application manager
1132
1133     // check appid then add it to the client
1134 }
1135
1136 void App::surface_removed(uint32_t surface_id)
1137 {
1138     HMI_DEBUG("wm", "surface_id is %u", surface_id);
1139
1140     app_list.removeSurface(surface_id);
1141 }
1142
1143 void App::emit_activated(char const *label)
1144 {
1145     this->send_event(kListEventName[Event_Active], label);
1146 }
1147
1148 void App::emit_deactivated(char const *label)
1149 {
1150     this->send_event(kListEventName[Event_Inactive], label);
1151 }
1152
1153 void App::emit_syncdraw(char const *label, char const *area, int x, int y, int w, int h)
1154 {
1155     this->send_event(kListEventName[Event_SyncDraw], label, area, x, y, w, h);
1156 }
1157
1158 void App::emit_flushdraw(char const *label)
1159 {
1160     this->send_event(kListEventName[Event_FlushDraw], label);
1161 }
1162
1163 void App::emit_visible(char const *label, bool is_visible)
1164 {
1165     this->send_event(is_visible ? kListEventName[Event_Visible] : kListEventName[Event_Invisible], label);
1166 }
1167
1168 void App::emit_invisible(char const *label)
1169 {
1170     return emit_visible(label, false);
1171 }
1172
1173 void App::emit_visible(char const *label) { return emit_visible(label, true); }
1174
1175 result<int> App::api_request_surface(char const *appid, char const *drawing_name)
1176 {
1177     auto lid = this->layers.get_layer_id(std::string(drawing_name));
1178     if (!lid)
1179     {
1180         /**
1181        * register drawing_name as fallback and make it displayed.
1182        */
1183         lid = this->layers.get_layer_id(std::string("Fallback"));
1184         HMI_DEBUG("wm", "%s is not registered in layers.json, then fallback as normal app", drawing_name);
1185         if (!lid)
1186         {
1187             return Err<int>("Drawing name does not match any role, Fallback is disabled");
1188         }
1189     }
1190
1191     auto rname = this->lookup_id(drawing_name);
1192     if (!rname)
1193     {
1194         // name does not exist yet, allocate surface id...
1195         auto id = int(this->id_alloc.generate_id(drawing_name));
1196         this->layers.add_surface(id, *lid);
1197
1198         // set the main_surface[_name] here and now
1199         if (!this->layers.main_surface_name.empty() &&
1200             this->layers.main_surface_name == drawing_name)
1201         {
1202             this->layers.main_surface = id;
1203             HMI_DEBUG("wm", "Set main_surface id to %u", id);
1204         }
1205
1206         // add client into the db
1207         std::string appid_str(appid);
1208         std::string role(drawing_name);
1209         //app_list.addClient(appid_str, role);
1210         app_list.addClient(appid_str, *lid, id, role);
1211
1212         return Ok<int>(id);
1213     }
1214
1215     // Check currently registered drawing names if it is already there.
1216     return Err<int>("Surface already present");
1217 }
1218
1219 char const *App::api_request_surface(char const *appid, char const *drawing_name,
1220                                      char const *ivi_id)
1221 {
1222     ST();
1223
1224     auto lid = this->layers.get_layer_id(std::string(drawing_name));
1225     unsigned sid = std::stol(ivi_id);
1226
1227     if (!lid)
1228     {
1229         /**
1230        * register drawing_name as fallback and make it displayed.
1231        */
1232         lid = this->layers.get_layer_id(std::string("Fallback"));
1233         HMI_DEBUG("wm", "%s is not registered in layers.json, then fallback as normal app", drawing_name);
1234         if (!lid)
1235         {
1236             return "Drawing name does not match any role, Fallback is disabled";
1237         }
1238     }
1239
1240     auto rname = this->lookup_id(drawing_name);
1241
1242     if (rname)
1243     {
1244         return "Surface already present";
1245     }
1246
1247     // register pair drawing_name and ivi_id
1248     this->id_alloc.register_name_id(drawing_name, sid);
1249     this->layers.add_surface(sid, *lid);
1250
1251     // this surface is already created
1252     HMI_DEBUG("wm", "surface_id is %u, layer_id is %u", sid, *lid);
1253
1254     this->controller->layers[*lid]->add_surface(sid);
1255     this->layout_commit();
1256
1257     return nullptr;
1258 }
1259
1260 result<json_object *> App::api_get_display_info()
1261 {
1262     // Check controller
1263     if (!this->controller)
1264     {
1265         return Err<json_object *>("ivi_controller global not available");
1266     }
1267
1268     // Set display info
1269     compositor::size o_size = this->controller->output_size;
1270     compositor::size p_size = this->controller->physical_size;
1271
1272     json_object *object = json_object_new_object();
1273     json_object_object_add(object, kKeyWidthPixel, json_object_new_int(o_size.w));
1274     json_object_object_add(object, kKeyHeightPixel, json_object_new_int(o_size.h));
1275     json_object_object_add(object, kKeyWidthMm, json_object_new_int(p_size.w));
1276     json_object_object_add(object, kKeyHeightMm, json_object_new_int(p_size.h));
1277
1278     return Ok<json_object *>(object);
1279 }
1280
1281 result<json_object *> App::api_get_area_info(char const *drawing_name)
1282 {
1283     HMI_DEBUG("wm", "called");
1284
1285     // Check drawing name, surface/layer id
1286     auto const &surface_id = this->lookup_id(drawing_name);
1287     if (!surface_id)
1288     {
1289         return Err<json_object *>("Surface does not exist");
1290     }
1291
1292     if (!this->controller->surface_exists(*surface_id))
1293     {
1294         return Err<json_object *>("Surface does not exist in controller!");
1295     }
1296
1297     auto layer_id = this->layers.get_layer_id(*surface_id);
1298     if (!layer_id)
1299     {
1300         return Err<json_object *>("Surface is not on any layer!");
1301     }
1302
1303     auto o_state = *this->layers.get_layout_state(*surface_id);
1304     if (o_state == nullptr)
1305     {
1306         return Err<json_object *>("Could not find layer for surface");
1307     }
1308
1309     struct LayoutState &state = *o_state;
1310     if ((state.main != *surface_id) && (state.sub != *surface_id))
1311     {
1312         return Err<json_object *>("Surface is inactive");
1313     }
1314
1315     // Set area rectangle
1316     compositor::rect area_info = this->area_info[*surface_id];
1317     json_object *object = json_object_new_object();
1318     json_object_object_add(object, kKeyX, json_object_new_int(area_info.x));
1319     json_object_object_add(object, kKeyY, json_object_new_int(area_info.y));
1320     json_object_object_add(object, kKeyWidth, json_object_new_int(area_info.w));
1321     json_object_object_add(object, kKeyHeight, json_object_new_int(area_info.h));
1322
1323     return Ok<json_object *>(object);
1324 }
1325
1326 void App::activate(int id)
1327 {
1328     auto ip = this->controller->sprops.find(id);
1329     if (ip != this->controller->sprops.end())
1330     {
1331         this->controller->surfaces[id]->set_visibility(1);
1332         char const *label =
1333             this->lookup_name(id).value_or("unknown-name").c_str();
1334
1335         // FOR CES DEMO >>>
1336         if ((0 == strcmp(label, "Radio")) || (0 == strcmp(label, "MediaPlayer")) || (0 == strcmp(label, "Music")) || (0 == strcmp(label, "Navigation")))
1337         {
1338             for (auto i = surface_bg.begin(); i != surface_bg.end(); ++i)
1339             {
1340                 if (id == *i)
1341                 {
1342                     // Remove id
1343                     this->surface_bg.erase(i);
1344
1345                     // Remove from BG layer (999)
1346                     HMI_DEBUG("wm", "Remove %s(%d) from BG layer", label, id);
1347                     this->controller->layers[999]->remove_surface(id);
1348
1349                     // Add to FG layer (1001)
1350                     HMI_DEBUG("wm", "Add %s(%d) to FG layer", label, id);
1351                     this->controller->layers[1001]->add_surface(id);
1352
1353                     for (int j : this->surface_bg)
1354                     {
1355                         HMI_DEBUG("wm", "Stored id:%d", j);
1356                     }
1357                     break;
1358                 }
1359             }
1360         }
1361         // <<< FOR CES DEMO
1362         this->layout_commit();
1363
1364         this->emit_visible(label);
1365         this->emit_activated(label);
1366     }
1367 }
1368
1369 void App::deactivate(int id)
1370 {
1371     auto ip = this->controller->sprops.find(id);
1372     if (ip != this->controller->sprops.end())
1373     {
1374         char const *label =
1375             this->lookup_name(id).value_or("unknown-name").c_str();
1376
1377         // FOR CES DEMO >>>
1378         if ((0 == strcmp(label, "Radio")) || (0 == strcmp(label, "MediaPlayer")) || (0 == strcmp(label, "Music")) || (0 == strcmp(label, "Navigation")))
1379         {
1380
1381             // Store id
1382             this->surface_bg.push_back(id);
1383
1384             // Remove from FG layer (1001)
1385             HMI_DEBUG("wm", "Remove %s(%d) from FG layer", label, id);
1386             this->controller->layers[1001]->remove_surface(id);
1387
1388             // Add to BG layer (999)
1389             HMI_DEBUG("wm", "Add %s(%d) to BG layer", label, id);
1390             this->controller->layers[999]->add_surface(id);
1391
1392             for (int j : surface_bg)
1393             {
1394                 HMI_DEBUG("wm", "Stored id:%d", j);
1395             }
1396         }
1397         else
1398         {
1399             this->controller->surfaces[id]->set_visibility(0);
1400         }
1401         // <<< FOR CES DEMO
1402
1403         this->emit_deactivated(label);
1404         this->emit_invisible(label);
1405     }
1406 }
1407
1408 void App::deactivate_main_surface()
1409 {
1410     this->layers.main_surface = -1;
1411     std::string appid = "HomeScreen";
1412     this->api_deactivate_surface(appid.c_str(), this->layers.main_surface_name.c_str(), [](const char *) {});
1413 }
1414
1415 bool App::can_split(struct LayoutState const &state, int new_id)
1416 {
1417     if (state.main != -1 && state.main != new_id)
1418     {
1419         auto new_id_layer = this->layers.get_layer_id(new_id).value();
1420         auto current_id_layer = this->layers.get_layer_id(state.main).value();
1421
1422         // surfaces are on separate layers, don't bother.
1423         if (new_id_layer != current_id_layer)
1424         {
1425             return false;
1426         }
1427
1428         std::string const &new_id_str = this->lookup_name(new_id).value();
1429         std::string const &cur_id_str = this->lookup_name(state.main).value();
1430
1431         auto const &layer = this->layers.get_layer(new_id_layer);
1432
1433         HMI_DEBUG("wm", "layer info name: %s", layer->name.c_str());
1434
1435         if (layer->layouts.empty())
1436         {
1437             return false;
1438         }
1439
1440         for (auto i = layer->layouts.cbegin(); i != layer->layouts.cend(); i++)
1441         {
1442             HMI_DEBUG("wm", "%d main_match '%s'", new_id_layer, i->main_match.c_str());
1443             auto rem = std::regex(i->main_match);
1444             if (std::regex_match(cur_id_str, rem))
1445             {
1446                 // build the second one only if the first already matched
1447                 HMI_DEBUG("wm", "%d sub_match '%s'", new_id_layer, i->sub_match.c_str());
1448                 auto res = std::regex(i->sub_match);
1449                 if (std::regex_match(new_id_str, res))
1450                 {
1451                     HMI_DEBUG("wm", "layout matched!");
1452                     return true;
1453                 }
1454             }
1455         }
1456     }
1457
1458     return false;
1459 }
1460
1461 void App::try_layout(struct LayoutState & /*state*/,
1462                      struct LayoutState const &new_layout,
1463                      std::function<void(LayoutState const &nl)> apply)
1464 {
1465     if (this->policy.layout_is_valid(new_layout))
1466     {
1467         apply(new_layout);
1468     }
1469 }
1470
1471 /**
1472  * controller_hooks
1473  */
1474 void controller_hooks::surface_created(uint32_t surface_id)
1475 {
1476     this->app->surface_created(surface_id);
1477 }
1478
1479 void controller_hooks::surface_removed(uint32_t surface_id)
1480 {
1481     this->app->surface_removed(surface_id);
1482 }
1483
1484 void controller_hooks::surface_visibility(uint32_t /*surface_id*/,
1485                                           uint32_t /*v*/) {}
1486
1487 void controller_hooks::surface_destination_rectangle(uint32_t /*surface_id*/,
1488                                                      uint32_t /*x*/,
1489                                                      uint32_t /*y*/,
1490                                                      uint32_t /*w*/,
1491                                                      uint32_t /*h*/) {}
1492
1493 } // namespace wm